org.apache.flink.runtime.operators.coordination

Interface OperatorCoordinator.Provider

All Superinterfaces:

Serializable

All Known Implementing Classes:

CollectSinkOperatorCoordinator.Provider, RecreateOnResetOperatorCoordinator.Provider, SourceCoordinatorProvider

Enclosing interface:

OperatorCoordinator

public static interface OperatorCoordinator.Provider
extends Serializable

The provider creates an OperatorCoordinator and takes a OperatorCoordinator.Context to pass to the OperatorCoordinator. This method is, for example, called on the job manager when the scheduler and execution graph are created, to instantiate the OperatorCoordinator.

The factory is Serializable, because it is attached to the JobGraph and is part of the serialized job graph that is sent to the dispatcher, or stored for recovery.

Method Summary

Modifier and Type	Method and Description
OperatorCoordinator	create(OperatorCoordinator.Context context) Creates the OperatorCoordinator, using the given context.
OperatorID	getOperatorId() Gets the ID of the operator to which the coordinator belongs.

Method Detail

getOperatorId

OperatorID getOperatorId()

Gets the ID of the operator to which the coordinator belongs.

create

OperatorCoordinator create(OperatorCoordinator.Context context)
                    throws Exception

Creates the OperatorCoordinator, using the given context.

Throws:

Exception