Class SplitComparators
- java.lang.Object
-
- org.apache.iceberg.flink.source.split.SplitComparators
-
public class SplitComparators extends java.lang.ObjectProvides implementations ofSerializableComparatorwhich could be used for ordering splits. These are used by theOrderedSplitAssignerFactoryand 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
-
-