Class DeletedColumnVector
- java.lang.Object
-
- org.apache.spark.sql.vectorized.ColumnVector
-
- org.apache.iceberg.spark.data.vectorized.DeletedColumnVector
-
- All Implemented Interfaces:
java.lang.AutoCloseable
public class DeletedColumnVector extends org.apache.spark.sql.vectorized.ColumnVector
-
-
Constructor Summary
Constructors Constructor Description DeletedColumnVector(Type type, boolean[] isDeleted)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
org.apache.spark.sql.vectorized.ColumnarArray
getArray(int rowId)
byte[]
getBinary(int rowId)
boolean
getBoolean(int rowId)
byte
getByte(int rowId)
org.apache.spark.sql.vectorized.ColumnVector
getChild(int ordinal)
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.sql.vectorized.ColumnarMap
getMap(int ordinal)
short
getShort(int rowId)
org.apache.spark.unsafe.types.UTF8String
getUTF8String(int rowId)
boolean
hasNull()
boolean
isNullAt(int rowId)
int
numNulls()
-
-
-
Constructor Detail
-
DeletedColumnVector
public DeletedColumnVector(Type type, boolean[] isDeleted)
-
-
Method Detail
-
close
public void close()
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in classorg.apache.spark.sql.vectorized.ColumnVector
-
hasNull
public boolean hasNull()
- Specified by:
hasNull
in classorg.apache.spark.sql.vectorized.ColumnVector
-
numNulls
public int numNulls()
- Specified by:
numNulls
in classorg.apache.spark.sql.vectorized.ColumnVector
-
isNullAt
public boolean isNullAt(int rowId)
- Specified by:
isNullAt
in classorg.apache.spark.sql.vectorized.ColumnVector
-
getBoolean
public boolean getBoolean(int rowId)
- Specified by:
getBoolean
in classorg.apache.spark.sql.vectorized.ColumnVector
-
getByte
public byte getByte(int rowId)
- Specified by:
getByte
in classorg.apache.spark.sql.vectorized.ColumnVector
-
getShort
public short getShort(int rowId)
- Specified by:
getShort
in classorg.apache.spark.sql.vectorized.ColumnVector
-
getInt
public int getInt(int rowId)
- Specified by:
getInt
in classorg.apache.spark.sql.vectorized.ColumnVector
-
getLong
public long getLong(int rowId)
- Specified by:
getLong
in classorg.apache.spark.sql.vectorized.ColumnVector
-
getFloat
public float getFloat(int rowId)
- Specified by:
getFloat
in classorg.apache.spark.sql.vectorized.ColumnVector
-
getDouble
public double getDouble(int rowId)
- Specified by:
getDouble
in classorg.apache.spark.sql.vectorized.ColumnVector
-
getArray
public org.apache.spark.sql.vectorized.ColumnarArray getArray(int rowId)
- Specified by:
getArray
in classorg.apache.spark.sql.vectorized.ColumnVector
-
getMap
public org.apache.spark.sql.vectorized.ColumnarMap getMap(int ordinal)
- Specified by:
getMap
in classorg.apache.spark.sql.vectorized.ColumnVector
-
getDecimal
public org.apache.spark.sql.types.Decimal getDecimal(int rowId, int precision, int scale)
- Specified by:
getDecimal
in classorg.apache.spark.sql.vectorized.ColumnVector
-
getUTF8String
public org.apache.spark.unsafe.types.UTF8String getUTF8String(int rowId)
- Specified by:
getUTF8String
in classorg.apache.spark.sql.vectorized.ColumnVector
-
getBinary
public byte[] getBinary(int rowId)
- Specified by:
getBinary
in classorg.apache.spark.sql.vectorized.ColumnVector
-
getChild
public org.apache.spark.sql.vectorized.ColumnVector getChild(int ordinal)
- Specified by:
getChild
in classorg.apache.spark.sql.vectorized.ColumnVector
-
-