Package org.apache.iceberg.arrow.vectorized

Class ColumnVector

java.lang.Object

org.apache.iceberg.arrow.vectorized.ColumnVector

All Implemented Interfaces:

AutoCloseable

public class ColumnVector
extends Object
implements AutoCloseable

This class is inspired by Spark's ColumnVector. This class represents the column data for an Iceberg table query. It wraps an arrow FieldVector and provides simple accessors for the row values. Advanced users can access the FieldVector.

Supported Iceberg data types:

• Types.BooleanType
• Types.IntegerType
• Types.LongType
• Types.FloatType
• Types.DoubleType
• Types.StringType
• Types.BinaryType
• Types.FixedType
• Types.TimestampType (with and without timezone)
• Types.TimestampNanoType (with and without timezone)
• Types.DateType
• Types.TimeType
• Types.UUIDType
• Types.DecimalType

Method Summary

Modifier and Type	Method	Description
void	close()
org.apache.arrow.vector.FieldVector	getArrowVector()	Decodes a dict-encoded vector and returns the actual arrow vector.
byte[]	getBinary(int rowId)
boolean	getBoolean(int rowId)
BigDecimal	getDecimal(int rowId, int precision, int scale)
double	getDouble(int rowId)
org.apache.arrow.vector.FieldVector	getFieldVector()	Returns the potentially dict-encoded FieldVector.
float	getFloat(int rowId)
int	getInt(int rowId)
long	getLong(int rowId)
String	getString(int rowId)
boolean	hasNull()
boolean	isNullAt(int rowId)
int	numNulls()

Methods inherited from class java.lang.Object

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

Method Details

getFieldVector

public org.apache.arrow.vector.FieldVector getFieldVector()

Returns the potentially dict-encoded FieldVector.

Returns:

instance of FieldVector

getArrowVector

public org.apache.arrow.vector.FieldVector getArrowVector()

Decodes a dict-encoded vector and returns the actual arrow vector.

Returns:

instance of FieldVector

hasNull

public boolean hasNull()

numNulls

public int numNulls()

close

public void close()

Specified by:

close in interface AutoCloseable

isNullAt

public boolean isNullAt(int rowId)

getBoolean

public boolean getBoolean(int rowId)

getInt

public int getInt(int rowId)

getLong

public long getLong(int rowId)

getFloat

public float getFloat(int rowId)

getDouble

public double getDouble(int rowId)

getString

public String getString(int rowId)

getBinary

public byte[] getBinary(int rowId)

getDecimal

public BigDecimal getDecimal(int rowId,
 int precision,
 int scale)