接口的使用
org.apache.flink.streaming.runtime.operators.asyncprocessing.AsyncStateProcessingOperator

使用AsyncStateProcessingOperator的程序包

程序包	说明
org.apache.flink.streaming.runtime.operators.asyncprocessing

org.apache.flink.streaming.runtime.operators.asyncprocessing中AsyncStateProcessingOperator的使用

实现AsyncStateProcessingOperator的org.apache.flink.streaming.runtime.operators.asyncprocessing中的类

限定符和类型	类和说明
class	AbstractAsyncStateStreamOperator<OUT> This operator is an abstract class that give the AbstractStreamOperator the ability to perform AsyncStateProcessing.
class	AbstractAsyncStateStreamOperatorV2<OUT> This operator is an abstract class that give the AbstractStreamOperatorV2 the ability to perform AsyncStateProcessing.
class	AbstractAsyncStateUdfStreamOperator<OUT,F extends org.apache.flink.api.common.functions.Function> This is used as the base class for operators that have a user-defined function.

参数类型为AsyncStateProcessingOperator的org.apache.flink.streaming.runtime.operators.asyncprocessing中的方法

限定符和类型	方法和说明
static <T> org.apache.flink.util.function.ThrowingConsumer<StreamRecord<T>,Exception>	AsyncStateProcessing.makeRecordProcessor(AsyncStateProcessingOperator asyncOperator, org.apache.flink.api.java.functions.KeySelector<T,?> keySelector, org.apache.flink.util.function.ThrowingConsumer<StreamRecord<T>,Exception> processor) Static method helper to make a record processor with given infos.