org.apache.flink.runtime.state.filesystem

Class FsFoldingState.Snapshot<K,N,T,ACC>

java.lang.Object

org.apache.flink.runtime.state.filesystem.AbstractFileStateHandle

org.apache.flink.runtime.state.filesystem.AbstractFsStateSnapshot<K,N,ACC,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>>

org.apache.flink.runtime.state.filesystem.FsFoldingState.Snapshot<K,N,T,ACC>

All Implemented Interfaces:

Serializable, KvStateSnapshot<K,N,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>,FsStateBackend>

Enclosing class:

FsFoldingState<K,N,T,ACC>

public static class FsFoldingState.Snapshot<K,N,T,ACC>
extends AbstractFsStateSnapshot<K,N,ACC,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>>

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.runtime.state.filesystem.AbstractFsStateSnapshot

keySerializer, namespaceSerializer, stateDesc, stateSerializer

Constructor Summary

Constructors

Constructor and Description
Snapshot(TypeSerializer<K> keySerializer, TypeSerializer<N> namespaceSerializer, TypeSerializer<ACC> stateSerializer, FoldingStateDescriptor<T,ACC> stateDescs, Path filePath)

Method Summary

Modifier and Type	Method and Description
KvState<K,N,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>,FsStateBackend>	createFsState(FsStateBackend backend, HashMap<N,Map<K,ACC>> stateMap)

Methods inherited from class org.apache.flink.runtime.state.filesystem.AbstractFsStateSnapshot

getStateSize, restoreState

Methods inherited from class org.apache.flink.runtime.state.filesystem.AbstractFileStateHandle

discardState, getFilePath, getFileSize, getFileSystem

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.runtime.state.KvStateSnapshot

discardState

Constructor Detail

Snapshot

public Snapshot(TypeSerializer<K> keySerializer,
                TypeSerializer<N> namespaceSerializer,
                TypeSerializer<ACC> stateSerializer,
                FoldingStateDescriptor<T,ACC> stateDescs,
                Path filePath)

Method Detail

createFsState

public KvState<K,N,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>,FsStateBackend> createFsState(FsStateBackend backend,
                                                                                                   HashMap<N,Map<K,ACC>> stateMap)

Specified by:

createFsState in class AbstractFsStateSnapshot<K,N,ACC,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>>