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>
RowDataConverter<T>	Convert RowData to a different output type.
SerializableRecordEmitter<T>
SplitWatermarkExtractor	The interface used to extract watermarks from splits.

Class Summary

Class	Description
AvroGenericRecordConverter
AvroGenericRecordReaderFunction	Deprecated. since 1.7.0.
ColumnStatsWatermarkExtractor	SplitWatermarkExtractor implementation which uses an Iceberg timestamp column statistics to get the watermarks for the IcebergSourceSplit.
ConverterReaderFunction<T>
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