Package org.apache.flink.state.forst

Class ListDelimitedSerializer

java.lang.Object

org.apache.flink.state.forst.ListDelimitedSerializer

public final class ListDelimitedSerializer
extends Object

Encapsulates a logic of serialization and deserialization of a list with a delimiter. Used in the savepoint format.

Method Summary

Modifier and Type	Method	Description
static <T> List<T>	deserializeList(byte[] valueBytes, org.apache.flink.api.common.typeutils.TypeSerializer<T> elementSerializer, org.apache.flink.core.memory.DataInputDeserializer dataInputView)
static <T> T	deserializeNextElement(org.apache.flink.core.memory.DataInputDeserializer in, org.apache.flink.api.common.typeutils.TypeSerializer<T> elementSerializer)	Deserializes a single element from a serialized list.
static <T> byte[]	serializeList(List<T> valueList, org.apache.flink.api.common.typeutils.TypeSerializer<T> elementSerializer, org.apache.flink.core.memory.DataOutputSerializer dataOutputView)

Methods inherited from class java.lang.Object

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

Method Detail

deserializeList

public static <T> List<T> deserializeList(byte[] valueBytes,
                                          org.apache.flink.api.common.typeutils.TypeSerializer<T> elementSerializer,
                                          org.apache.flink.core.memory.DataInputDeserializer dataInputView)
                                   throws IOException

Throws:

IOException

serializeList

public static <T> byte[] serializeList(List<T> valueList,
                                       org.apache.flink.api.common.typeutils.TypeSerializer<T> elementSerializer,
                                       org.apache.flink.core.memory.DataOutputSerializer dataOutputView)
                                throws IOException

Throws:

IOException

deserializeNextElement

public static <T> T deserializeNextElement(org.apache.flink.core.memory.DataInputDeserializer in,
                                           org.apache.flink.api.common.typeutils.TypeSerializer<T> elementSerializer)
                                    throws IOException

Deserializes a single element from a serialized list.

Throws:

IOException