Package io.delta.kernel.defaults.internal.data.vector

Class DefaultSubFieldVector

Object

io.delta.kernel.defaults.internal.data.vector.DefaultSubFieldVector

All Implemented Interfaces:

io.delta.kernel.data.ColumnVector, AutoCloseable

public class DefaultSubFieldVector
extends Object
implements io.delta.kernel.data.ColumnVector

ColumnVector wrapper on top of Row objects. This wrapper allows referencing any nested level column vector from a set of rows.

Constructor Summary

Constructors

Constructor	Description
DefaultSubFieldVector(int size, io.delta.kernel.types.DataType dataType, int columnOrdinal, Function<Integer,io.delta.kernel.data.Row> rowIdToRowAccessor)	Create an instance of DefaultSubFieldVector

Method Summary

Modifier and Type	Method	Description
void	close()
io.delta.kernel.data.ArrayValue	getArray(int rowId)
byte[]	getBinary(int rowId)
boolean	getBoolean(int rowId)
byte	getByte(int rowId)
io.delta.kernel.data.ColumnVector	getChild(int childOrdinal)
io.delta.kernel.types.DataType	getDataType()
BigDecimal	getDecimal(int rowId)
double	getDouble(int rowId)
float	getFloat(int rowId)
int	getInt(int rowId)
long	getLong(int rowId)
io.delta.kernel.data.MapValue	getMap(int rowId)
short	getShort(int rowId)
int	getSize()
String	getString(int rowId)
boolean	isNullAt(int rowId)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultSubFieldVector

public DefaultSubFieldVector(int size,
 io.delta.kernel.types.DataType dataType,
 int columnOrdinal,
 Function<Integer,io.delta.kernel.data.Row> rowIdToRowAccessor)

Create an instance of DefaultSubFieldVector

Parameters:

size - Number of elements in the vector

dataType - Datatype of the vector

columnOrdinal - Ordinal of the column represented by this vector in the rows returned by rowIdToRowAccessor

rowIdToRowAccessor - Function that returns a Row object for given rowId

Method Details

getDataType

public io.delta.kernel.types.DataType getDataType()

Specified by:

getDataType in interface io.delta.kernel.data.ColumnVector

getSize

public int getSize()

Specified by:

getSize in interface io.delta.kernel.data.ColumnVector

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface io.delta.kernel.data.ColumnVector

isNullAt

public boolean isNullAt(int rowId)

Specified by:

isNullAt in interface io.delta.kernel.data.ColumnVector

getBoolean

public boolean getBoolean(int rowId)

Specified by:

getBoolean in interface io.delta.kernel.data.ColumnVector

getByte

public byte getByte(int rowId)

Specified by:

getByte in interface io.delta.kernel.data.ColumnVector

getShort

public short getShort(int rowId)

Specified by:

getShort in interface io.delta.kernel.data.ColumnVector

getInt

public int getInt(int rowId)

Specified by:

getInt in interface io.delta.kernel.data.ColumnVector

getLong

public long getLong(int rowId)

Specified by:

getLong in interface io.delta.kernel.data.ColumnVector

getFloat

public float getFloat(int rowId)

Specified by:

getFloat in interface io.delta.kernel.data.ColumnVector

getDouble

public double getDouble(int rowId)

Specified by:

getDouble in interface io.delta.kernel.data.ColumnVector

getBinary

public byte[] getBinary(int rowId)

Specified by:

getBinary in interface io.delta.kernel.data.ColumnVector

getString

public String getString(int rowId)

Specified by:

getString in interface io.delta.kernel.data.ColumnVector

getDecimal

public BigDecimal getDecimal(int rowId)

Specified by:

getDecimal in interface io.delta.kernel.data.ColumnVector

getMap

public io.delta.kernel.data.MapValue getMap(int rowId)

Specified by:

getMap in interface io.delta.kernel.data.ColumnVector

getArray

public io.delta.kernel.data.ArrayValue getArray(int rowId)

Specified by:

getArray in interface io.delta.kernel.data.ColumnVector

getChild

public io.delta.kernel.data.ColumnVector getChild(int childOrdinal)

Specified by:

getChild in interface io.delta.kernel.data.ColumnVector