org.apache.flink.table.runtime.arrow.writers

Class ArrowFieldWriter<IN>

java.lang.Object

org.apache.flink.table.runtime.arrow.writers.ArrowFieldWriter<IN>

Type Parameters:

IN - Type of the row to write.

Direct Known Subclasses:

ArrayWriter, BigIntWriter, BinaryWriter, BooleanWriter, DateWriter, DecimalWriter, DoubleWriter, FloatWriter, IntWriter, MapWriter, NullWriter, RowWriter, SmallIntWriter, TimestampWriter, TimeWriter, TinyIntWriter, VarBinaryWriter, VarCharWriter

@Internal
public abstract class ArrowFieldWriter<IN>
extends Object

Base class for arrow field writer which is used to convert a field to an Arrow format.

Constructor Summary

Constructors

Constructor and Description
ArrowFieldWriter(org.apache.arrow.vector.ValueVector valueVector)

Method Summary

Modifier and Type	Method and Description
abstract void	doWrite(IN row, int ordinal) Sets the field value as the field at the specified ordinal of the specified row.
void	finish() Finishes the writing of the current row batch.
int	getCount() Returns the current count of elements written.
org.apache.arrow.vector.ValueVector	getValueVector() Returns the underlying container which stores the sequence of values of a column.
void	reset() Resets the state of the writer to write the next batch of fields.
void	write(IN row, int ordinal) Writes the specified ordinal of the specified row.

Methods inherited from class java.lang.Object

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

Constructor Detail

ArrowFieldWriter

public ArrowFieldWriter(org.apache.arrow.vector.ValueVector valueVector)

Method Detail

getValueVector

public org.apache.arrow.vector.ValueVector getValueVector()

Returns the underlying container which stores the sequence of values of a column.

getCount

public int getCount()

Returns the current count of elements written.

doWrite

public abstract void doWrite(IN row,
                             int ordinal)

Sets the field value as the field at the specified ordinal of the specified row.

write

public void write(IN row,
                  int ordinal)

Writes the specified ordinal of the specified row.

finish

public void finish()

Finishes the writing of the current row batch.

reset

public void reset()

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