org.apache.flink.runtime.state.heap

Class CopyOnWriteSkipListStateMapSnapshot<K,N,S>

java.lang.Object

org.apache.flink.runtime.state.heap.StateMapSnapshot<K,N,S,CopyOnWriteSkipListStateMap<K,N,S>>

org.apache.flink.runtime.state.heap.CopyOnWriteSkipListStateMapSnapshot<K,N,S>

Type Parameters:

K - type of key

N - type of namespace

S - type of state

public class CopyOnWriteSkipListStateMapSnapshot<K,N,S>
extends StateMapSnapshot<K,N,S,CopyOnWriteSkipListStateMap<K,N,S>>

This class represents the snapshot of a CopyOnWriteSkipListStateMap.

Field Summary

Fields inherited from class org.apache.flink.runtime.state.heap.StateMapSnapshot

owningStateMap

Method Summary

Modifier and Type	Method and Description
Iterator<StateEntry<K,N,S>>	getIterator(TypeSerializer<K> keySerializer, TypeSerializer<N> namespaceSerializer, TypeSerializer<S> stateSerializer, StateSnapshotTransformer<S> stateSnapshotTransformer)
void	release() Release the snapshot.
void	writeState(TypeSerializer<K> keySerializer, TypeSerializer<N> namespaceSerializer, TypeSerializer<S> stateSerializer, DataOutputView dov, StateSnapshotTransformer<S> stateSnapshotTransformer) Writes the state in this snapshot to output.

Methods inherited from class org.apache.flink.runtime.state.heap.StateMapSnapshot

isOwner

Methods inherited from class java.lang.Object

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

Method Detail

release

public void release()

Description copied from class: StateMapSnapshot

Release the snapshot.

Overrides:

release in class StateMapSnapshot<K,N,S,CopyOnWriteSkipListStateMap<K,N,S>>

getIterator

public Iterator<StateEntry<K,N,S>> getIterator(@Nonnull
                                               TypeSerializer<K> keySerializer,
                                               @Nonnull
                                               TypeSerializer<N> namespaceSerializer,
                                               @Nonnull
                                               TypeSerializer<S> stateSerializer,
                                               @Nullable
                                               StateSnapshotTransformer<S> stateSnapshotTransformer)

Specified by:

getIterator in class StateMapSnapshot<K,N,S,CopyOnWriteSkipListStateMap<K,N,S>>

writeState

public void writeState(TypeSerializer<K> keySerializer,
                       TypeSerializer<N> namespaceSerializer,
                       TypeSerializer<S> stateSerializer,
                       @Nonnull
                       DataOutputView dov,
                       @Nullable
                       StateSnapshotTransformer<S> stateSnapshotTransformer)
                throws IOException

Description copied from class: StateMapSnapshot

Writes the state in this snapshot to output. The state need to be transformed with the given transformer if the transformer is non-null.

Specified by:

writeState in class StateMapSnapshot<K,N,S,CopyOnWriteSkipListStateMap<K,N,S>>

Parameters:

keySerializer - the key serializer.

namespaceSerializer - the namespace serializer.

stateSerializer - the state serializer.

dov - the output.

stateSnapshotTransformer - state transformer, and can be null.

Throws:

IOException - on write-related problems.