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

Class DataStatisticsCoordinatorProvider<D extends org.apache.iceberg.flink.sink.shuffle.DataStatistics<D,​S>,​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 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

      All Methods Instance Methods Concrete Methods 
      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 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