org.apache.flink.streaming.api.operators

Interface CoordinatedOperatorFactory<OUT>

All Superinterfaces:

Serializable, StreamOperatorFactory<OUT>

All Known Implementing Classes:

CollectSinkOperatorFactory, DynamicFilteringDataCollectorOperatorFactory, SourceOperatorFactory

@Internal
public interface CoordinatedOperatorFactory<OUT>
extends StreamOperatorFactory<OUT>

A factory class for the StreamOperators implementing OperatorEventHandler.

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.
OperatorCoordinator.Provider	getCoordinatorProvider(String operatorName, OperatorID operatorID) Get the operator coordinator provider for this operator.

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

getChainingStrategy, getOperatorAttributes, getStreamOperatorClass, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, setInputType, setOutputType

Method Detail

createStreamOperator

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

The implementation should return an instance of OperatorEventHandler.

Specified by:

createStreamOperator in interface StreamOperatorFactory<OUT>

getCoordinatorProvider

OperatorCoordinator.Provider getCoordinatorProvider(String operatorName,
                                                    OperatorID operatorID)

Get the operator coordinator provider for this operator.

Parameters:

operatorName - the name of the operator.

operatorID - the id of the operator.

Returns:

the provider of the OperatorCoordinator for this operator.