org.apache.flink.table.runtime.arrow.readers

Class ArrowFieldReader<OUT>

java.lang.Object

org.apache.flink.table.runtime.arrow.readers.ArrowFieldReader<OUT>

Type Parameters:

OUT - Type of the row to write.

Direct Known Subclasses:

ArrayFieldReader, BigIntFieldReader, BooleanFieldReader, DateFieldReader, DecimalFieldReader, DoubleFieldReader, FloatFieldReader, IntFieldReader, RowFieldReader, SmallIntFieldReader, TimeFieldReader, TimestampFieldReader, TinyIntFieldReader, VarBinaryFieldReader, VarCharFieldReader

@Internal
public abstract class ArrowFieldReader<OUT>
extends Object

Base class for arrow field reader.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
org.apache.arrow.vector.ValueVector	getValueVector() Returns the underlying container which stores the sequence of values of a column to read.
abstract OUT	read(int index) Sets the field value as the specified value.

Methods inherited from class java.lang.Object

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

Constructor Detail

ArrowFieldReader

public ArrowFieldReader(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 to read.

read

public abstract OUT read(int index)

Sets the field value as the specified value.