Uses of Interface
org.apache.paimon.flink.sink.Committer.Factory

Packages that use Committer.Factory

Package	Description
org.apache.paimon.flink.sink
org.apache.paimon.flink.sink.cdc

Uses of Committer.Factory in org.apache.paimon.flink.sink

Methods in org.apache.paimon.flink.sink that return Committer.Factory

Modifier and Type	Method and Description
protected abstract Committer.Factory<Committable,ManifestCommittable>	FlinkSink.createCommitterFactory()
protected Committer.Factory<Committable,ManifestCommittable>	UnawareBucketCompactionSink.createCommitterFactory()
protected Committer.Factory<Committable,ManifestCommittable>	CompactorSink.createCommitterFactory()
protected Committer.Factory<Committable,ManifestCommittable>	FlinkWriteSink.createCommitterFactory()
protected Committer.Factory<MultiTableCommittable,WrappedManifestCommittable>	CombinedTableCompactorSink.createCommitterFactory(boolean isStreaming)

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

Constructor and Description
CommitterOperator(boolean streamingCheckpointEnabled, boolean forceSingleParallelism, boolean chaining, String initialCommitUser, Committer.Factory<CommitT,GlobalCommitT> committerFactory, CommittableStateManager<GlobalCommitT> committableStateManager)
CommitterOperator(boolean streamingCheckpointEnabled, boolean forceSingleParallelism, boolean chaining, String initialCommitUser, Committer.Factory<CommitT,GlobalCommitT> committerFactory, CommittableStateManager<GlobalCommitT> committableStateManager, Long endInputWatermark)

Uses of Committer.Factory in org.apache.paimon.flink.sink.cdc

Methods in org.apache.paimon.flink.sink.cdc that return Committer.Factory

Modifier and Type	Method and Description
protected Committer.Factory<MultiTableCommittable,WrappedManifestCommittable>	FlinkCdcMultiTableSink.createCommitterFactory()