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

Class RangePartitioner

java.lang.Object

org.apache.iceberg.flink.sink.shuffle.RangePartitioner

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.Partitioner<StatisticsOrRecord>

@Internal
public class RangePartitioner
extends Object
implements org.apache.flink.api.common.functions.Partitioner<StatisticsOrRecord>

This custom partitioner implements the DistributionMode.RANGE for Flink sink.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
RangePartitioner(Schema schema, SortOrder sortOrder)

Method Summary

Modifier and Type	Method	Description
int	partition(StatisticsOrRecord wrapper, int numPartitions)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RangePartitioner

public RangePartitioner(Schema schema,
 SortOrder sortOrder)

Method Details

partition

public int partition(StatisticsOrRecord wrapper,
 int numPartitions)

Specified by:

partition in interface org.apache.flink.api.common.functions.Partitioner<StatisticsOrRecord>