org.apache.flink.runtime.query

Class KvStateInfo<K,N,V>

java.lang.Object

org.apache.flink.runtime.query.KvStateInfo<K,N,V>

Type Parameters:

K - The type of key the state is associated to

N - The type of the namespace the state is associated to

V - The type of values kept internally in state

public class KvStateInfo<K,N,V>
extends Object

Metadata about a InternalKvState. This includes the serializers for the key, the namespace, and the values kept in the state.

Constructor Summary

Constructors

Constructor and Description
KvStateInfo(TypeSerializer<K> keySerializer, TypeSerializer<N> namespaceSerializer, TypeSerializer<V> stateValueSerializer)

Method Summary

Modifier and Type	Method and Description
KvStateInfo<K,N,V>	duplicate() Creates a deep copy of the current KvStateInfo by duplicating all the included serializers.
boolean	equals(Object o)
TypeSerializer<K>	getKeySerializer()
TypeSerializer<N>	getNamespaceSerializer()
TypeSerializer<V>	getStateValueSerializer()
int	hashCode()

Methods inherited from class java.lang.Object

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

Constructor Detail

KvStateInfo

public KvStateInfo(TypeSerializer<K> keySerializer,
                   TypeSerializer<N> namespaceSerializer,
                   TypeSerializer<V> stateValueSerializer)

Method Detail

getKeySerializer

public TypeSerializer<K> getKeySerializer()

Returns:

The serializer for the key the state is associated to.

getNamespaceSerializer

public TypeSerializer<N> getNamespaceSerializer()

Returns:

The serializer for the namespace the state is associated to.

getStateValueSerializer

public TypeSerializer<V> getStateValueSerializer()

Returns:

The serializer for the values kept in the state.

duplicate

public KvStateInfo<K,N,V> duplicate()

Creates a deep copy of the current KvStateInfo by duplicating all the included serializers.

This method assumes correct implementation of the TypeSerializer.duplicate() method of the included serializers.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object