C D E G H I N O P R S U V W

C

CarbonDictionaryWrapper - Class in org.apache.spark.sql

CarbonVectorProxy - Class in org.apache.spark.sql

Adapter class which handles the columnar vector reading of the carbondata based on the spark ColumnVector and ColumnarBatch API.

CarbonVectorProxy(MemoryMode, int, StructField[]) - Constructor for class org.apache.spark.sql.CarbonVectorProxy

Adapter class which handles the columnar vector reading of the carbondata based on the spark ColumnVector and ColumnarBatch API.

CarbonVectorProxy(MemoryMode, StructType, int) - Constructor for class org.apache.spark.sql.CarbonVectorProxy

close() - Method in class org.apache.carbondata.spark.vectorreader.VectorizedCarbonRecordReader

close() - Method in class org.apache.spark.sql.CarbonVectorProxy

Called to close all the columns in this batch.

column(int) - Method in class org.apache.spark.sql.CarbonVectorProxy

This API will return a columnvector from a batch of column vector rows based on the ordinal

convertCarbonSchemaToSparkSchema(CarbonColumn[]) - Method in class org.apache.carbondata.converter.SparkDataTypeConverterImpl

convert from CarbonColumn array to Spark's StructField array

convertFromBigDecimalToDecimal(Object) - Method in class org.apache.carbondata.converter.SparkDataTypeConverterImpl

convertFromByteToUTF8Bytes(byte[]) - Method in class org.apache.carbondata.converter.SparkDataTypeConverterImpl

convertFromByteToUTF8String(byte[]) - Method in class org.apache.carbondata.converter.SparkDataTypeConverterImpl

convertFromDecimalToBigDecimal(Object) - Method in class org.apache.carbondata.converter.SparkDataTypeConverterImpl

convertFromStringToByte(Object) - Method in class org.apache.carbondata.converter.SparkDataTypeConverterImpl

convertFromStringToDecimal(Object) - Method in class org.apache.carbondata.converter.SparkDataTypeConverterImpl

convertFromStringToUTF8String(Object) - Method in class org.apache.carbondata.converter.SparkDataTypeConverterImpl

D

dataType(int) - Method in class org.apache.spark.sql.CarbonVectorProxy

decodeToBinary(int) - Method in class org.apache.spark.sql.CarbonDictionaryWrapper

E

enableReturningBatches() - Method in class org.apache.carbondata.spark.vectorreader.VectorizedCarbonRecordReader

G

getColumnarBatch() - Method in class org.apache.spark.sql.CarbonVectorProxy

Returns the row in this batch at `rowId`.

getColumnVector(int) - Method in class org.apache.spark.sql.CarbonVectorProxy

getCurrentKey() - Method in class org.apache.carbondata.spark.vectorreader.VectorizedCarbonRecordReader

getCurrentValue() - Method in class org.apache.carbondata.spark.vectorreader.VectorizedCarbonRecordReader

getMaxId() - Method in class org.apache.spark.sql.CarbonDictionaryWrapper

getProgress() - Method in class org.apache.carbondata.spark.vectorreader.VectorizedCarbonRecordReader

getRow(int) - Method in class org.apache.spark.sql.CarbonVectorProxy

Returns the row in this batch at `rowId`.

H

hasDictionary(int) - Method in class org.apache.spark.sql.CarbonVectorProxy

I

initBatch(MemoryMode, StructType, InternalRow) - Method in class org.apache.carbondata.spark.vectorreader.VectorizedCarbonRecordReader

Returns the ColumnarBatch object that will be used for all rows returned by this reader.

initialize(InputSplit, TaskAttemptContext) - Method in class org.apache.carbondata.spark.vectorreader.VectorizedCarbonRecordReader

Implementation of RecordReader API.

isNullAt(int, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

N

nextKeyValue() - Method in class org.apache.carbondata.spark.vectorreader.VectorizedCarbonRecordReader

numRows() - Method in class org.apache.spark.sql.CarbonVectorProxy

Returns the number of rows for read, including filtered rows.

O

org.apache.carbondata.converter - package org.apache.carbondata.converter

org.apache.carbondata.spark.vectorreader - package org.apache.carbondata.spark.vectorreader

org.apache.spark.sql - package org.apache.spark.sql

P

putBoolean(int, boolean, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

putByte(int, byte, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

putByteArray(int, byte[], int) - Method in class org.apache.spark.sql.CarbonVectorProxy

putByteArray(int, byte[], int, int, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

putDecimal(int, Decimal, int, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

putDictionaryInt(int, int, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

putDouble(int, double, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

putDoubles(int, int, double, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

putFloat(int, float, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

putInt(int, int, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

putInts(int, int, int, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

putLong(int, long, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

putLongs(int, int, long, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

putNotNull(int, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

putNotNulls(int, int, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

putNull(int, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

putNulls(int, int, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

putRowToColumnBatch(int, Object, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

putShort(int, short, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

putShorts(int, int, short, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

R

reserveDictionaryIds(int, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

reset() - Method in class org.apache.spark.sql.CarbonVectorProxy

Resets this column for writing.

resetDictionaryIds(int) - Method in class org.apache.spark.sql.CarbonVectorProxy

S

setDictionary(CarbonDictionary, int) - Method in class org.apache.spark.sql.CarbonVectorProxy

setNumRows(int) - Method in class org.apache.spark.sql.CarbonVectorProxy

Sets the number of rows in this batch.

SparkDataTypeConverterImpl - Class in org.apache.carbondata.converter

Convert java data type to spark data type

SparkDataTypeConverterImpl() - Constructor for class org.apache.carbondata.converter.SparkDataTypeConverterImpl

U

unwrapGenericRowToObject(Object) - Method in class org.apache.carbondata.converter.SparkDataTypeConverterImpl

V

VectorizedCarbonRecordReader - Class in org.apache.carbondata.spark.vectorreader

A specialized RecordReader that reads into InternalRows or ColumnarBatches directly using the carbondata column APIs and fills the data directly into columns.

VectorizedCarbonRecordReader(QueryModel, InputMetricsStats, String) - Constructor for class org.apache.carbondata.spark.vectorreader.VectorizedCarbonRecordReader

W

wrapWithArrayBasedMapData(Object[], Object[]) - Method in class org.apache.carbondata.converter.SparkDataTypeConverterImpl

wrapWithGenericArrayData(Object) - Method in class org.apache.carbondata.converter.SparkDataTypeConverterImpl

wrapWithGenericRow(Object[]) - Method in class org.apache.carbondata.converter.SparkDataTypeConverterImpl

C D E G H I N O P R S U V W