Package org.apache.iceberg.flink.sink.shuffle
-
Class Summary Class Description DataStatisticsCoordinatorProvider<D extends org.apache.iceberg.flink.sink.shuffle.DataStatistics<D,S>,S> DataStatisticsCoordinatorProvider provides the method to create newDataStatisticsCoordinator