org.apache.flink.streaming.api.operators

类 SourceOperatorFactory<OUT>

java.lang.Object

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

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

所有已实现的接口:

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

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

The Factory class for SourceOperator.

另请参阅:

序列化表格

字段概要

从类继承的字段 org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory

chainingStrategy, processingTimeService

构造器概要

构造器

构造器和说明
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)

方法概要

限定符和类型	方法和说明
<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	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(org.apache.flink.api.common.typeinfo.TypeInformation<OUT> type, org.apache.flink.api.common.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.

从类继承的方法 org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory

getChainingStrategy, getMailboxExecutor, setChainingStrategy, setMailboxExecutor, setProcessingTimeService

从类继承的方法 java.lang.Object

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

从接口继承的方法 org.apache.flink.streaming.api.operators.StreamOperatorFactory

getChainingStrategy, getOperatorAttributes, isInputTypeConfigurable, isLegacySource, setChainingStrategy, setInputType

从接口继承的方法 org.apache.flink.streaming.runtime.tasks.ProcessingTimeServiceAware

setProcessingTimeService

构造器详细资料

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)

方法详细资料

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)

从接口复制的说明: CoordinatedOperatorFactory

The implementation should return an instance of OperatorEventHandler.

指定者:

createStreamOperator 在接口中 CoordinatedOperatorFactory<OUT>

指定者:

createStreamOperator 在接口中 StreamOperatorFactory<OUT>

getCoordinatorProvider

public org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Provider getCoordinatorProvider(String operatorName,
                                                                                                           org.apache.flink.runtime.jobgraph.OperatorID operatorID)

从接口复制的说明: CoordinatedOperatorFactory

Get the operator coordinator provider for this operator.

指定者:

getCoordinatorProvider 在接口中 CoordinatedOperatorFactory<OUT>

参数:

operatorName - the name of the operator.

operatorID - the id of the operator.

返回:

the provider of the OperatorCoordinator for this operator.

getStreamOperatorClass

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

从接口复制的说明: StreamOperatorFactory

Returns the runtime class of the stream operator.

指定者:

getStreamOperatorClass 在接口中 StreamOperatorFactory<OUT>

isStreamSource

public boolean isStreamSource()

从接口复制的说明: StreamOperatorFactory

Is this factory for StreamSource.

指定者:

isStreamSource 在接口中 StreamOperatorFactory<OUT>

isOutputTypeConfigurable

public boolean isOutputTypeConfigurable()

从接口复制的说明: 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.

指定者:

isOutputTypeConfigurable 在接口中 StreamOperatorFactory<OUT>

setOutputType

public void setOutputType(org.apache.flink.api.common.typeinfo.TypeInformation<OUT> type,
                          org.apache.flink.api.common.ExecutionConfig executionConfig)

从接口复制的说明: 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.

指定者:

setOutputType 在接口中 StreamOperatorFactory<OUT>

参数:

type - Output type information of the StreamTask

executionConfig - Execution configuration