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'sColumnVector
. This class represents the column data for an Iceberg table query. It wraps an arrowFieldVector
and provides simple accessors for the row values. Advanced users can access theFieldVector
.Supported Iceberg data types:
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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()
-
-
-
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 interfacejava.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)
-
-