SplitComparators

java.lang.Object

org.apache.iceberg.flink.source.split.SplitComparators

public class SplitComparators extends Object

Provides implementations of SerializableComparator which could be used for ordering splits. These are used by the OrderedSplitAssignerFactory and the IcebergSourceReader

Method Summary

Modifier and Type

Method

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

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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