CollectSinkOperatorCoordinator.Provider (Flink : Streaming Java 1.18.1-cp5 API)

java.lang.Object
- org.apache.flink.streaming.api.operators.collect.CollectSinkOperatorCoordinator.Provider

All Implemented Interfaces:

Serializable, org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Provider

Enclosing class:

CollectSinkOperatorCoordinator
```
public static class CollectSinkOperatorCoordinator.Provider
extends Object
implements org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Provider
```
Provider for CollectSinkOperatorCoordinator.

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

Provider(org.apache.flink.runtime.jobgraph.OperatorID operatorId, int socketTimeout)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`org.apache.flink.runtime.operators.coordination.OperatorCoordinator`	`create(org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context)`
`org.apache.flink.runtime.jobgraph.OperatorID`	`getOperatorId()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Provider

public Provider(org.apache.flink.runtime.jobgraph.OperatorID operatorId,
                int socketTimeout)

Method Detail
- getOperatorId
```
public org.apache.flink.runtime.jobgraph.OperatorID getOperatorId()
```
  Specified by:
  
  getOperatorId in interface org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Provider
- create
```
public org.apache.flink.runtime.operators.coordination.OperatorCoordinator create(org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context)
```
  Specified by:
  
  create in interface org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Provider