org.apache.iceberg.arrow.vectorized

Class ColumnVector

java.lang.Object

org.apache.iceberg.arrow.vectorized.ColumnVector

All Implemented Interfaces:

java.lang.AutoCloseable

public class ColumnVector
extends java.lang.Object
implements java.lang.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.TimestampType (with and without timezone)
• Types.DateType
• Types.TimeType
• Types.UUIDType

Method Summary

Modifier and Type	Method and Description
void	close()
byte[]	getBinary(int rowId)
boolean	getBoolean(int rowId)
double	getDouble(int rowId)
org.apache.arrow.vector.FieldVector	getFieldVector()
float	getFloat(int rowId)
int	getInt(int rowId)
long	getLong(int rowId)
java.lang.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 Detail

getFieldVector

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

hasNull

public boolean hasNull()

numNulls

public int numNulls()

close

public void close()

Specified by:

close in interface java.lang.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 java.lang.String getString(int rowId)

getBinary

public byte[] getBinary(int rowId)