Package org.apache.flink.state.forst

Class ForStSerializerUtils

java.lang.Object

org.apache.flink.state.forst.ForStSerializerUtils

public class ForStSerializerUtils
extends Object

A utility of serialization keys in ForSt.

Method Summary

Modifier and Type	Method	Description
static <K,N> byte[]	serializeKeyAndNamespace(ContextKey<K,N> contextKey, org.apache.flink.runtime.state.SerializedCompositeKeyBuilder<K> builder, N defaultNamespace, org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer, boolean enableKeyReuse)	Serialize a key and namespace.

Methods inherited from class java.lang.Object

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

Method Detail

serializeKeyAndNamespace

public static <K,N> byte[] serializeKeyAndNamespace(ContextKey<K,N> contextKey,
                                                          org.apache.flink.runtime.state.SerializedCompositeKeyBuilder<K> builder,
                                                          N defaultNamespace,
                                                          org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer,
                                                          boolean enableKeyReuse)
                                                   throws IOException

Serialize a key and namespace. No user key.

Parameters:

contextKey - the context key of current request

builder - key builder

defaultNamespace - default namespace of the state

namespaceSerializer - the namespace serializer

enableKeyReuse - whether to enable key reuse

Throws:

IOException