Package org.apache.flink.streaming.api.operators

Interface OneInputStreamOperatorFactory<IN,OUT>

Type Parameters:

IN - The input type of the operator.

OUT - The output type of the operator.

All Superinterfaces:

Serializable, StreamOperatorFactory<OUT>

All Known Implementing Classes:

AsyncWaitOperatorFactory, CommitterOperatorFactory, CompactCoordinatorFactory, CompactCoordinatorStateHandlerFactory, CompactorOperatorFactory, CompactorOperatorStateHandlerFactory, ContinuousFileReaderOperatorFactory, EvictingWindowOperatorFactory, SinkWriterOperatorFactory, TimestampsAndWatermarksOperatorFactory, WatermarkAssignerOperatorFactory, WindowOperatorFactory

public interface OneInputStreamOperatorFactory<IN,OUT>
extends StreamOperatorFactory<OUT>

A factory to create OneInputStreamOperator.

Method Summary

Methods inherited from interface org.apache.flink.streaming.api.operators.StreamOperatorFactory

createStreamOperator, getChainingStrategy, getOperatorAttributes, getStreamOperatorClass, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, setInputType, setOutputType