Package org.apache.paimon.flink.shuffle

Class Summary

Class	Description
RangeShuffle	RangeShuffle Util to shuffle the input stream by the sampling range.
RangeShuffle.KeyAndSizeExtractor<T>	KeyAndSizeExtractor is responsible for extracting the sort key and row size.
RangeShuffle.LocalSampleOperator<T>	LocalSampleOperator wraps the sample logic on the partition side (the first phase of distributed sample algorithm).