Class | Description |
---|---|
AbstractFileStateHandle |
Base class for state that is stored in a file.
|
AbstractFsState<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. |
AbstractFsStateSnapshot<K,N,SV,S extends State,SD extends StateDescriptor<S,?>> |
A snapshot of a heap key/value state stored in a file.
|
FileSerializableStateHandle<T extends Serializable> |
A state handle that points to state stored in a file via Java Serialization.
|
FileStreamStateHandle |
A state handle that points to state in a file system, accessible as an input stream.
|
FsFoldingState<K,N,T,ACC> |
Heap-backed partitioned
FoldingState that is
snapshotted into files. |
FsFoldingState.Snapshot<K,N,T,ACC> | |
FsListState<K,N,V> |
Heap-backed partitioned
ListState that is snapshotted
into files. |
FsListState.Snapshot<K,N,V> | |
FsReducingState<K,N,V> |
Heap-backed partitioned
ReducingState that is
snapshotted into files. |
FsReducingState.Snapshot<K,N,V> | |
FsStateBackend |
The file state backend is a state backend that stores the state of streaming jobs in a file system.
|
FsStateBackend.FsCheckpointStateOutputStream |
A CheckpointStateOutputStream that writes into a file and returns the path to that file upon
closing.
|
FsStateBackendFactory |
A factory that creates an
FsStateBackend
from a configuration. |
FsValueState<K,N,V> |
Heap-backed partitioned
ValueState that is snapshotted
into files. |
FsValueState.Snapshot<K,N,V> |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.