org.apache.paimon.utils

Class SerializationUtils

java.lang.Object

org.apache.paimon.utils.SerializationUtils

public class SerializationUtils
extends Object

Utils for serialization.

Constructor Summary

Constructors

Constructor and Description
SerializationUtils()

Method Summary

Modifier and Type	Method and Description
static BinaryRow	deserializeBinaryRow(byte[] bytes) Schemaless deserialization for BinaryRow.
static BinaryRow	deserializeBinaryRow(DataInputView input) Schemaless deserialization for BinaryRow from a DataInputView.
static byte[]	deserializedBytes(DataInputView in) Deserialize a byte[] bytes with length.
static VarBinaryType	newBytesType(boolean isNullable) Create a bytes type VarBinaryType(VarBinaryType.MAX_LENGTH).
static VarCharType	newStringType(boolean isNullable) Create a varchar type VarCharType(VarCharType.MAX_LENGTH).
static byte[]	serializeBinaryRow(BinaryRow row) Serialize BinaryRow, the difference between this and BinaryRowSerializer is that arity is also serialized here, so the deserialization is schemaless.
static void	serializeBinaryRow(BinaryRow row, DataOutputView out) Serialize BinaryRow to a DataOutputView.
static void	serializeBytes(DataOutputView out, byte[] binary) Serialize a byte[] bytes with length.

Methods inherited from class java.lang.Object

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

Constructor Detail

SerializationUtils

public SerializationUtils()

Method Detail

serializeBytes

public static void serializeBytes(DataOutputView out,
                                  byte[] binary)
                           throws IOException

Serialize a byte[] bytes with length.

Throws:

IOException

deserializedBytes

public static byte[] deserializedBytes(DataInputView in)
                                throws IOException

Deserialize a byte[] bytes with length.

Throws:

IOException

newBytesType

public static VarBinaryType newBytesType(boolean isNullable)

Create a bytes type VarBinaryType(VarBinaryType.MAX_LENGTH).

newStringType

public static VarCharType newStringType(boolean isNullable)

Create a varchar type VarCharType(VarCharType.MAX_LENGTH).

serializeBinaryRow

public static byte[] serializeBinaryRow(BinaryRow row)

Serialize BinaryRow, the difference between this and BinaryRowSerializer is that arity is also serialized here, so the deserialization is schemaless.

deserializeBinaryRow

public static BinaryRow deserializeBinaryRow(byte[] bytes)

Schemaless deserialization for BinaryRow.

serializeBinaryRow

public static void serializeBinaryRow(BinaryRow row,
                                      DataOutputView out)
                               throws IOException

Serialize BinaryRow to a DataOutputView.

Throws:

IOException

See Also:

serializeBinaryRow(BinaryRow)

deserializeBinaryRow

public static BinaryRow deserializeBinaryRow(DataInputView input)
                                      throws IOException

Schemaless deserialization for BinaryRow from a DataInputView.

Throws:

IOException