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 
 - 
 
 -