Modifier and Type | Class and Description |
---|---|
class |
StateObjectCollection<T extends StateObject>
This class represents a generic collection for
StateObject s. |
Modifier and Type | Class and Description |
---|---|
class |
OperatorState
Simple container class which contains the raw/managed operator state and key-group state handles
from all sub tasks of an operator and therefore represents the complete state of a logical
operator.
|
class |
OperatorSubtaskState
This class encapsulates the state for one parallel instance of an operator.
|
class |
StateObjectCollection<T extends StateObject>
This class represents a generic collection for
StateObject s. |
class |
SubtaskState
Container for the chained state of one parallel subtask of an operator/task.
|
class |
TaskState
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
|
class |
TaskStateSnapshot
This class encapsulates state handles to the snapshots of all operator instances executed within
one task.
|
Modifier and Type | Method and Description |
---|---|
static <T extends StateObject> |
StateAssignmentOperation.applyRepartitioner(OperatorID operatorID,
OperatorStateRepartitioner<T> opStateRepartitioner,
List<List<T>> chainOpParallelStates,
int oldParallelism,
int newParallelism) |
static <T extends StateObject> |
StateObjectCollection.empty() |
static <T extends StateObject> |
StateObjectCollection.emptyIfNull(StateObjectCollection<T> collection) |
static <T extends StateObject> |
StateAssignmentOperation.reDistributePartitionableStates(List<OperatorState> oldOperatorStates,
int newParallelism,
List<OperatorIDPair> newOperatorIDs,
java.util.function.Function<OperatorSubtaskState,StateObjectCollection<T>> extractHandle,
OperatorStateRepartitioner<T> stateRepartitioner) |
protected <T extends StateObject> |
PrioritizedOperatorSubtaskState.Builder.resolvePrioritizedAlternatives(StateObjectCollection<T> jobManagerState,
List<StateObjectCollection<T>> alternativesByPriority,
java.util.function.BiFunction<T,T,Boolean> approveFun)
This helper method resolves the dependencies between the ground truth of the operator
state obtained from the job manager and potential alternatives for recovery, e.g.
|
static <T extends StateObject> |
StateObjectCollection.singleton(T stateObject) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractSnapshotStrategy<T extends StateObject>
Abstract base class for implementing
SnapshotStrategy , that gives a consistent logging
across state backends. |
class |
ChainedStateHandle<T extends StateObject>
Handle to state handles for the operators in an operator chain.
|
class |
SnapshotResult<T extends StateObject>
This class contains the combined results from the snapshot of a state backend:
A state object representing the state that will be reported to the Job Manager to
acknowledge the checkpoint.
|
interface |
SnapshotStrategy<S extends StateObject>
Interface for different snapshot approaches in state backends.
|
Modifier and Type | Interface and Description |
---|---|
interface |
CompositeStateHandle
Base of all snapshots that are taken by
StateBackend s and some other components in tasks. |
interface |
IncrementalKeyedStateHandle
Common interface to all incremental
KeyedStateHandle . |
interface |
KeyedStateHandle
Base for the handles of the checkpointed states in keyed streams.
|
interface |
OperatorStateHandle
Interface of a state handle for operator state.
|
interface |
RetrievableStateHandle<T extends Serializable>
Handle to state that can be read back again via
RetrievableStateHandle.retrieveState() . |
interface |
StreamStateHandle
A
StateObject that represents state that was written to a stream. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractChannelStateHandle<Info>
Abstract channel state handle.
|
class |
ChainedStateHandle<T extends StateObject>
Handle to state handles for the operators in an operator chain.
|
class |
DirectoryKeyedStateHandle
This class is a keyed state handle based on a directory.
|
class |
DirectoryStateHandle
This state handle represents a directory.
|
class |
IncrementalLocalKeyedStateHandle
State handle for local copies of
IncrementalRemoteKeyedStateHandle . |
class |
IncrementalRemoteKeyedStateHandle
The handle to states of an incremental snapshot.
|
class |
InputChannelStateHandle
Handle to an InputChannel state. |
class |
KeyGroupsStateHandle
A handle to the partitioned stream operator state after it has been checkpointed.
|
class |
OperatorStreamStateHandle
State handle for partitionable operator state.
|
class |
PlaceholderStreamStateHandle
A placeholder state handle for shared state that will replaced by an original that was created in
a previous checkpoint.
|
class |
ResultSubpartitionStateHandle
Handle to a ResultSubpartition state. |
class |
RetrievableStreamStateHandle<T extends Serializable>
Wrapper around a
StreamStateHandle to make the referenced state object retrievable trough
a simple get call. |
class |
SnapshotResult<T extends StateObject>
This class contains the combined results from the snapshot of a state backend:
A state object representing the state that will be reported to the Job Manager to
acknowledge the checkpoint.
|
Modifier and Type | Method and Description |
---|---|
static <T extends StateObject> |
SnapshotResult.empty() |
static <T extends StateObject> |
SnapshotResult.of(T jobManagerState) |
static <T extends StateObject> |
SnapshotResult.withLocalState(T jobManagerState,
T localState) |
static <T extends StateObject> |
ChainedStateHandle.wrapSingleHandle(T stateHandleToWrap) |
Modifier and Type | Method and Description |
---|---|
static long |
StateUtil.getStateSize(StateObject handle)
Returns the size of a state object
|
Modifier and Type | Method and Description |
---|---|
static void |
StateUtil.bestEffortDiscardAllStateObjects(Iterable<? extends StateObject> handlesToDiscard)
Iterates through the passed state handles and calls discardState() on each handle that is not
null.
|
static void |
StateUtil.discardStateFuture(Future<? extends StateObject> stateFuture)
Discards the given state future by first trying to cancel it.
|
Modifier and Type | Class and Description |
---|---|
class |
FileStateHandle
StreamStateHandle for state that was written to a file stream. |
class |
RelativeFileStateHandle
A
StreamStateHandle for state that was written to a file stream. |
Modifier and Type | Class and Description |
---|---|
class |
ByteStreamStateHandle
A state handle that contains stream state in a byte array.
|
Modifier and Type | Class and Description |
---|---|
class |
BackendRestorerProcedure<T extends Closeable & Disposable,S extends StateObject>
This class implements the logic that creates (and potentially restores) a state backend.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.