Package org.apache.iceberg.flink.source
-
Class Summary Class Description FlinkInputFormat FlinkInputFormat
for Iceberg.FlinkInputSplit TODO ImplementLocatableInputSplit
.FlinkSource FlinkSource.Builder Source builder to buildDataStream
.RowDataRewriter RowDataRewriter.RewriteMap StreamingMonitorFunction This is the single (non-parallel) monitoring task which takes aFlinkInputFormat
, it is responsible for: Monitoring snapshots of the Iceberg table. Creating thesplits
corresponding to the incremental files Assigning them to downstream tasks for further processing.StreamingReaderOperator The operator that reads thesplits
received from the precedingStreamingMonitorFunction
.