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

Packages that use StreamOperatorFactory

Package	Description
org.apache.flink.connector.file.sink.compactor.operator
org.apache.flink.datastream.impl.utils
org.apache.flink.python.util
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.graph
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.async
org.apache.flink.streaming.api.operators.collect
org.apache.flink.streaming.api.transformations
org.apache.flink.streaming.runtime.operators.sink
org.apache.flink.streaming.runtime.translators
org.apache.flink.table.planner.plan.nodes.exec.utils
org.apache.flink.table.runtime.operators
org.apache.flink.table.runtime.operators.dynamicfiltering
org.apache.flink.table.runtime.operators.fusion
org.apache.flink.table.runtime.operators.multipleinput
org.apache.flink.table.runtime.operators.wmassigners

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

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

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 StreamOperatorFactory in org.apache.flink.datastream.impl.utils

Methods in org.apache.flink.datastream.impl.utils with parameters of type StreamOperatorFactory

Modifier and Type	Method and Description
static <T,R> AbstractDataStream<R>	StreamUtils.transformOneInputOperator(String operatorName, AbstractDataStream<T> inputStream, TypeInformation<R> outTypeInfo, StreamOperatorFactory<R> operatorFactory) Construct and return a new DataStream with one input operator.

Uses of StreamOperatorFactory in org.apache.flink.python.util

Methods in org.apache.flink.python.util that return StreamOperatorFactory

Modifier and Type	Method and Description
static StreamOperatorFactory<?>	PythonConfigUtil.getOperatorFactory(Transformation<?> transform)

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

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

Modifier and Type	Method and Description
protected <R> SingleOutputStreamOperator<R>	KeyedStream.doTransform(String operatorName, TypeInformation<R> outTypeInfo, StreamOperatorFactory<R> operatorFactory)
protected <R> SingleOutputStreamOperator<R>	DataStream.doTransform(String operatorName, TypeInformation<R> outTypeInfo, StreamOperatorFactory<R> operatorFactory)

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

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

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

Uses of StreamOperatorFactory in org.apache.flink.streaming.api.graph

Methods in org.apache.flink.streaming.api.graph with type parameters of type StreamOperatorFactory

Modifier and Type	Method and Description
<T extends StreamOperatorFactory<?>> T	StreamConfig.getStreamOperatorFactory(ClassLoader cl)
<T extends StreamOperatorFactory<?>> Class<T>	StreamConfig.getStreamOperatorFactoryClass(ClassLoader cl)

Methods in org.apache.flink.streaming.api.graph that return StreamOperatorFactory

Modifier and Type	Method and Description
StreamOperatorFactory<?>	StreamNode.getOperatorFactory()

Methods in org.apache.flink.streaming.api.graph with parameters of type StreamOperatorFactory

Modifier and Type	Method and Description
<IN1,IN2,OUT> void	StreamGraph.addCoOperator(Integer vertexID, String slotSharingGroup, String coLocationGroup, StreamOperatorFactory<OUT> taskOperatorFactory, TypeInformation<IN1> in1TypeInfo, TypeInformation<IN2> in2TypeInfo, TypeInformation<OUT> outTypeInfo, String operatorName)
<IN,OUT> void	StreamGraph.addLegacySource(Integer vertexID, String slotSharingGroup, String coLocationGroup, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<IN> inTypeInfo, TypeInformation<OUT> outTypeInfo, String operatorName)
<OUT> void	StreamGraph.addMultipleInputOperator(Integer vertexID, String slotSharingGroup, String coLocationGroup, StreamOperatorFactory<OUT> operatorFactory, List<TypeInformation<?>> inTypeInfos, TypeInformation<OUT> outTypeInfo, String operatorName)
protected StreamNode	StreamGraph.addNode(Integer vertexID, String slotSharingGroup, String coLocationGroup, Class<? extends TaskInvokable> vertexClass, StreamOperatorFactory<?> operatorFactory, String operatorName)
<IN,OUT> void	StreamGraph.addOperator(Integer vertexID, String slotSharingGroup, String coLocationGroup, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<IN> inTypeInfo, TypeInformation<OUT> outTypeInfo, String operatorName)
<IN,OUT> void	StreamGraph.addSink(Integer vertexID, String slotSharingGroup, String coLocationGroup, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<IN> inTypeInfo, TypeInformation<OUT> outTypeInfo, String operatorName)
void	StreamConfig.setStreamOperatorFactory(StreamOperatorFactory<?> factory)

Constructors in org.apache.flink.streaming.api.graph with parameters of type StreamOperatorFactory

Constructor and Description
StreamNode(Integer id, String slotSharingGroup, String coLocationGroup, StreamOperatorFactory<?> operatorFactory, String operatorName, Class<? extends TaskInvokable> jobVertexClass)

Uses of StreamOperatorFactory in org.apache.flink.streaming.api.operators

Subinterfaces of StreamOperatorFactory in org.apache.flink.streaming.api.operators

