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>

Class Summary

Class	Description
DataIteratorReaderFunction<T>	A ReaderFunction implementation that uses DataIterator.
IcebergSourceReader<T>
ReaderMetricsContext
RecordAndPosition<T>	A record along with the reader position to be stored in the checkpoint.
RowDataReaderFunction