org.apache.paimon.flink.sink

Class NoopCommittableStateManager

java.lang.Object

org.apache.paimon.flink.sink.NoopCommittableStateManager

All Implemented Interfaces:

Serializable, CommittableStateManager<ManifestCommittable>

public class NoopCommittableStateManager
extends Object
implements CommittableStateManager<ManifestCommittable>

A CommittableStateManager which does nothing. If a commit attempt fails, it will be lost after the job restarts.

Useful for committing optional snapshots. For example COMPACT snapshots produced by a separate compact job.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
NoopCommittableStateManager()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

NoopCommittableStateManager

public NoopCommittableStateManager()

Method Detail

initializeState

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

Specified by:

initializeState in interface CommittableStateManager<ManifestCommittable>

Throws:

Exception

snapshotState

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

Specified by:

snapshotState in interface CommittableStateManager<ManifestCommittable>

Throws:

Exception