org.apache.iceberg.flink.source.reader

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

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

Method Detail

extractWatermark

long extractWatermark(IcebergSourceSplit split)

Get the watermark for a split.