OperatorCoordinator.Provider (Flink : 2.0-SNAPSHOT API)

All Superinterfaces:

Serializable

All Known Implementing Classes:

CollectSinkOperatorCoordinator.Provider, DynamicFilteringDataCollectorOperatorCoordinator.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

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	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