public class StreamingMonitorFunction
This is the single (non-parallel) monitoring task which takes a FlinkInputFormat, it is
Monitoring snapshots of the Iceberg table.
Creating the splits corresponding to the incremental files
Assigning them to downstream tasks for further processing.
The splits to be read are forwarded to the downstream StreamingReaderOperator which
can have parallelism greater than one.