Modifier and Type	Interface and Description
interface	CoordinatedOperatorFactory<OUT> A factory class for the StreamOperators implementing OperatorEventHandler.
interface	InputFormatOperatorFactory<OUT> Input format source operator factory.
interface	OneInputStreamOperatorFactory<IN,OUT> A factory to create OneInputStreamOperator.
interface	OutputFormatOperatorFactory<IN,OUT> Interface for operator factories which create the sink operator containing an OutputFormat.
interface	TwoInputStreamOperatorFactory<IN1,IN2,OUT> A factory to create TwoInputStreamOperator.
interface	UdfStreamOperatorFactory<OUT> Udf stream operator factory.
interface	YieldingOperatorFactory<OUT> Deprecated.

Classes in org.apache.flink.streaming.api.operators that implement StreamOperatorFactory

Modifier and Type	Class and Description
class	AbstractStreamOperatorFactory<OUT> Base class for all stream operator factories.
class	SimpleInputFormatOperatorFactory<OUT> Input format source operator factory which just wrap existed StreamSource.
class	SimpleOperatorFactory<OUT> Simple factory which just wrap existed StreamOperator.
class	SimpleOutputFormatOperatorFactory<IN,OUT> A simple operator factory which create an operator containing an OutputFormat.
class	SimpleUdfStreamOperatorFactory<OUT> Udf stream operator factory which just wrap existed AbstractUdfStreamOperator.
class	SourceOperatorFactory<OUT> The Factory class for SourceOperator.

Methods in org.apache.flink.streaming.api.operators with parameters of type StreamOperatorFactory

Modifier and Type	Method and Description
static <OUT,OP extends StreamOperator<OUT>> Tuple2<OP,Optional<ProcessingTimeService>>	StreamOperatorFactoryUtil.createOperator(StreamOperatorFactory<OUT> operatorFactory, StreamTask<OUT,?> containingTask, StreamConfig configuration, Output<StreamRecord<OUT>> output, OperatorEventDispatcher operatorEventDispatcher) Creates a new operator using a factory and makes sure that all special factory traits are properly handled.

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

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

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

Uses of StreamOperatorFactory in org.apache.flink.streaming.api.operators.collect

Classes in org.apache.flink.streaming.api.operators.collect that implement StreamOperatorFactory

Modifier and Type	Class and Description
class	CollectSinkOperatorFactory<IN> The Factory class for CollectSinkOperator.

Uses of StreamOperatorFactory in org.apache.flink.streaming.api.transformations

Fields in org.apache.flink.streaming.api.transformations declared as StreamOperatorFactory

Modifier and Type	Field and Description
protected StreamOperatorFactory<OUT>	AbstractMultipleInputTransformation.operatorFactory

Methods in org.apache.flink.streaming.api.transformations that return StreamOperatorFactory

Modifier and Type	Method and Description
StreamOperatorFactory<OUT>	TwoInputTransformation.getOperatorFactory() Returns the StreamOperatorFactory of this Transformation.
StreamOperatorFactory<OUT>	AbstractMultipleInputTransformation.getOperatorFactory() Returns the StreamOperatorFactory of this Transformation.
StreamOperatorFactory<Object>	LegacySinkTransformation.getOperatorFactory() Returns the StreamOperatorFactory of this LegacySinkTransformation.
StreamOperatorFactory<T>	LegacySourceTransformation.getOperatorFactory() Returns the StreamOperatorFactory of this LegacySourceTransformation.
StreamOperatorFactory<OUT>	OneInputTransformation.getOperatorFactory() Returns the StreamOperatorFactory of this Transformation.

Constructors in org.apache.flink.streaming.api.transformations with parameters of type StreamOperatorFactory

Constructor and Description
AbstractMultipleInputTransformation(String name, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<OUT> outputType, int parallelism)
AbstractMultipleInputTransformation(String name, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<OUT> outputType, int parallelism, boolean parallelismConfigured)
KeyedMultipleInputTransformation(String name, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<OUT> outputType, int parallelism, TypeInformation<?> stateKeyType)
LegacySinkTransformation(Transformation<T> input, String name, StreamOperatorFactory<Object> operatorFactory, int parallelism)
LegacySinkTransformation(Transformation<T> input, String name, StreamOperatorFactory<Object> operatorFactory, int parallelism, boolean parallelismConfigured)
MultipleInputTransformation(String name, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<OUT> outputType, int parallelism)
MultipleInputTransformation(String name, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<OUT> outputType, int parallelism, boolean parallelismConfigured)
OneInputTransformation(Transformation<IN> input, String name, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<OUT> outputType, int parallelism)
OneInputTransformation(Transformation<IN> input, String name, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<OUT> outputType, int parallelism, boolean parallelismConfigured) Creates a new LegacySinkTransformation from the given input Transformation.
TwoInputTransformation(Transformation<IN1> input1, Transformation<IN2> input2, String name, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<OUT> outputType, int parallelism)
TwoInputTransformation(Transformation<IN1> input1, Transformation<IN2> input2, String name, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<OUT> outputType, int parallelism, boolean parallelismConfigured) Creates a new TwoInputTransformation from the given inputs and operator.

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

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

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

