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

Packages that use Committer

Package	Description
org.apache.paimon.flink.sink

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

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

Modifier and Type	Class and Description
class	StoreCommitter Committer for dynamic store.
class	StoreMultiCommitter StoreMultiCommitter for multiple dynamic store.

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

Modifier and Type	Field and Description
protected Committer<CommitT,GlobalCommitT>	CommitterOperator.committer Aggregate committables to global committables and commit the global committables to the external system.

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

Modifier and Type	Method and Description
Committer<CommitT,GlobalCommitT>	Committer.Factory.create(Committer.Context context)

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

Modifier and Type	Method and Description
void	CommittableStateManager.initializeState(org.apache.flink.runtime.state.StateInitializationContext context, Committer<?,GlobalCommitT> committer)
void	RestoreAndFailCommittableStateManager.initializeState(org.apache.flink.runtime.state.StateInitializationContext context, Committer<?,GlobalCommitT> committer)
void	NoopCommittableStateManager.initializeState(org.apache.flink.runtime.state.StateInitializationContext context, Committer<?,ManifestCommittable> committer)