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.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.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.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>	DataStream.doTransform(String operatorName, TypeInformation<R> outTypeInfo, StreamOperatorFactory<R> operatorFactory)
protected <R> SingleOutputStreamOperator<R>	KeyedStream.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)

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 that return types with arguments of type StreamOperatorFactory

Modifier and Type	Method and Description
Set<Tuple2<Integer,StreamOperatorFactory<?>>>	StreamGraph.getAllOperatorFactory()

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> 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> An operator that needs access to the MailboxExecutor to yield to downstream operators needs to be created through a factory implementing this interface.

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> A simple operator factory which create StreamSink 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<T>	LegacySourceTransformation.getOperatorFactory() Returns the StreamOperatorFactory of this LegacySourceTransformation.
StreamOperatorFactory<Object>	LegacySinkTransformation.getOperatorFactory() Returns the StreamOperatorFactory of this LegacySinkTransformation.
StreamOperatorFactory<OUT>	AbstractMultipleInputTransformation.getOperatorFactory() Returns the StreamOperatorFactory of this Transformation.
StreamOperatorFactory<OUT>	OneInputTransformation.getOperatorFactory() Returns the StreamOperatorFactory of this Transformation.
StreamOperatorFactory<OUT>	TwoInputTransformation.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)
KeyedMultipleInputTransformation(String name, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<OUT> outputType, int parallelism, TypeInformation<?> stateKeyType)
LegacySinkTransformation(Transformation<T> input, String name, StreamOperatorFactory<Object> operatorFactory, int parallelism)
LegacySourceTransformation(String name, StreamOperatorFactory<T> operatorFactory, TypeInformation<T> outputType, int parallelism, Boundedness boundedness)
MultipleInputTransformation(String name, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<OUT> outputType, int parallelism)
OneInputTransformation(Transformation<IN> input, 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)

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) 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) 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) 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) 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) 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.

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.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.