org.apache.paimon.flink.sink

Class RestoreAndFailCommittableStateManager<GlobalCommitT>

java.lang.Object

org.apache.paimon.flink.sink.RestoreAndFailCommittableStateManager<GlobalCommitT>

All Implemented Interfaces:

Serializable, CommittableStateManager<GlobalCommitT>

public class RestoreAndFailCommittableStateManager<GlobalCommitT>
extends Object
implements CommittableStateManager<GlobalCommitT>

A CommittableStateManager which stores uncommitted ManifestCommittables in state.

When the job restarts, these ManifestCommittables will be restored and committed, then an intended failure will occur, hoping that after the job restarts, all writers can start writing based on the restored snapshot.

Useful for committing snapshots containing records. For example snapshots produced by table store writers.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RestoreAndFailCommittableStateManager(SerializableSupplier<VersionedSerializer<GlobalCommitT>> committableSerializer)

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RestoreAndFailCommittableStateManager

public RestoreAndFailCommittableStateManager(SerializableSupplier<VersionedSerializer<GlobalCommitT>> committableSerializer)

Method Detail

initializeState

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

Specified by:

initializeState in interface CommittableStateManager<GlobalCommitT>

Throws:

Exception

snapshotState

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

Specified by:

snapshotState in interface CommittableStateManager<GlobalCommitT>

Throws:

Exception