org.apache.flink.runtime.state

Class ChangelogTaskLocalStateStore

java.lang.Object

org.apache.flink.runtime.state.TaskLocalStateStoreImpl

org.apache.flink.runtime.state.ChangelogTaskLocalStateStore

All Implemented Interfaces:

OwnedTaskLocalStateStore, TaskLocalStateStore

public class ChangelogTaskLocalStateStore
extends TaskLocalStateStoreImpl

Changelog's implementation of a TaskLocalStateStore.

Field Summary

Fields inherited from class org.apache.flink.runtime.state.TaskLocalStateStoreImpl

allocationID, discardExecutor, disposed, jobID, jobVertexID, localRecoveryConfig, lock, storedTaskStateByCheckpointID, subtaskIndex, TASK_STATE_SNAPSHOT_FILENAME

Constructor Summary

Constructors

Constructor and Description
ChangelogTaskLocalStateStore(JobID jobID, AllocationID allocationID, JobVertexID jobVertexID, int subtaskIndex, LocalRecoveryConfig localRecoveryConfig, Executor discardExecutor)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	dispose() Disposes the state of all local snapshots managed by this object.
protected File	getCheckpointDirectory(long checkpointId)
static Path	getLocalTaskOwnedDirectory(LocalRecoveryDirectoryProvider provider, JobID jobID)
void	pruneCheckpoints(java.util.function.LongPredicate pruningChecker, boolean breakOnceCheckerFalse) Pruning the useless checkpoints, it should be called only when holding the TaskLocalStateStoreImpl.lock.
void	storeLocalState(long checkpointId, TaskStateSnapshot localState) Stores the local state for the given checkpoint id.
String	toString()

Methods inherited from class org.apache.flink.runtime.state.TaskLocalStateStoreImpl

abortCheckpoint, confirmCheckpoint, deleteDirectory, getLocalRecoveryConfig, getLocalRecoveryDirectoryProvider, pruneMatchingCheckpoints, retrieveLocalState

Methods inherited from class java.lang.Object

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

Constructor Detail

ChangelogTaskLocalStateStore

public ChangelogTaskLocalStateStore(@Nonnull
                                    JobID jobID,
                                    @Nonnull
                                    AllocationID allocationID,
                                    @Nonnull
                                    JobVertexID jobVertexID,
                                    @Nonnegative
                                    int subtaskIndex,
                                    @Nonnull
                                    LocalRecoveryConfig localRecoveryConfig,
                                    @Nonnull
                                    Executor discardExecutor)

Method Detail

getLocalTaskOwnedDirectory

public static Path getLocalTaskOwnedDirectory(LocalRecoveryDirectoryProvider provider,
                                              JobID jobID)

storeLocalState

public void storeLocalState(long checkpointId,
                            @Nullable
                            TaskStateSnapshot localState)

Description copied from interface: TaskLocalStateStore

Stores the local state for the given checkpoint id.

Specified by:

storeLocalState in interface TaskLocalStateStore

Overrides:

storeLocalState in class TaskLocalStateStoreImpl

Parameters:

checkpointId - id for the checkpoint that created the local state that will be stored.

localState - the local state to store.

getCheckpointDirectory

protected File getCheckpointDirectory(long checkpointId)

Overrides:

getCheckpointDirectory in class TaskLocalStateStoreImpl

pruneCheckpoints

public void pruneCheckpoints(java.util.function.LongPredicate pruningChecker,
                             boolean breakOnceCheckerFalse)

Description copied from class: TaskLocalStateStoreImpl

Pruning the useless checkpoints, it should be called only when holding the TaskLocalStateStoreImpl.lock.

Overrides:

pruneCheckpoints in class TaskLocalStateStoreImpl

dispose

public CompletableFuture<Void> dispose()

Description copied from class: TaskLocalStateStoreImpl

Disposes the state of all local snapshots managed by this object.

Specified by:

dispose in interface OwnedTaskLocalStateStore

Overrides:

dispose in class TaskLocalStateStoreImpl

toString

public String toString()

Overrides:

toString in class TaskLocalStateStoreImpl