Package org.apache.flink.streaming.runtime.operators.asyncprocessing
-
Interface Summary Interface Description AsyncStateProcessing This class defines the basic interfaces to process a state in operator/input layer.AsyncStateProcessingOperator A more detailed interface based onAsyncStateProcessing, which gives the essential methods for an operator to perform async state processing. -
Class Summary Class Description AbstractAsyncStateStreamOperator<OUT> This operator is an abstract class that give theAbstractStreamOperatorthe ability to performAsyncStateProcessing.AbstractAsyncStateStreamOperatorV2<OUT> This operator is an abstract class that give theAbstractStreamOperatorV2the ability to performAsyncStateProcessing.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. -
Enum Summary Enum Description ElementOrder This enum defines the element order of being processed.