Package org.apache.iceberg.flink.sink.shuffle
package org.apache.iceberg.flink.sink.shuffle
-
ClassDescriptionDataStatisticsCoordinatorProvider provides the method to create new
DataStatisticsCoordinator
DataStatisticsOperator collects traffic distribution statistics.The wrapper class for data statistics and record.Range distribution requires gathering statistics on the sort keys to determine proper range boundaries to distribute/cluster rows before writer operators.