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> |
DbStateBackend.createFoldingState(TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc) |
protected <N,T,ACC> FoldingState<T,ACC> |
RocksDBStateBackend.createFoldingState(TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc) |
Modifier and Type | Method and Description |
---|---|
protected AbstractRocksDBState.AbstractRocksDBSnapshot<K,N,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>> |
RocksDBFoldingState.createRocksDBSnapshot(URI backupUri,
long checkpointId) |
Modifier and Type | Class and Description |
---|---|
class |
GenericFoldingState<K,N,T,ACC,Backend extends AbstractStateBackend,W extends ValueState<ACC> & KvState<K,N,ValueState<ACC>,ValueStateDescriptor<ACC>,Backend>>
Generic implementation of
FoldingState based on a wrapped ValueState . |
Modifier and Type | Method and Description |
---|---|
protected abstract <N,T,ACC> FoldingState<T,ACC> |
AbstractStateBackend.createFoldingState(TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc)
Creates and returns a new
FoldingState . |
Modifier and Type | Method and Description |
---|---|
KvStateSnapshot<K,N,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>,Backend> |
GenericFoldingState.snapshot(long checkpointId,
long timestamp) |
Modifier and Type | Class and Description |
---|---|
class |
FsFoldingState<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> |
FsStateBackend.createFoldingState(TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc) |
Modifier and Type | Method and Description |
---|---|
KvState<K,N,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>,FsStateBackend> |
FsFoldingState.Snapshot.createFsState(FsStateBackend backend,
HashMap<N,Map<K,ACC>> stateMap) |
KvStateSnapshot<K,N,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>,FsStateBackend> |
FsFoldingState.createHeapSnapshot(Path filePath) |
Modifier and Type | Class and Description |
---|---|
class |
MemFoldingState<K,N,T,ACC>
Heap-backed partitioned
FoldingState that is
snapshotted into a serialized memory copy. |
Modifier and Type | Method and Description |
---|---|
<N,T,ACC> FoldingState<T,ACC> |
MemoryStateBackend.createFoldingState(TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc) |
Modifier and Type | Method and Description |
---|---|
KvStateSnapshot<K,N,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>,MemoryStateBackend> |
MemFoldingState.createHeapSnapshot(byte[] bytes) |
KvState<K,N,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>,MemoryStateBackend> |
MemFoldingState.Snapshot.createMemState(HashMap<N,Map<K,ACC>> stateMap) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.