org.apache.spark.sql

Class CarbonVectorProxy.ColumnVectorProxy

java.lang.Object

org.apache.spark.sql.vectorized.ColumnVector

org.apache.spark.sql.CarbonVectorProxy.ColumnVectorProxy

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

CarbonVectorProxy.ColumnVectorProxyWithLazyLoad

Enclosing class:

CarbonVectorProxy

public static class CarbonVectorProxy.ColumnVectorProxy
extends org.apache.spark.sql.vectorized.ColumnVector

Field Summary

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

type

Constructor Summary

Constructors

Constructor and Description
ColumnVectorProxy(org.apache.spark.sql.vectorized.ColumnVector columnVector)

Method Summary

Modifier and Type	Method and Description
void	close()
org.apache.spark.sql.vectorized.ColumnarArray	getArray(int i)
byte[]	getBinary(int i)
boolean	getBoolean(int i)
byte	getByte(int i)
protected org.apache.spark.sql.vectorized.ColumnVector	getChild(int i)
org.apache.spark.sql.types.Decimal	getDecimal(int i, int i1, int i2)
double	getDouble(int i)
float	getFloat(int i)
int	getInt(int i)
long	getLong(int i)
org.apache.spark.sql.vectorized.ColumnarMap	getMap(int i)
short	getShort(int i)
org.apache.spark.unsafe.types.UTF8String	getUTF8String(int i)
org.apache.spark.sql.execution.vectorized.WritableColumnVector	getVector()
boolean	hasDictionary()
boolean	hasNull()
boolean	isNullAt(int i)
int	numNulls()
void	putAllByteArray(byte[] data, int offset, int length) It keeps all binary data of all rows to it.
void	putArray(int rowId, int offset, int length)
void	putBoolean(int rowId, boolean value)
void	putByte(int rowId, byte value)
void	putByteArray(int rowId, byte[] value)
void	putByteArray(int rowId, byte[] value, int offset, int length)
void	putBytes(int rowId, int count, byte[] src, int srcIndex)
void	putDecimal(int rowId, org.apache.spark.sql.types.Decimal value, int precision)
void	putDictionaryInt(int rowId, int value)
void	putDouble(int rowId, double value)
void	putDoubles(int rowId, int count, double value)
void	putDoubles(int rowId, int count, double[] src, int srcIndex)
void	putFloat(int rowId, float value)
void	putFloats(int rowId, int count, float[] src, int srcIndex)
void	putInt(int rowId, int value)
void	putInts(int rowId, int count, int value)
void	putInts(int rowId, int count, int[] src, int srcIndex)
void	putLong(int rowId, long value)
void	putLongs(int rowId, int count, long value)
void	putLongs(int rowId, int count, long[] src, int srcIndex)
void	putNotNull(int rowId)
void	putNotNulls(int rowId, int count)
void	putNull(int rowId)
void	putNulls(int rowId, int count)
void	putRowToColumnBatch(int rowId, Object value)
void	putShort(int rowId, short value)
void	putShorts(int rowId, int count, short value)
void	putShorts(int rowId, int count, short[] src, int srcIndex)
Object	reserveDictionaryIds(int capacity)
void	reset()
void	setDictionary(org.apache.carbondata.core.scan.result.vector.CarbonDictionary dictionary)
void	setLazyPage(org.apache.carbondata.core.scan.scanner.LazyPageLoader lazyPage)

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

ColumnVectorProxy

public ColumnVectorProxy(org.apache.spark.sql.vectorized.ColumnVector columnVector)

Method Detail

putRowToColumnBatch

public void putRowToColumnBatch(int rowId,
                                Object value)

putBoolean

public void putBoolean(int rowId,
                       boolean value)

putByte

public void putByte(int rowId,
                    byte value)

putBytes

public void putBytes(int rowId,
                     int count,
                     byte[] src,
                     int srcIndex)

putShort

public void putShort(int rowId,
                     short value)

putInt

public void putInt(int rowId,
                   int value)

putFloat

public void putFloat(int rowId,
                     float value)

putFloats

public void putFloats(int rowId,
                      int count,
                      float[] src,
                      int srcIndex)

putLong

public void putLong(int rowId,
                    long value)

putDouble

public void putDouble(int rowId,
                      double value)

putByteArray

public void putByteArray(int rowId,
                         byte[] value)

