| Interface | Description |
|---|---|
| FileScanTaskReader<T> |
Read a
FileScanTask into a CloseableIterator |
| Class | Description |
|---|---|
| AvroGenericRecordFileScanTaskReader | |
| DataIterator<T> |
Flink data iterator that reads
CombinedScanTask into a CloseableIterator |
| DataTaskReader | |
| FlinkInputFormat |
Flink
InputFormat for Iceberg. |
| FlinkInputSplit | |
| FlinkSource | |
| 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 | Description |
|---|---|
| StreamingStartingStrategy |
Starting strategy for streaming execution.
|