Package org.apache.iceberg.flink.source
-
Interface Summary Interface Description FileScanTaskReader<T> Read aFileScanTaskinto aCloseableIterator -
Class Summary Class Description DataIterator<T> Flink data iterator that readsCombinedScanTaskinto aCloseableIteratorFlinkInputFormat FlinkInputFormatfor Iceberg.FlinkInputSplit FlinkSource FlinkSource.Builder Source builder to buildDataStream.FlinkSplitPlanner IcebergSource<T> IcebergSource.Builder<T> RowDataFileScanTaskReader RowDataRewriter RowDataRewriter.RewriteMap ScanContext Context object with optional arguments for a Flink Scan.ScanContext.Builder StreamingMonitorFunction This is the single (non-parallel) monitoring task which takes aFlinkInputFormat, it is responsible for: Monitoring snapshots of the Iceberg table. Creating thesplitscorresponding to the incremental files Assigning them to downstream tasks for further processing.StreamingReaderOperator The operator that reads thesplitsreceived from the precedingStreamingMonitorFunction. -
Enum Summary Enum Description StreamingStartingStrategy Starting strategy for streaming execution.