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

Packages that use CommitterOperatorFactory

Package	Description
org.apache.paimon.flink.sink

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

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

Constructor and Description
AutoTagForSavepointCommitterOperatorFactory(CommitterOperatorFactory<CommitT,GlobalCommitT> commitOperatorFactory, SerializableSupplier<SnapshotManager> snapshotManagerFactory, SerializableSupplier<TagManager> tagManagerFactory, SerializableSupplier<TagDeletion> tagDeletionFactory, SerializableSupplier<List<TagCallback>> callbacksSupplier, java.time.Duration tagTimeRetained)
BatchWriteGeneratorTagOperatorFactory(CommitterOperatorFactory<CommitT,GlobalCommitT> commitOperatorFactory, FileStoreTable table)