Uses of Class
org.apache.paimon.flink.sink.CommitterOperator

Packages that use CommitterOperator

Package	Description
org.apache.paimon.flink.sink

Uses of CommitterOperator in org.apache.paimon.flink.sink

Constructors in org.apache.paimon.flink.sink with parameters of type CommitterOperator

Constructor and Description
AutoTagForSavepointCommitterOperator(CommitterOperator<CommitT,GlobalCommitT> commitOperator, SerializableSupplier<SnapshotManager> snapshotManagerFactory, SerializableSupplier<TagManager> tagManagerFactory, SerializableSupplier<TagDeletion> tagDeletionFactory, SerializableSupplier<List<TagCallback>> callbacksSupplier, java.time.Duration tagTimeRetained)
BatchWriteGeneratorTagOperator(CommitterOperator<CommitT,GlobalCommitT> commitOperator, FileStoreTable table)