public class VectorizedPrimitiveColumnReader extends BaseVectorizedColumnReader
BaseVectorizedColumnReader.NullIntIterator, BaseVectorizedColumnReader.RLEIntIterator, BaseVectorizedColumnReader.ValuesReaderIntIterator
dataColumn, definitionLevel, definitionLevelColumn, descriptor, dictionary, endOfPageValueCount, hiveType, isCurrentPageDictionaryEncoded, maxDefLevel, pageReader, pageValueCount, repetitionLevel, repetitionLevelColumn, skipTimestampConversion, type, valuesRead, writerTimezone
Constructor and Description |
---|
VectorizedPrimitiveColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor,
org.apache.parquet.column.page.PageReader pageReader,
boolean skipTimestampConversion,
ZoneId writerTimezone,
org.apache.parquet.schema.Type type,
TypeInfo hiveType) |
Modifier and Type | Method and Description |
---|---|
void |
readBatch(int total,
org.apache.hadoop.hive.ql.exec.vector.ColumnVector column,
TypeInfo columnType)
read records with specified size and type into the columnVector
|
decimalTypeCheck, readPage, readRepetitionAndDefinitionLevels
public VectorizedPrimitiveColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor, org.apache.parquet.column.page.PageReader pageReader, boolean skipTimestampConversion, ZoneId writerTimezone, org.apache.parquet.schema.Type type, TypeInfo hiveType) throws IOException
IOException
public void readBatch(int total, org.apache.hadoop.hive.ql.exec.vector.ColumnVector column, TypeInfo columnType) throws IOException
VectorizedColumnReader
total
- number of records to read into the column vectorcolumn
- column vector where the reader will read data intocolumnType
- the type of column vectorIOException
Copyright © 2022 The Apache Software Foundation. All rights reserved.