K
- The type of the key in the snapshot state.N
- The type of the namespace in the snapshot state.SV
- The type of the state value.@Deprecated public abstract class AbstractFsStateSnapshot<K,N,SV,S extends State,SD extends StateDescriptor<S,?>> extends AbstractFileStateHandle implements KvStateSnapshot<K,N,S,SD>
Modifier and Type | Field and Description |
---|---|
protected TypeSerializer<K> |
keySerializer
Deprecated.
Key Serializer
|
protected TypeSerializer<N> |
namespaceSerializer
Deprecated.
Namespace Serializer
|
protected SD |
stateDesc
Deprecated.
StateDescriptor, for sanity checks
|
protected TypeSerializer<SV> |
stateSerializer
Deprecated.
Serializer for the state value
|
Constructor and Description |
---|
AbstractFsStateSnapshot(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<SV> stateSerializer,
SD stateDesc,
Path filePath)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<K> |
getKeySerializer()
Deprecated.
|
TypeSerializer<N> |
getNamespaceSerializer()
Deprecated.
|
SD |
getStateDesc()
Deprecated.
|
TypeSerializer<SV> |
getStateSerializer()
Deprecated.
|
long |
getStateSize()
Deprecated.
Returns the size of the state in bytes.
|
discardState, getFilePath, getFileSize, getFileSystem
close, ensureNotClosed, isClosed, registerCloseable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
discardState
protected final TypeSerializer<K> keySerializer
protected final TypeSerializer<N> namespaceSerializer
protected final TypeSerializer<SV> stateSerializer
protected final SD extends StateDescriptor<S,?> stateDesc
public AbstractFsStateSnapshot(TypeSerializer<K> keySerializer, TypeSerializer<N> namespaceSerializer, TypeSerializer<SV> stateSerializer, SD stateDesc, Path filePath)
public long getStateSize() throws IOException
StateObject
If the the size is not known, return 0
.
getStateSize
in interface StateObject
IOException
public TypeSerializer<K> getKeySerializer()
public TypeSerializer<N> getNamespaceSerializer()
public TypeSerializer<SV> getStateSerializer()
public SD getStateDesc()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.