public static class FsValueState.Snapshot<K,N,V> extends AbstractFsStateSnapshot<K,N,V,ValueState<V>,ValueStateDescriptor<V>>
keySerializer, namespaceSerializer, stateDesc, stateSerializer
Constructor and Description |
---|
Snapshot(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<V> stateSerializer,
ValueStateDescriptor<V> stateDescs,
Path filePath) |
Modifier and Type | Method and Description |
---|---|
KvState<K,N,ValueState<V>,ValueStateDescriptor<V>,FsStateBackend> |
createFsState(FsStateBackend backend,
HashMap<N,Map<K,V>> stateMap) |
getStateSize, restoreState
discardState, getFilePath, getFileSize, getFileSystem
close, ensureNotClosed, isClosed, registerCloseable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
discardState
public Snapshot(TypeSerializer<K> keySerializer, TypeSerializer<N> namespaceSerializer, TypeSerializer<V> stateSerializer, ValueStateDescriptor<V> stateDescs, Path filePath)
public KvState<K,N,ValueState<V>,ValueStateDescriptor<V>,FsStateBackend> createFsState(FsStateBackend backend, HashMap<N,Map<K,V>> stateMap)
createFsState
in class AbstractFsStateSnapshot<K,N,V,ValueState<V>,ValueStateDescriptor<V>>
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.