Interface SplitWatermarkExtractor

  • All Superinterfaces:
    java.io.Serializable
    All Known Implementing Classes:
    ColumnStatsWatermarkExtractor

    public interface SplitWatermarkExtractor
    extends java.io.Serializable
    The interface used to extract watermarks from splits.
    • Method Detail

      • extractWatermark

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