Package org.apache.iceberg.flink.source

Interface Summary

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

Class Summary

Class	Description
DataIterator<T>	Flink data iterator that reads CombinedScanTask into a CloseableIterator
FlinkInputFormat	Flink InputFormat for Iceberg.
FlinkInputSplit	TODO Implement LocatableInputSplit.
FlinkSource
FlinkSource.Builder	Source builder to build DataStream.
FlinkSplitPlanner
RowDataFileScanTaskReader
RowDataRewriter
RowDataRewriter.RewriteMap
StreamingMonitorFunction	This is the single (non-parallel) monitoring task which takes a FlinkInputFormat, it is responsible for: Monitoring snapshots of the Iceberg table. Creating the splits corresponding to the incremental files Assigning them to downstream tasks for further processing.
StreamingReaderOperator	The operator that reads the splits received from the preceding StreamingMonitorFunction.