org.apache.paimon.arrow.writer

Class ArrowFieldWriter

java.lang.Object

org.apache.paimon.arrow.writer.ArrowFieldWriter

Direct Known Subclasses:

ArrowFieldWriters.ArrayWriter, ArrowFieldWriters.BigIntWriter, ArrowFieldWriters.BinaryWriter, ArrowFieldWriters.BooleanWriter, ArrowFieldWriters.DateWriter, ArrowFieldWriters.DecimalWriter, ArrowFieldWriters.DoubleWriter, ArrowFieldWriters.FloatWriter, ArrowFieldWriters.IntWriter, ArrowFieldWriters.MapWriter, ArrowFieldWriters.RowWriter, ArrowFieldWriters.SmallIntWriter, ArrowFieldWriters.StringWriter, ArrowFieldWriters.TimestampWriter, ArrowFieldWriters.TimeWriter, ArrowFieldWriters.TinyIntWriter

public abstract class ArrowFieldWriter
extends Object

A reusable writer to convert a field into Arrow FieldVector.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.arrow.vector.FieldVector	fieldVector

Constructor Summary

Constructors

Constructor and Description
ArrowFieldWriter(org.apache.arrow.vector.FieldVector fieldVector)

Method Summary

Modifier and Type	Method and Description
protected abstract void	doWrite(ColumnVector columnVector, int[] pickedInColumn, int startIndex, int batchRows)
protected abstract void	doWrite(int rowIndex, DataGetters getters, int pos)
protected int	getRowNumber(int startIndex, int currentIndex, int[] pickedInColumn)
void	reset() Reset the state of the writer to write the next batch of fields.
void	write(ColumnVector columnVector, int[] pickedInColumn, int startIndex, int batchRows) Write all data of a ColumnVector.
void	write(int rowIndex, DataGetters getters, int pos) Get the value from the row at the given position and write to specified row index.

Methods inherited from class java.lang.Object

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

Field Detail

fieldVector

protected final org.apache.arrow.vector.FieldVector fieldVector

Constructor Detail

ArrowFieldWriter

public ArrowFieldWriter(org.apache.arrow.vector.FieldVector fieldVector)

Method Detail

reset

public void reset()

Reset the state of the writer to write the next batch of fields.

write

public void write(ColumnVector columnVector,
                  @Nullable
                  int[] pickedInColumn,
                  int startIndex,
                  int batchRows)

Write all data of a ColumnVector.

Parameters:

columnVector - Which holds the paimon data.

pickedInColumn - Which rows is picked to write. Pick all if null. This is used to adapt deletion vector.

startIndex - From where to start writing.

batchRows - How many rows to write.

doWrite

protected abstract void doWrite(ColumnVector columnVector,
                                @Nullable
                                int[] pickedInColumn,
                                int startIndex,
                                int batchRows)

write

public void write(int rowIndex,
                  DataGetters getters,
                  int pos)

Get the value from the row at the given position and write to specified row index.

doWrite

protected abstract void doWrite(int rowIndex,
                                DataGetters getters,
                                int pos)

getRowNumber

protected int getRowNumber(int startIndex,
                           int currentIndex,
                           @Nullable
                           int[] pickedInColumn)