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

package org.apache.iceberg.flink.sink.shuffle

Related Packages

Package	Description
org.apache.iceberg.flink.sink
org.apache.iceberg.flink.sink.dynamic

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.
StatisticsOrRecordTypeInformation
StatisticsType	Range distribution requires gathering statistics on the sort keys to determine proper range boundaries to distribute/cluster rows before writer operators.