Class SplitComparators
- java.lang.Object
-
- org.apache.iceberg.flink.source.split.SplitComparators
-
public class SplitComparators extends java.lang.Object
Provides implementations ofSerializableComparator
which could be used for ordering splits. These are used by theOrderedSplitAssignerFactory
and theIcebergSourceReader
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static SerializableComparator<IcebergSourceSplit>
fileSequenceNumber()
Comparator which orders the splits based on the file sequence number of the data filesstatic SerializableComparator<IcebergSourceSplit>
watermark(SplitWatermarkExtractor watermarkExtractor)
Comparator which orders the splits based on watermark of the splits
-
-
-
Method Detail
-
fileSequenceNumber
public static SerializableComparator<IcebergSourceSplit> fileSequenceNumber()
Comparator which orders the splits based on the file sequence number of the data files
-
watermark
public static SerializableComparator<IcebergSourceSplit> watermark(SplitWatermarkExtractor watermarkExtractor)
Comparator which orders the splits based on watermark of the splits
-
-