Modifier and Type | Class and Description |
---|---|
class |
MigrationKeyGroupStateHandle
Deprecated.
|
class |
MigrationStreamStateHandle
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
SubtaskState
Container for the chained state of one parallel subtask of an operator/task.
|
class |
TaskState
Simple container class which contains the task state and key-group state handles for the sub
tasks of a
JobVertex . |
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 |
RetrievableStateHandle<T extends Serializable>
Handle to state that can be read back again via
RetrievableStateHandle.retrieveState() . |
interface |
StateHandle<T>
StateHandle is a general handle interface meant to abstract operator state fetching.
|
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 |
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 |
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 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–2017 The Apache Software Foundation. All rights reserved.