org.apache.paimon.flink.sink

Interface CommittableStateManager<GlobalCommitT>

All Superinterfaces:

Serializable

All Known Implementing Classes:

NoopCommittableStateManager, RestoreAndFailCommittableStateManager

public interface CommittableStateManager<GlobalCommitT>
extends Serializable

Helper interface for CommitterOperator. This interface manages operator states about ManifestCommittable.

Method Summary

Modifier and Type	Method and Description
void	initializeState(org.apache.flink.runtime.state.StateInitializationContext context, Committer<?,GlobalCommitT> committer)
void	snapshotState(org.apache.flink.runtime.state.StateSnapshotContext context, List<GlobalCommitT> committables)

Method Detail

initializeState

void initializeState(org.apache.flink.runtime.state.StateInitializationContext context,
                     Committer<?,GlobalCommitT> committer)
              throws Exception

Throws:

Exception

snapshotState

void snapshotState(org.apache.flink.runtime.state.StateSnapshotContext context,
                   List<GlobalCommitT> committables)
            throws Exception

Throws:

Exception