org.apache.hadoop.hive.ql.io.parquet.vector

Class VectorizedMapColumnReader

java.lang.Object

org.apache.hadoop.hive.ql.io.parquet.vector.VectorizedMapColumnReader

All Implemented Interfaces:

VectorizedColumnReader

public class VectorizedMapColumnReader
extends Object
implements VectorizedColumnReader

It's column level Parquet reader which is used to read a batch of records for a map column.

Constructor Summary

Constructors

Constructor and Description
VectorizedMapColumnReader(VectorizedListColumnReader keyColumnReader, VectorizedListColumnReader valueColumnReader)

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

VectorizedMapColumnReader

public VectorizedMapColumnReader(VectorizedListColumnReader keyColumnReader,
                                 VectorizedListColumnReader valueColumnReader)

Method Detail

readBatch

public void readBatch(int total,
                      org.apache.hadoop.hive.ql.exec.vector.ColumnVector column,
                      TypeInfo columnType)
               throws IOException

Description copied from interface: VectorizedColumnReader

read records with specified size and type into the columnVector

Specified by:

readBatch in interface VectorizedColumnReader

Parameters:

total - number of records to read into the column vector

column - column vector where the reader will read data into

columnType - the type of column vector

Throws:

IOException