Package org.apache.iceberg.flink.source

Interface Summary

Interface	Description
FileScanTaskReader<T>	Read a FileScanTask into a CloseableIterator

Class Summary

Class	Description
AvroGenericRecordFileScanTaskReader
DataIterator<T>	Flink data iterator that reads CombinedScanTask into a CloseableIterator
DataTaskReader
FlinkInputFormat	Flink InputFormat for Iceberg.
FlinkInputSplit
FlinkSource	Deprecated. since 1.7.0, will be removed in 2.0.0.
FlinkSource.Builder	Source builder to build DataStream.
FlinkSplitPlanner
IcebergSource<T>
IcebergSource.Builder<T>
IcebergTableSource	Flink Iceberg table source.
RowDataFileScanTaskReader
RowDataRewriter
RowDataRewriter.RewriteMap
RowDataToAvroGenericRecordConverter	This is not serializable because Avro Schema is not actually serializable, even though it implements Serializable interface.
ScanContext	Context object with optional arguments for a Flink Scan.
ScanContext.Builder
StreamingMonitorFunction	This is the single (non-parallel) monitoring task which takes a FlinkInputFormat, it is responsible for: Monitoring snapshots of the Iceberg table.
StreamingReaderOperator	The operator that reads the splits received from the preceding StreamingMonitorFunction.

Enum Summary

Enum	Description
StreamingStartingStrategy	Starting strategy for streaming execution.