Class | Description |
---|---|
AbstractMemState<K,N,SV,S extends State,SD extends StateDescriptor<S,?>> |
Base class for partitioned
ListState implementations that are backed by a regular
heap hash map. |
AbstractMemStateSnapshot<K,N,SV,S extends State,SD extends StateDescriptor<S,?>> |
A snapshot of a
MemValueState for a checkpoint. |
ByteStreamStateHandle |
A state handle that contains stream state in a byte array.
|
MemFoldingState<K,N,T,ACC> |
Heap-backed partitioned
FoldingState that is
snapshotted into a serialized memory copy. |
MemFoldingState.Snapshot<K,N,T,ACC> | |
MemListState<K,N,V> |
Heap-backed partitioned
ListState that is snapshotted
into a serialized memory copy. |
MemListState.Snapshot<K,N,V> | |
MemoryStateBackend |
A
AbstractStateBackend that stores all its data and checkpoints in memory and has no
capabilities to spill to disk. |
MemoryStateBackend.MemoryCheckpointOutputStream |
A CheckpointStateOutputStream that writes into a byte array.
|
MemReducingState<K,N,V> |
Heap-backed partitioned
ReducingState that is
snapshotted into a serialized memory copy. |
MemReducingState.Snapshot<K,N,V> | |
MemValueState<K,N,V> |
Heap-backed key/value state that is snapshotted into a serialized memory copy.
|
MemValueState.Snapshot<K,N,V> | |
SerializedStateHandle<T extends Serializable> |
A state handle that represents its state in serialized form as bytes.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.