Interface | Description |
---|---|
CheckpointListener |
This interface must be implemented by functions/operations that want to receive
a commit notification once a checkpoint has been completely acknowledged by all
participants.
|
CheckpointStreamFactory | |
FunctionInitializationContext |
This interface provides a context in which user functions can initialize by registering to managed state (i.e.
|
FunctionSnapshotContext |
This interface provides a context in which user functions that use managed state (i.e.
|
KeyedStateBackend<K> |
A keyed state backend provides methods for managing keyed state.
|
KeyGroupsList |
This interface offers ordered random read access to multiple key group ids.
|
KvState<N> |
Key/Value state implementation for user-defined state.
|
ManagedInitializationContext |
This interface provides a context in which operators can initialize by registering to managed state (i.e.
|
ManagedSnapshotContext |
This interface provides a context in which operators that use managed state (i.e.
|
OperatorStateBackend |
Interface that combines both, the user facing
OperatorStateStore interface and the system interface
Snapshotable |
RetrievableStateHandle<T extends Serializable> |
Handle to state that can be read back again via
RetrievableStateHandle.retrieveState() . |
Snapshotable<S extends StateObject> |
Interface for operators that can perform snapshots of their state.
|
StateBackendFactory<T extends AbstractStateBackend> |
A factory to create a specific state backend.
|
StateHandle<T> |
StateHandle is a general handle interface meant to abstract operator state fetching.
|
StateInitializationContext |
This interface provides a context in which operators can initialize by registering to managed state (i.e.
|
StateObject |
Base of all types that represent checkpointed state.
|
StateSnapshotContext |
This interface provides a context in which operators that use managed (i.e.
|
StateTransformationFunction<S,T> |
Interface for a binary function that is used for push-down of state transformation into state backends.
|
StreamStateHandle |
A
StateObject that represents state that was written to a stream. |
Class | Description |
---|---|
AbstractKeyedStateBackend<K> |
Base implementation of KeyedStateBackend.
|
AbstractStateBackend |
A state backend defines how state is stored and snapshotted during checkpoints.
|
ArrayListSerializer<T> | |
BoundedInputStream |
Wrapper around a FSDataInputStream to limit the maximum read offset.
|
ChainedStateHandle<T extends StateObject> |
Handle to state handles for the operators in an operator chain.
|
CheckpointStreamFactory.CheckpointStateOutputStream |
A dedicated output stream that produces a
StreamStateHandle when closed. |
DefaultKeyedStateStore |
Default implementation of KeyedStateStore that currently forwards state registration to a
RuntimeContext . |
DefaultOperatorStateBackend |
Default implementation of OperatorStateStore that provides the ability to make snapshots.
|
DoneFuture<T> |
A
Future that is always done and will just yield the object that was given at creation
time. |
GenericFoldingState<N,T,ACC,W extends ValueState<ACC> & KvState<N>> |
Generic implementation of
FoldingState based on a wrapped ValueState . |
GenericListState<N,T,W extends ValueState<ArrayList<T>> & KvState<N>> |
Generic implementation of
ListState based on a wrapped ValueState . |
GenericReducingState<N,T,W extends ValueState<T> & KvState<N>> |
Generic implementation of
ReducingState based on a wrapped ValueState . |
KeyedBackendSerializationProxy |
Serialization proxy for all meta data in keyed state backends.
|
KeyedBackendSerializationProxy.StateMetaInfo<N,S> |
This is the serialization proxy for
RegisteredBackendStateMetaInfo for a single registered state in a
keyed backend. |
KeyedStateCheckpointOutputStream |
Checkpoint output stream that allows to write raw keyed state in a partitioned way, split into key-groups.
|
KeyGroupRange |
This class defines a range of key-group indexes.
|
KeyGroupRangeAssignment | |
KeyGroupRangeOffsets |
This class combines a key-group range with offsets that correspond to the key-groups in the range.
|
KeyGroupsStateHandle |
A handle to the partitioned stream operator state after it has been checkpointed.
|
KeyGroupStatePartitionStreamProvider |
This class provides access to an input stream that contains state data for one key group and the key group id.
|
MultiStreamStateHandle |
Wrapper class that takes multiple
StreamStateHandle and makes them look like a single one. |
NonClosingCheckpointOutputStream<T extends StreamStateHandle> |
Abstract class to implement custom checkpoint output streams which should not be closable for user code.
|
OperatorBackendSerializationProxy |
Serialization proxy for all meta data in operator state backends.
|
OperatorBackendSerializationProxy.StateMetaInfo<S> | |
OperatorStateCheckpointOutputStream |
Checkpoint output stream that allows to write raw operator state in a partitioned way.
|
OperatorStateHandle |
State handle for partitionable operator state.
|
OperatorStateHandle.StateMetaInfo | |
RegisteredBackendStateMetaInfo<N,S> |
Compound meta information for a registered state in a keyed state backend.
|
RetrievableStreamStateHandle<T extends Serializable> |
Wrapper around a
StreamStateHandle to make the referenced state object retrievable trough a simple get call. |
SerializedCheckpointData |
This class represents serialized checkpoint data for a collection of elements.
|
StateInitializationContextImpl |
Default implementation of
StateInitializationContext . |
StatePartitionStreamProvider |
This class provides access to input streams that contain data of one state partition of a partitionable state.
|
StateSnapshotContextSynchronousImpl |
This class is a default implementation for StateSnapshotContext.
|
StateUtil |
Helpers for
StateObject related code. |
TaskStateHandles |
This class encapsulates all state handles for a task.
|
VoidNamespace |
Uninstantiable placeholder class for state without a namespace.
|
VoidNamespaceSerializer |
Serializer for
VoidNamespace . |
Enum | Description |
---|---|
OperatorStateHandle.Mode |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.