org.apache.iceberg.flink.sink.shuffle

Class DataStatisticsCoordinatorProvider<D extends org.apache.iceberg.flink.sink.shuffle.DataStatistics<D,S>,S>

java.lang.Object

org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator.Provider

org.apache.iceberg.flink.sink.shuffle.DataStatisticsCoordinatorProvider<D,S>

All Implemented Interfaces:

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

@Internal
public class DataStatisticsCoordinatorProvider<D extends org.apache.iceberg.flink.sink.shuffle.DataStatistics<D,S>,S>
extends org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator.Provider

DataStatisticsCoordinatorProvider provides the method to create new DataStatisticsCoordinator

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DataStatisticsCoordinatorProvider(java.lang.String operatorName, org.apache.flink.runtime.jobgraph.OperatorID operatorID, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.iceberg.flink.sink.shuffle.DataStatistics<D,S>> statisticsSerializer)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.runtime.operators.coordination.OperatorCoordinator	getCoordinator(org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context)

Methods inherited from class org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator.Provider

create, create, getOperatorId

Methods inherited from class java.lang.Object

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

Constructor Detail

DataStatisticsCoordinatorProvider

public DataStatisticsCoordinatorProvider(java.lang.String operatorName,
                                         org.apache.flink.runtime.jobgraph.OperatorID operatorID,
                                         org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.iceberg.flink.sink.shuffle.DataStatistics<D,S>> statisticsSerializer)

Method Detail

getCoordinator

public org.apache.flink.runtime.operators.coordination.OperatorCoordinator getCoordinator(org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Context context)

Specified by:

getCoordinator in class org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator.Provider