Package org.apache.iceberg.flink.source.reader

Interface Summary

Interface	Description
DataIteratorBatcher<T>	Batcher converts iterator of T into iterator of batched RecordsWithSplitIds<RecordAndPosition<T>>, as FLIP-27's SplitReader.fetch() returns batched records.
ReaderFunction<T>
SerializableRecordEmitter<T>
SplitWatermarkExtractor	The interface used to extract watermarks from splits.

Class Summary

Class	Description
AvroGenericRecordReaderFunction	Read Iceberg rows as GenericRecord.
ColumnStatsWatermarkExtractor	SplitWatermarkExtractor implementation which uses an Iceberg timestamp column statistics to get the watermarks for the IcebergSourceSplit.
DataIteratorReaderFunction<T>	A ReaderFunction implementation that uses DataIterator.
IcebergSourceReader<T>
IcebergSourceReaderMetrics
MetaDataReaderFunction	Reading metadata tables (like snapshots, manifests, etc.)
RecordAndPosition<T>	A record along with the reader position to be stored in the checkpoint.
RowDataReaderFunction