org.apache.iceberg.spark.data.vectorized

Class ColumnVectorWithFilter

java.lang.Object

org.apache.spark.sql.vectorized.ColumnVector

org.apache.iceberg.spark.data.vectorized.IcebergArrowColumnVector

org.apache.iceberg.spark.data.vectorized.ColumnVectorWithFilter

All Implemented Interfaces:

java.lang.AutoCloseable

public class ColumnVectorWithFilter
extends IcebergArrowColumnVector

Field Summary

Fields inherited from class org.apache.spark.sql.vectorized.ColumnVector

type

Constructor Summary

Constructors

Constructor and Description
ColumnVectorWithFilter(VectorHolder holder, int[] rowIdMapping)

Method Summary

Modifier and Type	Method and Description
static org.apache.spark.sql.vectorized.ColumnVector	forHolder(VectorHolder holder, int[] rowIdMapping, int numRows)
org.apache.spark.sql.vectorized.ColumnarArray	getArray(int rowId)
byte[]	getBinary(int rowId)
boolean	getBoolean(int rowId)
org.apache.spark.sql.types.Decimal	getDecimal(int rowId, int precision, int scale)
double	getDouble(int rowId)
float	getFloat(int rowId)
int	getInt(int rowId)
long	getLong(int rowId)
org.apache.spark.unsafe.types.UTF8String	getUTF8String(int rowId)
boolean	isNullAt(int rowId)

Methods inherited from class org.apache.iceberg.spark.data.vectorized.IcebergArrowColumnVector

accessor, close, getByte, getChild, getMap, getShort, hasNull, nullabilityHolder, numNulls, vectorAccessor

Methods inherited from class org.apache.spark.sql.vectorized.ColumnVector

dataType, getBooleans, getBytes, getDoubles, getFloats, getInterval, getInts, getLongs, getShorts, getStruct

Methods inherited from class java.lang.Object

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

Constructor Detail

ColumnVectorWithFilter

public ColumnVectorWithFilter(VectorHolder holder,
                              int[] rowIdMapping)

Method Detail

isNullAt

public boolean isNullAt(int rowId)

Overrides:

isNullAt in class IcebergArrowColumnVector

getBoolean

public boolean getBoolean(int rowId)

Overrides:

getBoolean in class IcebergArrowColumnVector

getInt

public int getInt(int rowId)

Overrides:

getInt in class IcebergArrowColumnVector

getLong

public long getLong(int rowId)

Overrides:

getLong in class IcebergArrowColumnVector

getFloat

public float getFloat(int rowId)

Overrides:

getFloat in class IcebergArrowColumnVector

getDouble

public double getDouble(int rowId)

Overrides:

getDouble in class IcebergArrowColumnVector

getArray

public org.apache.spark.sql.vectorized.ColumnarArray getArray(int rowId)

Overrides:

getArray in class IcebergArrowColumnVector

getDecimal

public org.apache.spark.sql.types.Decimal getDecimal(int rowId,
                                                     int precision,
                                                     int scale)

Overrides:

getDecimal in class IcebergArrowColumnVector

getUTF8String

public org.apache.spark.unsafe.types.UTF8String getUTF8String(int rowId)

Overrides:

getUTF8String in class IcebergArrowColumnVector

getBinary

public byte[] getBinary(int rowId)

Overrides:

getBinary in class IcebergArrowColumnVector

forHolder

public static org.apache.spark.sql.vectorized.ColumnVector forHolder(VectorHolder holder,
                                                                     int[] rowIdMapping,
                                                                     int numRows)