Package org.apache.iceberg.flink.source.reader
package org.apache.iceberg.flink.source.reader
-
ClassDescriptionDeprecated.since 1.7.0.
SplitWatermarkExtractorimplementation which uses an Iceberg timestamp column statistics to get the watermarks for theIcebergSourceSplit.Batcher converts iterator of T into iterator of batchedRecordsWithSplitIds<RecordAndPosition<T>>, as FLIP-27'sSplitReader.fetch()returns batched records.AReaderFunctionimplementation that usesDataIterator.Reading metadata tables (like snapshots, manifests, etc.)A record along with the reader position to be stored in the checkpoint.Convert RowData to a different output type.The interface used to extract watermarks from splits.