Modifier and Type | Class and Description |
---|---|
class |
MigrationKeyGroupStateHandle
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
|
class |
MigrationStreamStateHandle
Deprecated.
Internal class for savepoint backwards compatibility. Don't use for other purposes.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractAsyncSnapshotIOCallable<H extends StateObject>
Abstract base class for async IO operations of snapshots against a
CheckedOutputStream . |
Modifier and Type | Class and Description |
---|---|
class |
OperatorState
Simple container class which contains the raw/managed/legacy operator state and key-group state handles for the sub
tasks of an operator.
|
class |
OperatorSubtaskState
Container for the state of one parallel subtask of an operator.
|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
ChainedStateHandle<T extends StateObject>
Handle to state handles for the operators in an operator chain.
|
interface |
Snapshotable<S extends StateObject>
Interface for operators that can perform snapshots of their state.
|
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 |
KeyedStateHandle
Base for the handles of the checkpointed states in keyed streams.
|
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 |
ChainedStateHandle<T extends StateObject>
Handle to state handles for the operators in an operator chain.
|
class |
IncrementalKeyedStateHandle
The handle to states of an incremental snapshot.
|
class |
KeyGroupsStateHandle
A handle to the partitioned stream operator state after it has been checkpointed.
|
class |
MultiStreamStateHandle
Wrapper class that takes multiple
StreamStateHandle and makes them look like a single one. |
class |
OperatorStateHandle
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 |
RetrievableStreamStateHandle<T extends Serializable>
Wrapper around a
StreamStateHandle to make the referenced state object retrievable trough a simple get call. |
Modifier and Type | Method and Description |
---|---|
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(RunnableFuture<? 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. |
Modifier and Type | Class and Description |
---|---|
class |
ByteStreamStateHandle
A state handle that contains stream state in a byte array.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.