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
    Get the watermark for a split.
  • Method Details

    • extractWatermark

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