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

Packages that use OneInputStreamOperatorFactory

Package	Description
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

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	Description
<R> SingleOutputStreamOperator<R>	DataStream.transform(String operatorName, org.apache.flink.api.common.typeinfo.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	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	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	Description
class	CommitterOperatorFactory<CommT>	A StreamOperatorFactory for CommitterOperator.
class	SinkWriterOperatorFactory<InputT,CommT>	A StreamOperatorFactory for SinkWriterOperator.