Modifier and Type | Method and Description |
---|---|
<T,ACC> FoldingState<T,ACC> |
StateBackend.createFoldingState(FoldingStateDescriptor<T,ACC> stateDesc)
Creates and returns a new
FoldingState . |
Modifier and Type | Field and Description |
---|---|
protected FoldingStateDescriptor<T,ACC> |
RocksDBFoldingState.stateDesc
This holds the name of the state and can create an initial default value for the state.
|
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 | 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) |
Constructor and Description |
---|
RocksDBFoldingState(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc,
File dbPath,
String backupPath,
org.rocksdb.Options options)
Creates a new
RocksDBFoldingState . |
RocksDBFoldingState(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc,
File dbPath,
String backupPath,
String restorePath,
org.rocksdb.Options options)
Creates a
RocksDBFoldingState by restoring from a directory. |
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 | 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 |
---|---|
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 | Method and Description |
---|---|
protected <N,T,ACC> FoldingState<T,ACC> |
FsStateBackend.createFoldingState(TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc) |
Constructor and Description |
---|
FsFoldingState(FsStateBackend backend,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc)
Creates a new and empty partitioned state.
|
FsFoldingState(FsStateBackend backend,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc,
HashMap<N,Map<K,ACC>> state)
Creates a new key/value state with the given state contents.
|
Snapshot(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<ACC> stateSerializer,
FoldingStateDescriptor<T,ACC> stateDescs,
Path filePath) |
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) |
Modifier and Type | Method and Description |
---|---|
<N,T,ACC> FoldingState<T,ACC> |
MemoryStateBackend.createFoldingState(TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc) |
Constructor and Description |
---|
MemFoldingState(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc) |
MemFoldingState(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc,
HashMap<N,Map<K,ACC>> state) |
Snapshot(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<ACC> stateSerializer,
FoldingStateDescriptor<T,ACC> stateDescs,
byte[] data) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.