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

Class DefaultViewVector

Object

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

All Implemented Interfaces:

io.delta.kernel.data.ColumnVector, AutoCloseable

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

Provides a restricted view on an underlying column vector.

Constructor Summary

Constructors

Constructor	Description
DefaultViewVector(io.delta.kernel.data.ColumnVector underlyingVector, int start, int end)

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 ordinal)
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

DefaultViewVector

public DefaultViewVector(io.delta.kernel.data.ColumnVector underlyingVector,
 int start,
 int end)

Parameters:

underlyingVector - the underlying column vector to read

start - the row index of the underlyingVector where we want this vector to start

end - the row index of the underlyingVector where we want this vector to end (exclusive)

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 ordinal)

Specified by:

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