org.apache.flink.runtime.state.changelog

Interface LocalChangelogRegistry

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

LocalChangelogRegistryImpl

@Internal
public interface LocalChangelogRegistry
extends Closeable

This registry is responsible for deleting changlog's local handles which are not in use.

Field Summary

Fields

Modifier and Type	Field and Description
static LocalChangelogRegistry	NO_OP

Method Summary

Modifier and Type	Method and Description
void	discardUpToCheckpoint(long upTo) Called upon ChangelogKeyedStateBackend#notifyCheckpointComplete and ChangelogKeyedStateBackend#notifyCheckpointSubsumed.
void	register(StreamStateHandle handle, long checkpointID) Called upon ChangelogKeyedStateBackend#notifyCheckpointComplete.

Methods inherited from interface java.io.Closeable

close

Field Detail

NO_OP

static final LocalChangelogRegistry NO_OP

Method Detail

register

void register(StreamStateHandle handle,
              long checkpointID)

Called upon ChangelogKeyedStateBackend#notifyCheckpointComplete.

Parameters:

handle - handle to register.

checkpointID - latest used checkpointID.

discardUpToCheckpoint

void discardUpToCheckpoint(long upTo)

Called upon ChangelogKeyedStateBackend#notifyCheckpointComplete and ChangelogKeyedStateBackend#notifyCheckpointSubsumed. Remote dstl handles are unregistered when CompletedCheckpointStore.addCheckpointAndSubsumeOldestOne(org.apache.flink.runtime.checkpoint.CompletedCheckpoint, org.apache.flink.runtime.checkpoint.CheckpointsCleaner, java.lang.Runnable), local dtsl handles are unregistered when the checkpoint completes, because only one checkpoint is kept for local recovery.

Parameters:

upTo - lowest CheckpointID which is still valid.