Class and Description |
---|
AbstractStateBackend
A state backend defines how state is stored and snapshotted during checkpoints.
|
AbstractStateBackend.CheckpointStateOutputStream
A dedicated output stream that produces a
StreamStateHandle when closed. |
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.
|
KvState
Key/Value state implementation for user-defined state.
|
KvStateSnapshot
This class represents a snapshot of the
KvState , taken for a checkpoint. |
StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
Class and Description |
---|
StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
Class and Description |
---|
StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
Class and Description |
---|
StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
Class and Description |
---|
StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
Class and Description |
---|
StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
Class and Description |
---|
StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
Class and Description |
---|
AbstractStateBackend
A state backend defines how state is stored and snapshotted during checkpoints.
|
AbstractStateBackend.CheckpointStateOutputStream
A dedicated output stream that produces a
StreamStateHandle when closed. |
AbstractStateBackend.CheckpointStateOutputView
A dedicated DataOutputView stream that produces a
StateHandle<DataInputView> when closed. |
KvState
Key/Value state implementation for user-defined state.
|
KvStateSnapshot
This class represents a snapshot of the
KvState , taken for a checkpoint. |
SerializedCheckpointData
This class represents serialized checkpoint data for a collection of elements.
|
StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
StreamStateHandle
A state handle that produces an input stream when resolved.
|
Class and Description |
---|
AbstractHeapState
Base class for partitioned
ListState implementations that are backed by a regular
heap hash map. |
AbstractStateBackend
A state backend defines how state is stored and snapshotted during checkpoints.
|
AbstractStateBackend.CheckpointStateOutputStream
A dedicated output stream that produces a
StreamStateHandle when closed. |
KvState
Key/Value state implementation for user-defined state.
|
KvStateSnapshot
This class represents a snapshot of the
KvState , taken for a checkpoint. |
StateBackendFactory
A factory to create a specific state backend.
|
StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
StreamStateHandle
A state handle that produces an input stream when resolved.
|
Class and Description |
---|
AbstractHeapState
Base class for partitioned
ListState implementations that are backed by a regular
heap hash map. |
AbstractStateBackend
A state backend defines how state is stored and snapshotted during checkpoints.
|
AbstractStateBackend.CheckpointStateOutputStream
A dedicated output stream that produces a
StreamStateHandle when closed. |
KvState
Key/Value state implementation for user-defined state.
|
KvStateSnapshot
This class represents a snapshot of the
KvState , taken for a checkpoint. |
StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
StreamStateHandle
A state handle that produces an input stream when resolved.
|
Class and Description |
---|
StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
Class and Description |
---|
StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
Class and Description |
---|
StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
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.
|
SerializedCheckpointData
This class represents serialized checkpoint data for a collection of elements.
|
Class and Description |
---|
AbstractStateBackend
A state backend defines how state is stored and snapshotted during checkpoints.
|
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.
|
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 |
---|
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 |
---|
AbstractStateBackend.CheckpointStateOutputView
A dedicated DataOutputView stream that produces a
StateHandle<DataInputView> when closed. |
Class and Description |
---|
AbstractStateBackend
A state backend defines how state is stored and snapshotted during checkpoints.
|
KvStateSnapshot
This class represents a snapshot of the
KvState , taken for a checkpoint. |
StateHandle
StateHandle is a general handle interface meant to abstract operator state fetching.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.