putInts

public void putInts(int rowId,
                    int count,
                    int value)

putInts

public void putInts(int rowId,
                    int count,
                    int[] src,
                    int srcIndex)

putShorts

public void putShorts(int rowId,
                      int count,
                      short value)

putShorts

public void putShorts(int rowId,
                      int count,
                      short[] src,
                      int srcIndex)

putLongs

public void putLongs(int rowId,
                     int count,
                     long value)

putLongs

public void putLongs(int rowId,
                     int count,
                     long[] src,
                     int srcIndex)

putDecimal

public void putDecimal(int rowId,
                       org.apache.spark.sql.types.Decimal value,
                       int precision)

putDoubles

public void putDoubles(int rowId,
                       int count,
                       double value)

putDoubles

public void putDoubles(int rowId,
                       int count,
                       double[] src,
                       int srcIndex)

putByteArray

public void putByteArray(int rowId,
                         byte[] value,
                         int offset,
                         int length)

putNotNull

public void putNotNull(int rowId)

putNotNulls

public void putNotNulls(int rowId,
                        int count)

putDictionaryInt

public void putDictionaryInt(int rowId,
                             int value)

setDictionary

public void setDictionary(org.apache.carbondata.core.scan.result.vector.CarbonDictionary dictionary)

putNull

public void putNull(int rowId)

putNulls

public void putNulls(int rowId,
                     int count)

hasDictionary

public boolean hasDictionary()

reserveDictionaryIds

public Object reserveDictionaryIds(int capacity)

isNullAt

public boolean isNullAt(int i)

Specified by:

isNullAt in class org.apache.spark.sql.vectorized.ColumnVector

getBoolean

public boolean getBoolean(int i)

Specified by:

getBoolean in class org.apache.spark.sql.vectorized.ColumnVector

getByte

public byte getByte(int i)

Specified by:

getByte in class org.apache.spark.sql.vectorized.ColumnVector

getShort

public short getShort(int i)

Specified by:

getShort in class org.apache.spark.sql.vectorized.ColumnVector

getInt

public int getInt(int i)

Specified by:

getInt in class org.apache.spark.sql.vectorized.ColumnVector

getLong

public long getLong(int i)

Specified by:

getLong in class org.apache.spark.sql.vectorized.ColumnVector

getFloat

public float getFloat(int i)

Specified by:

getFloat in class org.apache.spark.sql.vectorized.ColumnVector

getDouble

public double getDouble(int i)

Specified by:

getDouble in class org.apache.spark.sql.vectorized.ColumnVector

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in class org.apache.spark.sql.vectorized.ColumnVector

hasNull

public boolean hasNull()

Specified by:

hasNull in class org.apache.spark.sql.vectorized.ColumnVector

numNulls

public int numNulls()

Specified by:

numNulls in class org.apache.spark.sql.vectorized.ColumnVector

getArray

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

Specified by:

getArray in class org.apache.spark.sql.vectorized.ColumnVector

getMap

public org.apache.spark.sql.vectorized.ColumnarMap getMap(int i)

Specified by:

getMap in class org.apache.spark.sql.vectorized.ColumnVector

getDecimal

public org.apache.spark.sql.types.Decimal getDecimal(int i,
                                                     int i1,
                                                     int i2)

Specified by:

getDecimal in class org.apache.spark.sql.vectorized.ColumnVector

getUTF8String

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

Specified by:

getUTF8String in class org.apache.spark.sql.vectorized.ColumnVector

getBinary

public byte[] getBinary(int i)

Specified by:

getBinary in class org.apache.spark.sql.vectorized.ColumnVector

getChild

protected org.apache.spark.sql.vectorized.ColumnVector getChild(int i)

Specified by:

getChild in class org.apache.spark.sql.vectorized.ColumnVector

reset

public void reset()

setLazyPage

public void setLazyPage(org.apache.carbondata.core.scan.scanner.LazyPageLoader lazyPage)

putAllByteArray

public void putAllByteArray(byte[] data,
                            int offset,
                            int length)

It keeps all binary data of all rows to it. Should use along with @{putArray(int rowId, int offset, int length)} to keep lengths and offset.

putArray

public void putArray(int rowId,
                     int offset,
                     int length)

getVector

public org.apache.spark.sql.execution.vectorized.WritableColumnVector getVector()