Package 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	Description
SourceOperatorFactory(org.apache.flink.api.connector.source.Source<OUT,?,?> source, org.apache.flink.api.common.eventtime.WatermarkStrategy<OUT> watermarkStrategy)
SourceOperatorFactory(org.apache.flink.api.connector.source.Source<OUT,?,?> source, org.apache.flink.api.common.eventtime.WatermarkStrategy<OUT> watermarkStrategy, boolean emitProgressiveWatermarks)
SourceOperatorFactory(org.apache.flink.api.connector.source.Source<OUT,?,?> source, org.apache.flink.api.common.eventtime.WatermarkStrategy<OUT> watermarkStrategy, boolean emitProgressiveWatermarks, int numCoordinatorWorkerThread)

Method Summary

Modifier and Type	Method	Description
<T extends StreamOperator<OUT>> T	createStreamOperator(StreamOperatorParameters<OUT> parameters)	The implementation should return an instance of OperatorEventHandler.
org.apache.flink.api.connector.source.Boundedness	getBoundedness()
org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Provider	getCoordinatorProvider(String operatorName, org.apache.flink.runtime.jobgraph.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	isStreamSource()	Is this factory for StreamSource.
void	setCoordinatorListeningID(String coordinatorListeningID)

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.runtime.tasks.ProcessingTimeServiceAware

setProcessingTimeService

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

getChainingStrategy, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, setChainingStrategy, setInputType, setOutputType

Constructor Detail

SourceOperatorFactory

public SourceOperatorFactory(org.apache.flink.api.connector.source.Source<OUT,?,?> source,
                             org.apache.flink.api.common.eventtime.WatermarkStrategy<OUT> watermarkStrategy)

SourceOperatorFactory

public SourceOperatorFactory(org.apache.flink.api.connector.source.Source<OUT,?,?> source,
                             org.apache.flink.api.common.eventtime.WatermarkStrategy<OUT> watermarkStrategy,
                             boolean emitProgressiveWatermarks)

SourceOperatorFactory

public SourceOperatorFactory(org.apache.flink.api.connector.source.Source<OUT,?,?> source,
                             org.apache.flink.api.common.eventtime.WatermarkStrategy<OUT> watermarkStrategy,
                             boolean emitProgressiveWatermarks,
                             int numCoordinatorWorkerThread)

Method Detail

getBoundedness

public org.apache.flink.api.connector.source.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 org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Provider getCoordinatorProvider(String operatorName,
                                                                                                           org.apache.flink.runtime.jobgraph.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>