org.apache.flink.streaming.api.operators.collect

Class CollectSinkOperatorCoordinator.Provider

java.lang.Object

org.apache.flink.streaming.api.operators.collect.CollectSinkOperatorCoordinator.Provider

All Implemented Interfaces:

Serializable, OperatorCoordinator.Provider

Enclosing class:

CollectSinkOperatorCoordinator

public static class CollectSinkOperatorCoordinator.Provider
extends Object
implements OperatorCoordinator.Provider

Provider for CollectSinkOperatorCoordinator.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Provider(OperatorID operatorId, int socketTimeout)

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

Provider

public Provider(OperatorID operatorId,
                int socketTimeout)

Method Detail

getOperatorId

public OperatorID getOperatorId()

Description copied from interface: OperatorCoordinator.Provider

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

Specified by:

getOperatorId in interface OperatorCoordinator.Provider

create

public OperatorCoordinator create(OperatorCoordinator.Context context)

Description copied from interface: OperatorCoordinator.Provider

Creates the OperatorCoordinator, using the given context.

Specified by:

create in interface OperatorCoordinator.Provider