Uses of Class
org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory
-
-
Uses of AbstractStreamOperatorFactory in org.apache.flink.streaming.api.functions.source
Subclasses of AbstractStreamOperatorFactory in org.apache.flink.streaming.api.functions.source Modifier and Type Class Description classContinuousFileReaderOperatorFactory<OUT,T extends TimestampedInputSplit>ContinuousFileReaderOperatorfactory. -
Uses of AbstractStreamOperatorFactory in org.apache.flink.streaming.api.operators
Subclasses of AbstractStreamOperatorFactory in org.apache.flink.streaming.api.operators Modifier and Type Class Description classSimpleInputFormatOperatorFactory<OUT>Input format source operator factory which just wrap existedStreamSource.classSimpleOperatorFactory<OUT>Simple factory which just wrap existedStreamOperator.classSimpleOutputFormatOperatorFactory<IN,OUT>A simple operator factory which create an operator containing anOutputFormat.classSimpleUdfStreamOperatorFactory<OUT>Udf stream operator factory which just wrap existedAbstractUdfStreamOperator.classSourceOperatorFactory<OUT>The Factory class forSourceOperator. -
Uses of AbstractStreamOperatorFactory in org.apache.flink.streaming.api.operators.async
Subclasses of AbstractStreamOperatorFactory in org.apache.flink.streaming.api.operators.async Modifier and Type Class Description classAsyncWaitOperatorFactory<IN,OUT>The factory ofAsyncWaitOperator. -
Uses of AbstractStreamOperatorFactory in org.apache.flink.streaming.api.operators.collect
Subclasses of AbstractStreamOperatorFactory in org.apache.flink.streaming.api.operators.collect Modifier and Type Class Description classCollectSinkOperatorFactory<IN>The Factory class forCollectSinkOperator. -
Uses of AbstractStreamOperatorFactory in org.apache.flink.streaming.runtime.operators.sink
Subclasses of AbstractStreamOperatorFactory in org.apache.flink.streaming.runtime.operators.sink Modifier and Type Class Description classCommitterOperatorFactory<CommT>AStreamOperatorFactoryforCommitterOperator.classSinkWriterOperatorFactory<InputT,CommT>AStreamOperatorFactoryforSinkWriterOperator.
-