Uses of Class
org.apache.paimon.consumer.ConsumerManager

Packages that use ConsumerManager

Package	Description
org.apache.paimon.table.sink
org.apache.paimon.table.source.snapshot

Uses of ConsumerManager in org.apache.paimon.table.sink

Constructors in org.apache.paimon.table.sink with parameters of type ConsumerManager

Constructor and Description
TableCommitImpl(FileStoreCommit commit, Runnable expireSnapshots, PartitionExpire partitionExpire, TagAutoManager tagAutoManager, Lock lock, java.time.Duration consumerExpireTime, ConsumerManager consumerManager, CoreOptions.ExpireExecutionMode expireExecutionMode, String tableName, boolean forceCreatingSnapshot)

Uses of ConsumerManager in org.apache.paimon.table.source.snapshot

Methods in org.apache.paimon.table.source.snapshot that return ConsumerManager

Modifier and Type	Method and Description
ConsumerManager	SnapshotReader.consumerManager()
ConsumerManager	SnapshotReaderImpl.consumerManager()