Package org.apache.paimon.flink.source.operator

Class Summary

Class	Description
CombinedAwareBatchSourceFunction	It is responsible for monitoring compactor source of aware bucket table in batch mode.
CombinedAwareStreamingSourceFunction	It is responsible for monitoring compactor source of multi bucket table in stream mode.
CombinedCompactorSourceFunction<T>	This is the single (non-parallel) monitoring task, it is responsible for: Monitoring snapshots of the Paimon table.
CombinedUnawareBatchSourceFunction	It is responsible for the batch compactor source of the table with unaware bucket in combined mode.
CombinedUnawareStreamingSourceFunction	It is responsible for monitoring compactor source in stream mode for the table of unaware bucket.
MonitorFunction	This is the single (non-parallel) monitoring task, it is responsible for: Monitoring snapshots of the Paimon table.
MultiTablesReadOperator	The operator that reads the Tuple2<Split, String> received from the preceding CombinedAwareBatchSourceFunction or CombinedAwareStreamingSourceFunction.
MultiUnawareTablesReadOperator	The operator is used for historical partition compaction.
ReadOperator	The operator that reads the splits received from the preceding MonitorFunction.