Package org.apache.iceberg.flink.sink.shuffle

Class DataStatisticsCoordinatorProvider

java.lang.Object

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

org.apache.iceberg.flink.sink.shuffle.DataStatisticsCoordinatorProvider

All Implemented Interfaces:

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

@Internal
public class DataStatisticsCoordinatorProvider
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	Description
DataStatisticsCoordinatorProvider(String operatorName, org.apache.flink.runtime.jobgraph.OperatorID operatorID, Schema schema, SortOrder sortOrder, int downstreamParallelism, StatisticsType type, double closeFileCostWeightPercentage)

Method Summary

Modifier and Type	Method	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 Details

DataStatisticsCoordinatorProvider

public DataStatisticsCoordinatorProvider(String operatorName,
 org.apache.flink.runtime.jobgraph.OperatorID operatorID,
 Schema schema,
 SortOrder sortOrder,
 int downstreamParallelism,
 StatisticsType type,
 double closeFileCostWeightPercentage)

Method Details

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