Package org.apache.iceberg.flink.source.reader

Interface SplitWatermarkExtractor

All Superinterfaces:
Serializable
All Known Implementing Classes:
ColumnStatsWatermarkExtractor
public interface SplitWatermarkExtractor extends Serializable
The interface used to extract watermarks from splits.

  • Method Summary

    Modifier and Type
    Method
    Description
    long
    extractWatermark(IcebergSourceSplit split)
    Get the watermark for a split.

  • Method Details

    • extractWatermark

      long extractWatermark(IcebergSourceSplit split)
      Get the watermark for a split.