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

Class Summary

Class	Description
DataStatisticsCoordinatorProvider	DataStatisticsCoordinatorProvider provides the method to create new DataStatisticsCoordinator
DataStatisticsOperator	DataStatisticsOperator collects traffic distribution statistics.
DataStatisticsOperatorFactory
RangePartitioner	This custom partitioner implements the DistributionMode.RANGE for Flink sink.
StatisticsOrRecord	The wrapper class for data statistics and record.

Enum Summary

Enum	Description
StatisticsType	Range distribution requires gathering statistics on the sort keys to determine proper range boundaries to distribute/cluster rows before writer operators.