org.apache.paimon.utils

Class ListDelimitedSerializer

java.lang.Object

org.apache.paimon.utils.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.

Constructor Summary

Constructors

Constructor and Description
ListDelimitedSerializer()

Method Summary

Modifier and Type	Method and Description
<T> List<T>	deserializeList(byte[] valueBytes, Serializer<T> elementSerializer)
static <T> T	deserializeNextElement(DataInputDeserializer in, Serializer<T> elementSerializer) Deserializes a single element from a serialized list.
byte[]	serializeList(List<byte[]> valueList)
<T> byte[]	serializeList(List<T> valueList, Serializer<T> elementSerializer)

Methods inherited from class java.lang.Object

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

Constructor Detail

ListDelimitedSerializer

public ListDelimitedSerializer()

Method Detail

deserializeList

public <T> List<T> deserializeList(byte[] valueBytes,
                                   Serializer<T> elementSerializer)

serializeList

public <T> byte[] serializeList(List<T> valueList,
                                Serializer<T> elementSerializer)
                         throws IOException

Throws:

IOException

serializeList

public byte[] serializeList(List<byte[]> valueList)
                     throws IOException

Throws:

IOException

deserializeNextElement

public static <T> T deserializeNextElement(DataInputDeserializer in,
                                           Serializer<T> elementSerializer)

Deserializes a single element from a serialized list.