public class SplitComparators
extends java.lang.Object
SerializableComparator
which could be used for ordering splits. These are used by the OrderedSplitAssignerFactory
and the IcebergSourceReader
Modifier and Type | Method and Description |
---|---|
static SerializableComparator<IcebergSourceSplit> |
fileSequenceNumber()
Comparator which orders the splits based on the file sequence number of the data files
|
static SerializableComparator<IcebergSourceSplit> |
watermark(SplitWatermarkExtractor watermarkExtractor)
Comparator which orders the splits based on watermark of the splits
|
public static SerializableComparator<IcebergSourceSplit> fileSequenceNumber()
public static SerializableComparator<IcebergSourceSplit> watermark(SplitWatermarkExtractor watermarkExtractor)