public class VectorizedListColumnReader extends BaseVectorizedColumnReader
BaseVectorizedColumnReader.NullIntIterator, BaseVectorizedColumnReader.RLEIntIterator, BaseVectorizedColumnReader.ValuesReaderIntIterator
dataColumn, definitionLevel, definitionLevelColumn, descriptor, dictionary, endOfPageValueCount, hiveType, isCurrentPageDictionaryEncoded, legacyConversionEnabled, maxDefLevel, pageReader, pageValueCount, repetitionLevel, repetitionLevelColumn, skipProlepticConversion, skipTimestampConversion, type, valuesRead, writerTimezone
Constructor and Description |
---|
VectorizedListColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor,
org.apache.parquet.column.page.PageReader pageReader,
boolean skipTimestampConversion,
ZoneId writerTimezone,
boolean skipProlepticConversion,
boolean legacyConversionEnabled,
org.apache.parquet.schema.Type type,
TypeInfo hiveType) |
Modifier and Type | Method and Description |
---|---|
void |
readBatch(int total,
ColumnVector column,
TypeInfo columnType)
read records with specified size and type into the columnVector
|
decimalTypeCheck, readPage, readRepetitionAndDefinitionLevels
public VectorizedListColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor, org.apache.parquet.column.page.PageReader pageReader, boolean skipTimestampConversion, ZoneId writerTimezone, boolean skipProlepticConversion, boolean legacyConversionEnabled, org.apache.parquet.schema.Type type, TypeInfo hiveType) throws IOException
IOException
public void readBatch(int total, 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.