org.apache.paimon.data

Interface BinaryWriter

All Known Implementing Classes:

BinaryArrayWriter, BinaryRowWriter

public interface BinaryWriter

Writer to write a composite data format, like row, array. 1. Invoke reset(). 2. Write each field by writeXX or setNullAt. (Same field can not be written repeatedly.) 3. Invoke complete().

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	BinaryWriter.ValueSetter Accessor for setting the elements of a binary writer during runtime.

Method Summary

Modifier and Type	Method and Description
void	complete() Finally, complete write to set real size to binary.
static BinaryWriter.ValueSetter	createValueSetter(DataType elementType) Creates an accessor for setting the elements of a binary writer during runtime.
static BinaryWriter.ValueSetter	createValueSetter(DataType elementType, Serializer<?> serializer)
void	reset() Reset writer to prepare next write.
void	setNullAt(int pos) Set null to this field.
static void	write(BinaryWriter writer, int pos, Object o, DataType type, Serializer<?> serializer) Deprecated. Use #createValueSetter(DataType) for avoiding logical types during runtime.
void	writeArray(int pos, InternalArray value, InternalArraySerializer serializer)
void	writeBinary(int pos, byte[] bytes)
void	writeBoolean(int pos, boolean value)
void	writeByte(int pos, byte value)
void	writeDecimal(int pos, Decimal value, int precision)
void	writeDouble(int pos, double value)
void	writeFloat(int pos, float value)
void	writeInt(int pos, int value)
void	writeLong(int pos, long value)
void	writeMap(int pos, InternalMap value, InternalMapSerializer serializer)
void	writeRow(int pos, InternalRow value, InternalRowSerializer serializer)
void	writeShort(int pos, short value)
void	writeString(int pos, BinaryString value)
void	writeTimestamp(int pos, Timestamp value, int precision)

Method Detail

reset

void reset()

Reset writer to prepare next write.

setNullAt

void setNullAt(int pos)

Set null to this field.

writeBoolean

void writeBoolean(int pos,
                  boolean value)

writeByte

void writeByte(int pos,
               byte value)

writeShort

void writeShort(int pos,
                short value)

writeInt

void writeInt(int pos,
              int value)

writeLong

void writeLong(int pos,
               long value)

writeFloat

void writeFloat(int pos,
                float value)

writeDouble

void writeDouble(int pos,
                 double value)

writeString

void writeString(int pos,
                 BinaryString value)

writeBinary

void writeBinary(int pos,
                 byte[] bytes)

writeDecimal

void writeDecimal(int pos,
                  Decimal value,
                  int precision)

writeTimestamp

void writeTimestamp(int pos,
                    Timestamp value,
                    int precision)

writeArray

void writeArray(int pos,
                InternalArray value,
                InternalArraySerializer serializer)

writeMap

void writeMap(int pos,
              InternalMap value,
              InternalMapSerializer serializer)

writeRow

void writeRow(int pos,
              InternalRow value,
              InternalRowSerializer serializer)

complete

void complete()

Finally, complete write to set real size to binary.

write

@Deprecated
static void write(BinaryWriter writer,
                              int pos,
                              Object o,
                              DataType type,
                              Serializer<?> serializer)

Deprecated. Use #createValueSetter(DataType) for avoiding logical types during runtime.

createValueSetter

static BinaryWriter.ValueSetter createValueSetter(DataType elementType)

Creates an accessor for setting the elements of a binary writer during runtime.

Parameters:

elementType - the element type

createValueSetter

static BinaryWriter.ValueSetter createValueSetter(DataType elementType,
                                                  Serializer<?> serializer)