@Internal public class PrioritizedOperatorSubtaskState extends Object
OperatorSubtaskState
that are (partial)
substitutes for each other and imposes a priority ordering over all alternatives for the
different states which define an order in which the operator should attempt to restore the state
from them. One OperatorSubtaskState is considered as the "ground truth" about which state should
be represented. Alternatives may be complete or partial substitutes for the "ground truth" with a
higher priority (if they had a lower alternative, they would not really be alternatives).
Substitution is determined on a per-sub-state basis.Modifier and Type | Class and Description |
---|---|
static class |
PrioritizedOperatorSubtaskState.Builder
A builder for PrioritizedOperatorSubtaskState.
|
Modifier and Type | Method and Description |
---|---|
static PrioritizedOperatorSubtaskState |
empty(long restoredCheckpointId) |
static PrioritizedOperatorSubtaskState |
emptyNotRestored()
Returns an empty
PrioritizedOperatorSubtaskState singleton for an empty, not-restored
operator state. |
StateObjectCollection<KeyedStateHandle> |
getJobManagerManagedKeyedState()
Returns the managed keyed state from the job manager, which represents the ground truth about
what this state should represent.
|
StateObjectCollection<OperatorStateHandle> |
getJobManagerManagedOperatorState()
Returns the managed operator state from the job manager, which represents the ground truth
about what this state should represent.
|
StateObjectCollection<KeyedStateHandle> |
getJobManagerRawKeyedState()
Returns the raw keyed state from the job manager, which represents the ground truth about
what this state should represent.
|
StateObjectCollection<OperatorStateHandle> |
getJobManagerRawOperatorState()
Returns the raw operator state from the job manager, which represents the ground truth about
what this state should represent.
|
StateObjectCollection<InputChannelStateHandle> |
getPrioritizedInputChannelState() |
List<StateObjectCollection<KeyedStateHandle>> |
getPrioritizedManagedKeyedState()
Returns an immutable list with all alternative snapshots to restore the managed keyed state,
in the order in which we should attempt to restore.
|
List<StateObjectCollection<OperatorStateHandle>> |
getPrioritizedManagedOperatorState()
Returns an immutable list with all alternative snapshots to restore the managed operator
state, in the order in which we should attempt to restore.
|
List<StateObjectCollection<KeyedStateHandle>> |
getPrioritizedRawKeyedState()
Returns an immutable list with all alternative snapshots to restore the raw keyed state, in
the order in which we should attempt to restore.
|
List<StateObjectCollection<OperatorStateHandle>> |
getPrioritizedRawOperatorState()
Returns an immutable list with all alternative snapshots to restore the raw operator state,
in the order in which we should attempt to restore.
|
StateObjectCollection<ResultSubpartitionStateHandle> |
getPrioritizedResultSubpartitionState() |
Long |
getRestoredCheckpointId()
Returns the checkpoint id if this was created for a restored operator, null otherwise.
|
boolean |
isRestored()
Returns true if this was created for a restored operator, false otherwise.
|
@Nonnull public List<StateObjectCollection<OperatorStateHandle>> getPrioritizedManagedOperatorState()
@Nonnull public List<StateObjectCollection<OperatorStateHandle>> getPrioritizedRawOperatorState()
@Nonnull public List<StateObjectCollection<KeyedStateHandle>> getPrioritizedManagedKeyedState()
@Nonnull public List<StateObjectCollection<KeyedStateHandle>> getPrioritizedRawKeyedState()
@Nonnull public StateObjectCollection<OperatorStateHandle> getJobManagerManagedOperatorState()
@Nonnull public StateObjectCollection<OperatorStateHandle> getJobManagerRawOperatorState()
@Nonnull public StateObjectCollection<KeyedStateHandle> getJobManagerManagedKeyedState()
@Nonnull public StateObjectCollection<KeyedStateHandle> getJobManagerRawKeyedState()
@Nonnull public StateObjectCollection<InputChannelStateHandle> getPrioritizedInputChannelState()
@Nonnull public StateObjectCollection<ResultSubpartitionStateHandle> getPrioritizedResultSubpartitionState()
public boolean isRestored()
@Nullable public Long getRestoredCheckpointId()
public static PrioritizedOperatorSubtaskState emptyNotRestored()
PrioritizedOperatorSubtaskState
singleton for an empty, not-restored
operator state.public static PrioritizedOperatorSubtaskState empty(long restoredCheckpointId)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.