Uses of StreamOperatorFactory in org.apache.flink.streaming.runtime.translators

Methods in org.apache.flink.streaming.runtime.translators with parameters of type StreamOperatorFactory

Modifier and Type	Method and Description
protected Collection<Integer>	AbstractTwoInputTransformationTranslator.translateInternal(Transformation<OUT> transformation, Transformation<IN1> firstInputTransformation, Transformation<IN2> secondInputTransformation, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<?> keyTypeInfo, KeySelector<IN1,?> firstKeySelector, KeySelector<IN2,?> secondKeySelector, TransformationTranslator.Context context)

Uses of StreamOperatorFactory in org.apache.flink.table.planner.plan.nodes.exec.utils

Methods in org.apache.flink.table.planner.plan.nodes.exec.utils with parameters of type StreamOperatorFactory

Modifier and Type	Method and Description
static <I,O> OneInputTransformation<I,O>	ExecNodeUtil.createOneInputTransformation(Transformation<I> input, String name, String desc, StreamOperatorFactory<O> operatorFactory, TypeInformation<O> outputType, int parallelism, boolean parallelismConfigured) Create a OneInputTransformation.
static <I,O> OneInputTransformation<I,O>	ExecNodeUtil.createOneInputTransformation(Transformation<I> input, String name, String desc, StreamOperatorFactory<O> operatorFactory, TypeInformation<O> outputType, int parallelism, long memoryBytes, boolean parallelismConfigured) Create a OneInputTransformation with memoryBytes.
static <I,O> OneInputTransformation<I,O>	ExecNodeUtil.createOneInputTransformation(Transformation<I> input, TransformationMetadata transformationMeta, StreamOperatorFactory<O> operatorFactory, TypeInformation<O> outputType, int parallelism, boolean parallelismConfigured) Create a OneInputTransformation.
static <I,O> OneInputTransformation<I,O>	ExecNodeUtil.createOneInputTransformation(Transformation<I> input, TransformationMetadata transformationMeta, StreamOperatorFactory<O> operatorFactory, TypeInformation<O> outputType, int parallelism, long memoryBytes, boolean parallelismConfigured) Create a OneInputTransformation with memoryBytes.
static <I1,I2,O> TwoInputTransformation<I1,I2,O>	ExecNodeUtil.createTwoInputTransformation(Transformation<I1> input1, Transformation<I2> input2, String name, String desc, StreamOperatorFactory<O> operatorFactory, TypeInformation<O> outputType, int parallelism, long memoryBytes, boolean parallelismConfigured) Create a TwoInputTransformation with memoryBytes.
static <I1,I2,O> TwoInputTransformation<I1,I2,O>	ExecNodeUtil.createTwoInputTransformation(Transformation<I1> input1, Transformation<I2> input2, TransformationMetadata transformationMeta, StreamOperatorFactory<O> operatorFactory, TypeInformation<O> outputType, int parallelism, long memoryBytes) Create a TwoInputTransformation with memoryBytes.
static <I1,I2,O> TwoInputTransformation<I1,I2,O>	ExecNodeUtil.createTwoInputTransformation(Transformation<I1> input1, Transformation<I2> input2, TransformationMetadata transformationMeta, StreamOperatorFactory<O> operatorFactory, TypeInformation<O> outputType, int parallelism, long memoryBytes, boolean parallelismConfigured)

Uses of StreamOperatorFactory in org.apache.flink.table.runtime.operators

Classes in org.apache.flink.table.runtime.operators that implement StreamOperatorFactory

Modifier and Type	Class and Description
class	CodeGenOperatorFactory<OUT> Stream operator factory for code gen operator.

Uses of StreamOperatorFactory in org.apache.flink.table.runtime.operators.dynamicfiltering

Classes in org.apache.flink.table.runtime.operators.dynamicfiltering that implement StreamOperatorFactory

Modifier and Type	Class and Description
class	DynamicFilteringDataCollectorOperatorFactory The factory class for DynamicFilteringDataCollectorOperator.

Uses of StreamOperatorFactory in org.apache.flink.table.runtime.operators.fusion

Classes in org.apache.flink.table.runtime.operators.fusion that implement StreamOperatorFactory

Modifier and Type	Class and Description
class	OperatorFusionCodegenFactory<OUT> Stream operator factory for multiple operator fusion codegen.

Uses of StreamOperatorFactory in org.apache.flink.table.runtime.operators.multipleinput

Classes in org.apache.flink.table.runtime.operators.multipleinput that implement StreamOperatorFactory

Modifier and Type	Class and Description
class	BatchMultipleInputStreamOperatorFactory The factory to create BatchMultipleInputStreamOperator.

Constructors in org.apache.flink.table.runtime.operators.multipleinput with parameters of type StreamOperatorFactory

Constructor and Description
TableOperatorWrapper(StreamOperatorFactory<RowData> factory, String operatorName, List<TypeInformation<?>> allInputTypes, TypeInformation<?> outputType)

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

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

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