org.apache.flink.runtime.state.heap

Class HeapFoldingState<K,N,T,ACC>

java.lang.Object

org.apache.flink.runtime.state.heap.AbstractHeapState<K,N,ACC,FoldingState<T,ACC>>

org.apache.flink.runtime.state.heap.HeapFoldingState<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:

AppendingState<T,ACC>, FoldingState<T,ACC>, State, InternalAppendingState<K,N,T,ACC,ACC>, InternalFoldingState<K,N,T,ACC>, InternalKvState<K,N,ACC>

Deprecated.

will be removed in a future version

@Deprecated
public class HeapFoldingState<K,N,T,ACC>
extends AbstractHeapState<K,N,ACC,FoldingState<T,ACC>>
implements InternalFoldingState<K,N,T,ACC>

Heap-backed partitioned FoldingState that is snapshotted into files.

Field Summary

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

currentNamespace, keySerializer, namespaceSerializer, stateTable, valueSerializer

Constructor Summary

Constructors

Constructor and Description
HeapFoldingState(StateTable<K,N,ACC> stateTable, TypeSerializer<K> keySerializer, TypeSerializer<ACC> valueSerializer, TypeSerializer<N> namespaceSerializer, ACC defaultValue, FoldFunction<T,ACC> foldFunction) Deprecated. Creates a new key/value state for the given hash map of key/value pairs.

Method Summary

Modifier and Type	Method and Description
void	add(T value) Deprecated. Updates the operator state accessible by AppendingState.get() by adding the given value to the list of values.
ACC	get() Deprecated. Returns the current value for the state.
TypeSerializer<K>	getKeySerializer() Deprecated. Returns the TypeSerializer for the type of key this state is associated to.
TypeSerializer<N>	getNamespaceSerializer() Deprecated. Returns the TypeSerializer for the type of namespace this state is associated to.
TypeSerializer<ACC>	getValueSerializer() Deprecated. Returns the TypeSerializer for the type of value this state holds.

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

clear, getDefaultValue, getSerializedValue, getStateTable, setCurrentNamespace

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.internal.InternalKvState

getSerializedValue, setCurrentNamespace

Methods inherited from interface org.apache.flink.api.common.state.State

clear

Constructor Detail

HeapFoldingState

public HeapFoldingState(StateTable<K,N,ACC> stateTable,
                        TypeSerializer<K> keySerializer,
                        TypeSerializer<ACC> valueSerializer,
                        TypeSerializer<N> namespaceSerializer,
                        ACC defaultValue,
                        FoldFunction<T,ACC> foldFunction)

Deprecated.

Creates a new key/value state for the given hash map of key/value pairs.

Parameters:

stateTable - The state table for which this state is associated to.

keySerializer - The serializer for the keys.

valueSerializer - The serializer for the state.

namespaceSerializer - The serializer for the namespace.

defaultValue - The default value for the state.

foldFunction - The fold function used for folding state.

Method Detail

getKeySerializer

public TypeSerializer<K> getKeySerializer()

Deprecated.

Description copied from interface: InternalKvState

Returns the TypeSerializer for the type of key this state is associated to.

Specified by:

getKeySerializer in interface InternalKvState<K,N,ACC>

getNamespaceSerializer

public TypeSerializer<N> getNamespaceSerializer()

Deprecated.

Description copied from interface: InternalKvState

Returns the TypeSerializer for the type of namespace this state is associated to.

Specified by:

getNamespaceSerializer in interface InternalKvState<K,N,ACC>

getValueSerializer

public TypeSerializer<ACC> getValueSerializer()

Deprecated.

Description copied from interface: InternalKvState

Returns the TypeSerializer for the type of value this state holds.

Specified by:

getValueSerializer in interface InternalKvState<K,N,ACC>

get

public ACC get()

Deprecated.

Description copied from interface: AppendingState

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.

NOTE TO IMPLEMENTERS: if the state is empty, then this method should return null.

Specified by:

get in interface AppendingState<T,ACC>

Returns:

The operator state value corresponding to the current input or null if the state is empty.

add

public void add(T value)
         throws IOException

Deprecated.

Description copied from interface: AppendingState

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

If null is passed in, the state value will remain unchanged.

Specified by:

add in interface AppendingState<T,ACC>

Parameters:

value - The new value for the state.

Throws:

IOException