Package org.apache.iceberg.flink.source
-
Interface Summary Interface Description FileScanTaskReader<T> Read aFileScanTaskinto aCloseableIterator -
Class Summary Class Description AvroGenericRecordFileScanTaskReader DataIterator<T> Flink data iterator that readsCombinedScanTaskinto aCloseableIteratorDataTaskReader FlinkInputFormat FlinkInputFormatfor Iceberg.FlinkInputSplit FlinkSource FlinkSource.Builder Source builder to buildDataStream.FlinkSplitPlanner IcebergSource<T> IcebergSource.Builder<T> IcebergTableSource Flink Iceberg table source.RowDataFileScanTaskReader RowDataRewriter RowDataRewriter.RewriteMap RowDataToAvroGenericRecordConverter This is not serializable because AvroSchemais not actually serializable, even though it implementsSerializableinterface.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.StreamingReaderOperator The operator that reads thesplitsreceived from the precedingStreamingMonitorFunction. -
Enum Summary Enum Description StreamingStartingStrategy Starting strategy for streaming execution.