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 Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description long
extractWatermark(IcebergSourceSplit split)
Get the watermark for a split.
-
-
-
Method Detail
-
extractWatermark
long extractWatermark(IcebergSourceSplit split)
Get the watermark for a split.
-
-