Package org.apache.flink.formats.parquet.vector.reader

Class BytesColumnReader

java.lang.Object

org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader<WritableBytesVector>

org.apache.flink.formats.parquet.vector.reader.BytesColumnReader

All Implemented Interfaces:

ColumnReader<WritableBytesVector>

public class BytesColumnReader
extends AbstractColumnReader<WritableBytesVector>

Bytes ColumnReader. A int length and bytes data.

Field Summary

Fields inherited from class org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader

descriptor, dictionary, maxDefLevel, runLenDecoder

Constructor Summary

Constructors

Constructor	Description
BytesColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor, org.apache.parquet.column.page.PageReader pageReader)

Method Summary

Modifier and Type	Method	Description
protected void	readBatch(int rowId, int num, WritableBytesVector column)	Read batch from AbstractColumnReader.runLenDecoder and AbstractColumnReader.dataInputStream.
protected void	readBatchFromDictionaryIds(int rowId, int num, WritableBytesVector column, WritableIntVector dictionaryIds)	Decode dictionary ids to data.

Methods inherited from class org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader

afterReadPage, checkTypeName, readToVector, supportLazyDecode

Methods inherited from class java.lang.Object

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

Constructor Detail

BytesColumnReader

public BytesColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor,
                         org.apache.parquet.column.page.PageReader pageReader)
                  throws IOException

Throws:

IOException

Method Detail

readBatch

protected void readBatch(int rowId,
                         int num,
                         WritableBytesVector column)

Description copied from class: AbstractColumnReader

Read batch from AbstractColumnReader.runLenDecoder and AbstractColumnReader.dataInputStream.

Specified by:

readBatch in class AbstractColumnReader<WritableBytesVector>

readBatchFromDictionaryIds

protected void readBatchFromDictionaryIds(int rowId,
                                          int num,
                                          WritableBytesVector column,
                                          WritableIntVector dictionaryIds)

Description copied from class: AbstractColumnReader

Decode dictionary ids to data. From AbstractColumnReader.runLenDecoder and AbstractColumnReader.dictionaryIdsDecoder.

Specified by:

readBatchFromDictionaryIds in class AbstractColumnReader<WritableBytesVector>