| Interface | Description |
|---|---|
| FileScanTaskReader<T> |
Read a
FileScanTask into a CloseableIterator |
| 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. |