Class and Description |
---|
AbstractKeyedStateBackend
Base implementation of KeyedStateBackend.
|
AbstractStateBackend
A state backend defines how state is stored and snapshotted during checkpoints.
|
CheckpointStreamFactory |
KeyedStateBackend
A keyed state backend provides methods for managing keyed state.
|
KeyGroupRange
This class defines a range of key-group indexes.
|
KeyGroupsStateHandle
A handle to the partitioned stream operator state after it has been checkpointed.
|
KvState
Key/Value state implementation for user-defined state.
|
Snapshotable
Interface for operators that can perform snapshots of their state.
|
StateBackendFactory
A factory to create a specific state backend.
|
Class and Description |
---|
KeyGroupsStateHandle
A handle to the partitioned stream operator state after it has been checkpointed.
|
Class and Description |
---|
KeyGroupsStateHandle
A handle to the partitioned stream operator state after it has been checkpointed.
|
StreamStateHandle
A
StateObject that represents state that was written to a stream. |
Class and Description |
---|
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.
|
StateObject
Base of all types that represent checkpointed state.
|
StreamStateHandle
A
StateObject that represents state that was written to a stream. |
Class and Description |
---|
ChainedStateHandle
Handle to state handles for the operators in an operator chain.
|
KeyGroupRange
This class defines a range of key-group indexes.
|
KeyGroupsStateHandle
A handle to the partitioned stream operator state after it has been checkpointed.
|
OperatorStateHandle
State handle for partitionable operator state.
|
StateObject
Base of all types that represent checkpointed state.
|
StreamStateHandle
A
StateObject that represents state that was written to a stream. |
Class and Description |
---|
KeyGroupsStateHandle
A handle to the partitioned stream operator state after it has been checkpointed.
|
OperatorStateHandle
State handle for partitionable operator state.
|
StreamStateHandle
A
StateObject that represents state that was written to a stream. |
Class and Description |
---|
TaskStateHandles
This class encapsulates all state handles for a task.
|
Class and Description |
---|
TaskStateHandles
This class encapsulates all state handles for a task.
|
Class and Description |
---|
TaskStateHandles
This class encapsulates all state handles for a task.
|
Class and Description |
---|
KeyGroupRange
This class defines a range of key-group indexes.
|
KvState
Key/Value state implementation for user-defined state.
|
Class and Description |
---|
AbstractKeyedStateBackend
Base implementation of KeyedStateBackend.
|
AbstractStateBackend
A state backend defines how state is stored and snapshotted during checkpoints.
|
ChainedStateHandle
Handle to state handles for the operators in an operator chain.
|
CheckpointStreamFactory |
CheckpointStreamFactory.CheckpointStateOutputStream
A dedicated output stream that produces a
StreamStateHandle when closed. |
DoneFuture
A
Future that is always done and will just yield the object that was given at creation
time. |
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.
|
KeyedBackendSerializationProxy.StateMetaInfo
This is the serialization proxy for
RegisteredBackendStateMetaInfo for a single registered state in a
keyed backend. |
KeyedStateBackend
A keyed state backend provides methods for managing keyed state.
|
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.
|
KeyGroupRangeOffsets
This class combines a key-group range with offsets that correspond to the key-groups in the range.
|
KeyGroupsList
This interface offers ordered random read access to multiple key group ids.
|
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.
|
KvState
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.
|
NonClosingCheckpointOutputStream
Abstract class to implement custom checkpoint output streams which should not be closable for user code.
|
OperatorBackendSerializationProxy.StateMetaInfo |
OperatorStateBackend
Interface that combines both, the user facing
OperatorStateStore interface and the system interface
Snapshotable |
OperatorStateCheckpointOutputStream
Checkpoint output stream that allows to write raw operator state in a partitioned way.
|
OperatorStateHandle
State handle for partitionable operator state.
|
OperatorStateHandle.Mode |
OperatorStateHandle.StateMetaInfo |
RegisteredBackendStateMetaInfo
Compound meta information for a registered state in a keyed state backend.
|
RetrievableStateHandle
Handle to state that can be read back again via
RetrievableStateHandle.retrieveState() . |
SerializedCheckpointData
This class represents serialized checkpoint data for a collection of elements.
|
Snapshotable
Interface for operators that can perform snapshots of their state.
|
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.
|
StatePartitionStreamProvider
This class provides access to input streams that contain data of one state partition of a partitionable state.
|
StateSnapshotContext
This interface provides a context in which operators that use managed (i.e.
|
StreamStateHandle
A
StateObject that represents state that was written to a stream. |
TaskStateHandles
This class encapsulates all state handles for a task.
|
VoidNamespace
Uninstantiable placeholder class for state without a namespace.
|
VoidNamespaceSerializer
Serializer for
VoidNamespace . |
Class and Description |
---|
AbstractKeyedStateBackend
Base implementation of KeyedStateBackend.
|
AbstractStateBackend
A state backend defines how state is stored and snapshotted during checkpoints.
|
CheckpointStreamFactory |
CheckpointStreamFactory.CheckpointStateOutputStream
A dedicated output stream that produces a
StreamStateHandle when closed. |
KeyGroupRange
This class defines a range of key-group indexes.
|
StateBackendFactory
A factory to create a specific state backend.
|
StateObject
Base of all types that represent checkpointed state.
|
StreamStateHandle
A
StateObject that represents state that was written to a stream. |
Class and Description |
---|
AbstractKeyedStateBackend
Base implementation of KeyedStateBackend.
|
AbstractStateBackend
A state backend defines how state is stored and snapshotted during checkpoints.
|
CheckpointStreamFactory |
KeyGroupRange
This class defines a range of key-group indexes.
|
Class and Description |
---|
AbstractKeyedStateBackend
Base implementation of KeyedStateBackend.
|
CheckpointStreamFactory |
KeyedStateBackend
A keyed state backend provides methods for managing keyed state.
|
KeyGroupRange
This class defines a range of key-group indexes.
|
KeyGroupsStateHandle
A handle to the partitioned stream operator state after it has been checkpointed.
|
KvState
Key/Value state implementation for user-defined state.
|
RegisteredBackendStateMetaInfo
Compound meta information for a registered state in a keyed state backend.
|
Snapshotable
Interface for operators that can perform snapshots of their state.
|
Class and Description |
---|
AbstractKeyedStateBackend
Base implementation of KeyedStateBackend.
|
CheckpointStreamFactory |
KeyedStateBackend
A keyed state backend provides methods for managing keyed state.
|
KeyGroupRange
This class defines a range of key-group indexes.
|
KeyGroupsStateHandle
A handle to the partitioned stream operator state after it has been checkpointed.
|
KvState
Key/Value state implementation for user-defined state.
|
RegisteredBackendStateMetaInfo
Compound meta information for a registered state in a keyed state backend.
|
Snapshotable
Interface for operators that can perform snapshots of their state.
|
StateTransformationFunction
Interface for a binary function that is used for push-down of state transformation into state backends.
|
Class and Description |
---|
AbstractKeyedStateBackend
Base implementation of KeyedStateBackend.
|
AbstractStateBackend
A state backend defines how state is stored and snapshotted during checkpoints.
|
CheckpointStreamFactory |
CheckpointStreamFactory.CheckpointStateOutputStream
A dedicated output stream that produces a
StreamStateHandle when closed. |
KeyGroupRange
This class defines a range of key-group indexes.
|
StateObject
Base of all types that represent checkpointed state.
|
StreamStateHandle
A
StateObject that represents state that was written to a stream. |
Class and Description |
---|
AbstractKeyedStateBackend
Base implementation of KeyedStateBackend.
|
AbstractStateBackend
A state backend defines how state is stored and snapshotted during checkpoints.
|
CheckpointStreamFactory |
KeyGroupRange
This class defines a range of key-group indexes.
|
Class and Description |
---|
KeyGroupRange
This class defines a range of key-group indexes.
|
TaskStateHandles
This class encapsulates all state handles for a task.
|
Class and Description |
---|
RetrievableStateHandle
Handle to state that can be read back again via
RetrievableStateHandle.retrieveState() . |
Class and Description |
---|
RetrievableStateHandle
Handle to state that can be read back again via
RetrievableStateHandle.retrieveState() . |
Class and Description |
---|
VoidNamespace
Uninstantiable placeholder class for state without a namespace.
|
Class and Description |
---|
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.
|
Class and Description |
---|
AbstractStateBackend
A state backend defines how state is stored and snapshotted during checkpoints.
|
Class and 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.
|
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.
|
StateInitializationContext
This interface provides a context in which operators can initialize by registering to managed state (i.e.
|
StateSnapshotContext
This interface provides a context in which operators that use managed (i.e.
|
Class and Description |
---|
OperatorStateBackend
Interface that combines both, the user facing
OperatorStateStore interface and the system interface
Snapshotable |
StateInitializationContext
This interface provides a context in which operators can initialize by registering to managed state (i.e.
|
StateSnapshotContext
This interface provides a context in which operators that use managed (i.e.
|
Class and Description |
---|
AbstractStateBackend
A state backend defines how state is stored and snapshotted during checkpoints.
|
Class and Description |
---|
KeyedStateBackend
A keyed state backend provides methods for managing keyed state.
|
KeyGroupsList
This interface offers ordered random read access to multiple key group ids.
|
KeyGroupsStateHandle
A handle to the partitioned stream operator state after it has been checkpointed.
|
OperatorStateBackend
Interface that combines both, the user facing
OperatorStateStore interface and the system interface
Snapshotable |
OperatorStateHandle
State handle for partitionable operator state.
|
StateInitializationContext
This interface provides a context in which operators can initialize by registering to managed state (i.e.
|
StateSnapshotContext
This interface provides a context in which operators that use managed (i.e.
|
StreamStateHandle
A
StateObject that represents state that was written to a stream. |
VoidNamespace
Uninstantiable placeholder class for state without a namespace.
|
Class and Description |
---|
StateInitializationContext
This interface provides a context in which operators can initialize by registering to managed state (i.e.
|
StateSnapshotContext
This interface provides a context in which operators that use managed (i.e.
|
Class and Description |
---|
VoidNamespace
Uninstantiable placeholder class for state without a namespace.
|
Class and 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.
|
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.
|
Class and 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.
|
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.
|
Class and 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.
|
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.
|
Class and 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.
|
Class and Description |
---|
StateInitializationContext
This interface provides a context in which operators can initialize by registering to managed state (i.e.
|
StateSnapshotContext
This interface provides a context in which operators that use managed (i.e.
|
Class and Description |
---|
AbstractKeyedStateBackend
Base implementation of KeyedStateBackend.
|
CheckpointStreamFactory |
KeyGroupRange
This class defines a range of key-group indexes.
|
KeyGroupsStateHandle
A handle to the partitioned stream operator state after it has been checkpointed.
|
OperatorStateBackend
Interface that combines both, the user facing
OperatorStateStore interface and the system interface
Snapshotable |
OperatorStateHandle
State handle for partitionable operator state.
|
StreamStateHandle
A
StateObject that represents state that was written to a stream. |
TaskStateHandles
This class encapsulates all state handles for a task.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.