Uses of Class
org.apache.paimon.flink.source.AbstractNonCoordinatedSource

Packages that use AbstractNonCoordinatedSource

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

Uses of AbstractNonCoordinatedSource in org.apache.paimon.flink.service

Subclasses of AbstractNonCoordinatedSource in org.apache.paimon.flink.service

Modifier and Type	Class and Description
class	QueryFileMonitor This is the single (non-parallel) monitoring task, it is responsible for: Read incremental files from tables.

Uses of AbstractNonCoordinatedSource in org.apache.paimon.flink.source

Subclasses of AbstractNonCoordinatedSource in org.apache.paimon.flink.source

Modifier and Type	Class and Description
class	BucketUnawareCompactSource Source for unaware-bucket Compaction.

Uses of AbstractNonCoordinatedSource in org.apache.paimon.flink.source.operator

Subclasses of AbstractNonCoordinatedSource in org.apache.paimon.flink.source.operator

Modifier and Type	Class and Description
class	CombinedAwareBatchSource It is responsible for monitoring compactor source of aware bucket table in batch mode.
class	CombinedAwareStreamingSource It is responsible for monitoring compactor source of multi bucket table in stream mode.
class	CombinedCompactorSource<T> This is the single (non-parallel) monitoring task, it is responsible for: Monitoring snapshots of the Paimon table.
class	CombinedUnawareBatchSource It is responsible for the batch compactor source of the table with unaware bucket in combined mode.
class	CombinedUnawareStreamingSource It is responsible for monitoring compactor source in stream mode for the table of unaware bucket.
class	MonitorSource This is the single (non-parallel) monitoring task, it is responsible for: Monitoring snapshots of the Paimon table.