Uses of Interface
org.apache.paimon.flink.sink.CommittableStateManager

Packages that use CommittableStateManager

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

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

Classes in org.apache.paimon.flink.sink that implement CommittableStateManager

Modifier and Type	Class and Description
class	NoopCommittableStateManager A CommittableStateManager which does nothing.
class	RestoreAndFailCommittableStateManager<GlobalCommitT> A CommittableStateManager which stores uncommitted ManifestCommittables in state.

Methods in org.apache.paimon.flink.sink that return CommittableStateManager

Modifier and Type	Method and Description
protected CommittableStateManager<ManifestCommittable>	UnawareBucketCompactionSink.createCommittableStateManager()
protected CommittableStateManager<WrappedManifestCommittable>	CombinedTableCompactorSink.createCommittableStateManager()
protected abstract CommittableStateManager<ManifestCommittable>	FlinkSink.createCommittableStateManager()
protected CommittableStateManager<ManifestCommittable>	FlinkWriteSink.createCommittableStateManager()
protected CommittableStateManager<ManifestCommittable>	CompactorSink.createCommittableStateManager()

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

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 CommittableStateManager in org.apache.paimon.flink.sink.cdc

Methods in org.apache.paimon.flink.sink.cdc that return CommittableStateManager

Modifier and Type	Method and Description
protected CommittableStateManager<WrappedManifestCommittable>	FlinkCdcMultiTableSink.createCommittableStateManager()