Modifier and Type | Method and Description |
---|---|
FoldingState<T,ACC> |
FoldingStateDescriptor.bind(StateBackend stateBackend) |
<T,ACC> FoldingState<T,ACC> |
StateBackend.createFoldingState(FoldingStateDescriptor<T,ACC> stateDesc)
Creates and returns a new
FoldingState . |
Modifier and Type | Class and Description |
---|---|
class |
RocksDBFoldingState<K,N,T,ACC>
FoldingState implementation that stores state in RocksDB. |
Modifier and Type | Method and Description |
---|---|
protected <N,T,ACC> FoldingState<T,ACC> |
RocksDBKeyedStateBackend.createFoldingState(TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc) |
Modifier and Type | Class and Description |
---|---|
class |
GenericFoldingState<N,T,ACC,W extends ValueState<ACC> & KvState<N>>
Generic implementation of
FoldingState based on a wrapped ValueState . |
Modifier and Type | Method and Description |
---|---|
protected abstract <N,T,ACC> FoldingState<T,ACC> |
AbstractKeyedStateBackend.createFoldingState(TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc)
Creates and returns a new
FoldingState . |
Modifier and Type | Class and Description |
---|---|
class |
HeapFoldingState<K,N,T,ACC>
Heap-backed partitioned
FoldingState that is
snapshotted into files. |
Modifier and Type | Method and Description |
---|---|
protected <N,T,ACC> FoldingState<T,ACC> |
HeapKeyedStateBackend.createFoldingState(TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc) |
Modifier and Type | Method and Description |
---|---|
<N,T,ACC> FoldingState<T,ACC> |
AsyncHeapKeyedStateBackend.createFoldingState(TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.