Uses of Interface
org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory

Packages that use OneInputStreamOperatorFactory

Package	Description
org.apache.flink.connector.file.sink.compactor.operator
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.operators.async
org.apache.flink.streaming.runtime.operators.sink
org.apache.flink.table.runtime.operators.wmassigners

Uses of OneInputStreamOperatorFactory in org.apache.flink.connector.file.sink.compactor.operator

Classes in org.apache.flink.connector.file.sink.compactor.operator that implement OneInputStreamOperatorFactory

Modifier and Type	Class and Description
class	CompactCoordinatorFactory Factory for CompactCoordinator.
class	CompactCoordinatorStateHandlerFactory Factory for CompactCoordinatorStateHandler.
class	CompactorOperatorFactory Factory for CompactorOperator.
class	CompactorOperatorStateHandlerFactory Factory for CompactorOperatorStateHandler.

Uses of OneInputStreamOperatorFactory in org.apache.flink.streaming.api.datastream

Methods in org.apache.flink.streaming.api.datastream with parameters of type OneInputStreamOperatorFactory

Modifier and Type	Method and Description
<R> SingleOutputStreamOperator<R>	DataStream.transform(String operatorName, TypeInformation<R> outTypeInfo, OneInputStreamOperatorFactory<T,R> operatorFactory) Method for passing user defined operators created by the given factory along with the type information that will transform the DataStream.

Uses of OneInputStreamOperatorFactory in org.apache.flink.streaming.api.functions.source

Classes in org.apache.flink.streaming.api.functions.source that implement OneInputStreamOperatorFactory

Modifier and Type	Class and Description
class	ContinuousFileReaderOperatorFactory<OUT,T extends TimestampedInputSplit> ContinuousFileReaderOperator factory.

Uses of OneInputStreamOperatorFactory in org.apache.flink.streaming.api.operators.async

Classes in org.apache.flink.streaming.api.operators.async that implement OneInputStreamOperatorFactory

Modifier and Type	Class and Description
class	AsyncWaitOperatorFactory<IN,OUT> The factory of AsyncWaitOperator.

Uses of OneInputStreamOperatorFactory in org.apache.flink.streaming.runtime.operators.sink

Classes in org.apache.flink.streaming.runtime.operators.sink that implement OneInputStreamOperatorFactory

Modifier and Type	Class and Description
class	CommitterOperatorFactory<CommT> A StreamOperatorFactory for CommitterOperator.
class	SinkWriterOperatorFactory<InputT,CommT> A StreamOperatorFactory for SinkWriterOperator.

Uses of OneInputStreamOperatorFactory in org.apache.flink.table.runtime.operators.wmassigners

Classes in org.apache.flink.table.runtime.operators.wmassigners that implement OneInputStreamOperatorFactory

Modifier and Type	Class and Description
class	WatermarkAssignerOperatorFactory The factory of WatermarkAssignerOperator.