public class VectorizedPrimitiveColumnReader extends Object implements VectorizedColumnReader
Modifier and Type | Class and Description |
---|---|
protected static class |
VectorizedPrimitiveColumnReader.NullIntIterator |
protected static class |
VectorizedPrimitiveColumnReader.RLEIntIterator |
protected static class |
VectorizedPrimitiveColumnReader.ValuesReaderIntIterator |
Constructor and Description |
---|
VectorizedPrimitiveColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor,
org.apache.parquet.column.page.PageReader pageReader,
boolean skipTimestampConversion,
org.apache.parquet.schema.Type type) |
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
|
public VectorizedPrimitiveColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor, org.apache.parquet.column.page.PageReader pageReader, boolean skipTimestampConversion, org.apache.parquet.schema.Type type) throws IOException
IOException
public void readBatch(int total, org.apache.hadoop.hive.ql.exec.vector.ColumnVector column, TypeInfo columnType) throws IOException
VectorizedColumnReader
readBatch
in interface 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 © 2021 The Apache Software Foundation. All rights reserved.