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:
AutoCloseable
-
Field Summary
Fields inherited from class org.apache.spark.sql.vectorized.ColumnVector
type
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionorg.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
-
Constructor Details
-
ColumnVectorWithFilter
-
-
Method Details
-
isNullAt
public boolean isNullAt(int rowId) - Overrides:
isNullAt
in classIcebergArrowColumnVector
-
getBoolean
public boolean getBoolean(int rowId) - Overrides:
getBoolean
in classIcebergArrowColumnVector
-
getInt
public int getInt(int rowId) - Overrides:
getInt
in classIcebergArrowColumnVector
-
getLong
public long getLong(int rowId) - Overrides:
getLong
in classIcebergArrowColumnVector
-
getFloat
public float getFloat(int rowId) - Overrides:
getFloat
in classIcebergArrowColumnVector
-
getDouble
public double getDouble(int rowId) - Overrides:
getDouble
in classIcebergArrowColumnVector
-
getArray
public org.apache.spark.sql.vectorized.ColumnarArray getArray(int rowId) - Overrides:
getArray
in classIcebergArrowColumnVector
-
getDecimal
public org.apache.spark.sql.types.Decimal getDecimal(int rowId, int precision, int scale) - Overrides:
getDecimal
in classIcebergArrowColumnVector
-
getUTF8String
public org.apache.spark.unsafe.types.UTF8String getUTF8String(int rowId) - Overrides:
getUTF8String
in classIcebergArrowColumnVector
-
getBinary
public byte[] getBinary(int rowId) - Overrides:
getBinary
in classIcebergArrowColumnVector
-