org.apache.flink.streaming.api.operators

Class SourceOperatorFactory<OUT>

java.lang.Object

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

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

All Implemented Interfaces:

Serializable, CoordinatedOperatorFactory<OUT>, StreamOperatorFactory<OUT>, ProcessingTimeServiceAware

public class SourceOperatorFactory<OUT>
extends AbstractStreamOperatorFactory<OUT>
implements CoordinatedOperatorFactory<OUT>, ProcessingTimeServiceAware

The Factory class for SourceOperator.

See Also:

Serialized Form

Field Summary

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

chainingStrategy, processingTimeService

Constructor Summary

Constructors

Constructor and Description
SourceOperatorFactory(Source<OUT,?,?> source, WatermarkStrategy<OUT> watermarkStrategy)
SourceOperatorFactory(Source<OUT,?,?> source, WatermarkStrategy<OUT> watermarkStrategy, boolean emitProgressiveWatermarks)
SourceOperatorFactory(Source<OUT,?,?> source, WatermarkStrategy<OUT> watermarkStrategy, boolean emitProgressiveWatermarks, int numCoordinatorWorkerThread)

Method Summary

Modifier and Type	Method and Description
<T extends StreamOperator<OUT>> T	createStreamOperator(StreamOperatorParameters<OUT> parameters) The implementation should return an instance of OperatorEventHandler.
Boundedness	getBoundedness()
OperatorCoordinator.Provider	getCoordinatorProvider(String operatorName, OperatorID operatorID) Get the operator coordinator provider for this operator.
Class<? extends StreamOperator>	getStreamOperatorClass(ClassLoader classLoader) Returns the runtime class of the stream operator.
boolean	isOutputTypeConfigurable() If the stream operator need access to the output type information at StreamGraph generation.
boolean	isStreamSource() Is this factory for StreamSource.
void	setCoordinatorListeningID(String coordinatorListeningID)
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, setChainingStrategy, setMailboxExecutor, setProcessingTimeService

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.streaming.api.operators.StreamOperatorFactory

getChainingStrategy, getOperatorAttributes, isInputTypeConfigurable, isLegacySource, setChainingStrategy, setInputType

Methods inherited from interface org.apache.flink.streaming.runtime.tasks.ProcessingTimeServiceAware

setProcessingTimeService

Constructor Detail

SourceOperatorFactory

public SourceOperatorFactory(Source<OUT,?,?> source,
                             WatermarkStrategy<OUT> watermarkStrategy)

SourceOperatorFactory

public SourceOperatorFactory(Source<OUT,?,?> source,
                             WatermarkStrategy<OUT> watermarkStrategy,
                             boolean emitProgressiveWatermarks)

SourceOperatorFactory

public SourceOperatorFactory(Source<OUT,?,?> source,
                             WatermarkStrategy<OUT> watermarkStrategy,
                             boolean emitProgressiveWatermarks,
                             int numCoordinatorWorkerThread)

Method Detail

getBoundedness

public Boundedness getBoundedness()

setCoordinatorListeningID

public void setCoordinatorListeningID(@Nullable
                                      String coordinatorListeningID)

createStreamOperator

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

Description copied from interface: CoordinatedOperatorFactory

The implementation should return an instance of OperatorEventHandler.

Specified by:

createStreamOperator in interface CoordinatedOperatorFactory<OUT>

Specified by:

createStreamOperator in interface StreamOperatorFactory<OUT>

getCoordinatorProvider

public OperatorCoordinator.Provider getCoordinatorProvider(String operatorName,
                                                           OperatorID operatorID)

Description copied from interface: CoordinatedOperatorFactory

Get the operator coordinator provider for this operator.

Specified by:

getCoordinatorProvider in interface CoordinatedOperatorFactory<OUT>

Parameters:

operatorName - the name of the operator.

operatorID - the id of the operator.

Returns:

the provider of the OperatorCoordinator for this operator.

getStreamOperatorClass

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

Description copied from interface: StreamOperatorFactory

Returns the runtime class of the stream operator.

Specified by:

getStreamOperatorClass in interface StreamOperatorFactory<OUT>

isStreamSource

public boolean isStreamSource()

Description copied from interface: StreamOperatorFactory

Is this factory for StreamSource.

Specified by:

isStreamSource in interface StreamOperatorFactory<OUT>

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.

Specified by:

isOutputTypeConfigurable in interface StreamOperatorFactory<OUT>

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.

Specified by:

setOutputType in interface StreamOperatorFactory<OUT>

Parameters:

type - Output type information of the StreamTask

executionConfig - Execution configuration