Package org.apache.iceberg.flink.source.reader
package org.apache.iceberg.flink.source.reader
-
ClassDescriptionRead Iceberg rows as
GenericRecord.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.The interface used to extract watermarks from splits.