org.apache.flink.streaming.api.operators

Class SimpleOperatorFactory<OUT>

java.lang.Object

org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<OUT>

org.apache.flink.streaming.api.operators.SimpleOperatorFactory<OUT>

Type Parameters:

OUT - The output type of the operator

All Implemented Interfaces:

Serializable, StreamOperatorFactory<OUT>, ProcessingTimeServiceAware

Direct Known Subclasses:

SimpleInputFormatOperatorFactory, SimpleOutputFormatOperatorFactory, SimpleUdfStreamOperatorFactory

@Internal
public class SimpleOperatorFactory<OUT>
extends AbstractStreamOperatorFactory<OUT>

Simple factory which just wrap existed StreamOperator.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory

chainingStrategy, processingTimeService

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SimpleOperatorFactory(StreamOperator<OUT> operator)

Method Summary

Modifier and Type	Method and Description
<T extends StreamOperator<OUT>> T	createStreamOperator(StreamOperatorParameters<OUT> parameters) Create the operator.
StreamOperator<OUT>	getOperator()
OperatorAttributes	getOperatorAttributes() Is called to get the OperatorAttributes of the operator.
Class<? extends StreamOperator>	getStreamOperatorClass(ClassLoader classLoader) Returns the runtime class of the stream operator.
boolean	isInputTypeConfigurable() If the stream operator need to be configured with the data type they will operate on.
boolean	isLegacySource()
boolean	isOutputTypeConfigurable() If the stream operator need access to the output type information at StreamGraph generation.
boolean	isStreamSource() Is this factory for StreamSource.
static <OUT> SimpleOperatorFactory<OUT>	of(StreamOperator<OUT> operator) Create a SimpleOperatorFactory from existed StreamOperator.
void	setChainingStrategy(ChainingStrategy strategy) Set the chaining strategy for operator factory.
void	setInputType(TypeInformation<?> type, ExecutionConfig executionConfig) Is called by the StreamGraph.addOperator(java.lang.Integer, java.lang.String, java.lang.String, org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT>, org.apache.flink.api.common.typeinfo.TypeInformation<IN>, org.apache.flink.api.common.typeinfo.TypeInformation<OUT>, java.lang.String) method when the StreamGraph is generated.
void	setOutputType(TypeInformation<OUT> type, ExecutionConfig executionConfig) Is called by the StreamGraph.addOperator(java.lang.Integer, java.lang.String, java.lang.String, org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT>, org.apache.flink.api.common.typeinfo.TypeInformation<IN>, org.apache.flink.api.common.typeinfo.TypeInformation<OUT>, java.lang.String) method when the StreamGraph is generated.

Methods inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory

getChainingStrategy, getMailboxExecutor, setMailboxExecutor, setProcessingTimeService

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SimpleOperatorFactory

protected SimpleOperatorFactory(StreamOperator<OUT> operator)

Method Detail

of

public static <OUT> SimpleOperatorFactory<OUT> of(StreamOperator<OUT> operator)

Create a SimpleOperatorFactory from existed StreamOperator.

getOperator

public StreamOperator<OUT> getOperator()

createStreamOperator

public <T extends StreamOperator<OUT>> T createStreamOperator(StreamOperatorParameters<OUT> parameters)

Description copied from interface: StreamOperatorFactory

Create the operator. Sets access to the context and the output.

setChainingStrategy

public void setChainingStrategy(ChainingStrategy strategy)

Description copied from interface: StreamOperatorFactory

Set the chaining strategy for operator factory.

Specified by:

setChainingStrategy in interface StreamOperatorFactory<OUT>

Overrides:

setChainingStrategy in class AbstractStreamOperatorFactory<OUT>

isStreamSource

public boolean isStreamSource()

Description copied from interface: StreamOperatorFactory

Is this factory for StreamSource.

isLegacySource

public boolean isLegacySource()

isOutputTypeConfigurable

public boolean isOutputTypeConfigurable()

Description copied from interface: StreamOperatorFactory

If the stream operator need access to the output type information at StreamGraph generation. This can be useful for cases where the output type is specified by the returns method and, thus, after the stream operator has been created.

setOutputType

public void setOutputType(TypeInformation<OUT> type,
                          ExecutionConfig executionConfig)

Description copied from interface: StreamOperatorFactory

Is called by the StreamGraph.addOperator(java.lang.Integer, java.lang.String, java.lang.String, org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT>, org.apache.flink.api.common.typeinfo.TypeInformation<IN>, org.apache.flink.api.common.typeinfo.TypeInformation<OUT>, java.lang.String) method when the StreamGraph is generated. The method is called with the output TypeInformation which is also used for the StreamTask output serializer.

Parameters:

type - Output type information of the StreamTask

executionConfig - Execution configuration

isInputTypeConfigurable

public boolean isInputTypeConfigurable()

Description copied from interface: StreamOperatorFactory

If the stream operator need to be configured with the data type they will operate on.

setInputType

public void setInputType(TypeInformation<?> type,
                         ExecutionConfig executionConfig)

Description copied from interface: StreamOperatorFactory

Is called by the StreamGraph.addOperator(java.lang.Integer, java.lang.String, java.lang.String, org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT>, org.apache.flink.api.common.typeinfo.TypeInformation<IN>, org.apache.flink.api.common.typeinfo.TypeInformation<OUT>, java.lang.String) method when the StreamGraph is generated.

Parameters:

type - The data type of the input.

executionConfig - The execution config for this parallel execution.

getStreamOperatorClass

public Class<? extends StreamOperator> getStreamOperatorClass(ClassLoader classLoader)

Description copied from interface: StreamOperatorFactory

Returns the runtime class of the stream operator.

getOperatorAttributes

public OperatorAttributes getOperatorAttributes()

Description copied from interface: StreamOperatorFactory

Is called to get the OperatorAttributes of the operator. OperatorAttributes can inform the frame to optimize the job performance.

Returns:

OperatorAttributes of the operator.