public class TaskLocalStateStoreImpl extends Object implements OwnedTaskLocalStateStore
TaskLocalStateStore
.Constructor and Description |
---|
TaskLocalStateStoreImpl(JobID jobID,
AllocationID allocationID,
JobVertexID jobVertexID,
int subtaskIndex,
LocalRecoveryConfig localRecoveryConfig,
Executor discardExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
confirmCheckpoint(long confirmedCheckpointId)
Notifies that the checkpoint with the given id was confirmed as complete.
|
CompletableFuture<Void> |
dispose()
Disposes the state of all local snapshots managed by this object.
|
LocalRecoveryConfig |
getLocalRecoveryConfig()
Returns the
LocalRecoveryConfig for this task local state store. |
void |
pruneMatchingCheckpoints(java.util.function.LongPredicate matcher)
Remove all checkpoints from the store that match the given predicate.
|
TaskStateSnapshot |
retrieveLocalState(long checkpointID)
Returns the local state that is stored under the given checkpoint id or null if nothing was stored under the id.
|
void |
storeLocalState(long checkpointId,
TaskStateSnapshot localState)
Stores the local state for the given checkpoint id.
|
String |
toString() |
public TaskLocalStateStoreImpl(@Nonnull JobID jobID, @Nonnull AllocationID allocationID, @Nonnull JobVertexID jobVertexID, @Nonnegative int subtaskIndex, @Nonnull LocalRecoveryConfig localRecoveryConfig, @Nonnull Executor discardExecutor)
public void storeLocalState(@Nonnegative long checkpointId, @Nullable TaskStateSnapshot localState)
TaskLocalStateStore
storeLocalState
in interface TaskLocalStateStore
checkpointId
- id for the checkpoint that created the local state that will be stored.localState
- the local state to store.@Nullable public TaskStateSnapshot retrieveLocalState(long checkpointID)
TaskLocalStateStore
retrieveLocalState
in interface TaskLocalStateStore
checkpointID
- the checkpoint id by which we search for local state.@Nonnull public LocalRecoveryConfig getLocalRecoveryConfig()
TaskLocalStateStore
LocalRecoveryConfig
for this task local state store.getLocalRecoveryConfig
in interface TaskLocalStateStore
public void confirmCheckpoint(long confirmedCheckpointId)
TaskLocalStateStore
confirmCheckpoint
in interface TaskLocalStateStore
public void pruneMatchingCheckpoints(@Nonnull java.util.function.LongPredicate matcher)
TaskLocalStateStore
pruneMatchingCheckpoints
in interface TaskLocalStateStore
matcher
- the predicate that selects the checkpoints for pruning.public CompletableFuture<Void> dispose()
dispose
in interface OwnedTaskLocalStateStore
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.