| Class | Description |
|---|---|
| FlinkInputFormat |
Flink
InputFormat for Iceberg. |
| FlinkInputSplit |
TODO Implement
LocatableInputSplit. |
| FlinkSource | |
| FlinkSource.Builder |
Source builder to build
DataStream. |
| 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. |