org.apache.flink.runtime.state.memory

Class MemFoldingState<K,N,T,ACC>

java.lang.Object

org.apache.flink.runtime.state.AbstractHeapState<K,N,SV,S,SD,MemoryStateBackend>

org.apache.flink.runtime.state.memory.AbstractMemState<K,N,ACC,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>>

org.apache.flink.runtime.state.memory.MemFoldingState<K,N,T,ACC>

Type Parameters:

K - The type of the key.

N - The type of the namespace.

T - The type of the values that can be folded into the state.

ACC - The type of the value in the folding state.

All Implemented Interfaces:

FoldingState<T,ACC>, MergingState<T,ACC>, State, KvState<K,N,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>,MemoryStateBackend>

public class MemFoldingState<K,N,T,ACC>
extends AbstractMemState<K,N,ACC,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>>
implements FoldingState<T,ACC>

Heap-backed partitioned FoldingState that is snapshotted into a serialized memory copy.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MemFoldingState.Snapshot<K,N,T,ACC>

Field Summary

Fields inherited from class org.apache.flink.runtime.state.AbstractHeapState

currentKey, currentNamespace, currentNSState, keySerializer, namespaceSerializer, state, stateDesc, stateSerializer

Constructor Summary

Constructors

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)

Method Summary

Modifier and Type	Method and Description
void	add(T value) Updates the operator state accessible by MergingState.get() by adding the given value to the list of values.
KvStateSnapshot<K,N,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>,MemoryStateBackend>	createHeapSnapshot(byte[] bytes)
ACC	get() Returns the current value for the state.

Methods inherited from class org.apache.flink.runtime.state.memory.AbstractMemState

snapshot

Methods inherited from class org.apache.flink.runtime.state.AbstractHeapState

clear, dispose, getKeySerializer, getNamespaceSerializer, setCurrentKey, setCurrentNamespace, size

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.api.common.state.State

clear

Constructor Detail

MemFoldingState

public MemFoldingState(TypeSerializer<K> keySerializer,
                       TypeSerializer<N> namespaceSerializer,
                       FoldingStateDescriptor<T,ACC> stateDesc)

MemFoldingState

public MemFoldingState(TypeSerializer<K> keySerializer,
                       TypeSerializer<N> namespaceSerializer,
                       FoldingStateDescriptor<T,ACC> stateDesc,
                       HashMap<N,Map<K,ACC>> state)

Method Detail

get

public ACC get()

Description copied from interface: MergingState

Returns the current value for the state. When the state is not partitioned the returned value is the same for all inputs in a given operator instance. If state partitioning is applied, the value returned depends on the current operator input, as the operator maintains an independent state for each partition.

Specified by:

get in interface MergingState<T,ACC>

Returns:

The operator state value corresponding to the current input.

add

public void add(T value)
         throws IOException

Description copied from interface: MergingState

Updates the operator state accessible by MergingState.get() by adding the given value to the list of values. The next time MergingState.get() is called (for the same state partition) the returned state will represent the updated list.

Specified by:

add in interface MergingState<T,ACC>

Parameters:

value - The new value for the state.

Throws:

IOException - Thrown if the system cannot access the state.

createHeapSnapshot

public KvStateSnapshot<K,N,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>,MemoryStateBackend> createHeapSnapshot(byte[] bytes)

Specified by:

createHeapSnapshot in class AbstractMemState<K,N,ACC,FoldingState<T,ACC>,FoldingStateDescriptor<T,ACC>>