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

Fields in org.apache.paimon.flink.sink declared as Committer.Factory

Modifier and Type	Field and Description
protected Committer.Factory<CommitT,GlobalCommitT>	CommitterOperatorFactory.committerFactory

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

Modifier and Type	Method and Description
protected Committer.Factory<Committable,ManifestCommittable>	UnawareBucketCompactionSink.createCommitterFactory()
protected Committer.Factory<Committable,ManifestCommittable>	CompactorSink.createCommitterFactory()
protected abstract Committer.Factory<Committable,ManifestCommittable>	FlinkSink.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(org.apache.flink.streaming.api.operators.StreamOperatorParameters<CommitT> parameters, boolean streamingCheckpointEnabled, boolean forceSingleParallelism, String initialCommitUser, Committer.Factory<CommitT,GlobalCommitT> committerFactory, CommittableStateManager<GlobalCommitT> committableStateManager, Long endInputWatermark)
CommitterOperatorFactory(boolean streamingCheckpointEnabled, boolean forceSingleParallelism, String initialCommitUser, Committer.Factory<CommitT,GlobalCommitT> committerFactory, CommittableStateManager<GlobalCommitT> committableStateManager)
CommitterOperatorFactory(boolean streamingCheckpointEnabled, boolean forceSingleParallelism, 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()