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

Class BooleanColumnReader

java.lang.Object

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

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

All Implemented Interfaces:

ColumnReader<WritableBooleanVector>

public class BooleanColumnReader
extends AbstractColumnReader<WritableBooleanVector>

Boolean ColumnReader.

Field Summary

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

descriptor, dictionary, maxDefLevel, runLenDecoder

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected void	afterReadPage()	After read a page, we may need some initialization.
protected void	readBatch(int rowId, int num, WritableBooleanVector column)	Read batch from AbstractColumnReader.runLenDecoder and AbstractColumnReader.dataInputStream.
protected void	readBatchFromDictionaryIds(int rowId, int num, WritableBooleanVector column, WritableIntVector dictionaryIds)	Decode dictionary ids to data.
protected boolean	supportLazyDecode()	Support lazy dictionary ids decode.

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

checkTypeName, readToVector

Methods inherited from class java.lang.Object

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

Constructor Detail

BooleanColumnReader

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

Throws:

IOException

Method Detail

supportLazyDecode

protected boolean supportLazyDecode()

Description copied from class: AbstractColumnReader

Support lazy dictionary ids decode. See more in ParquetDictionary. If return false, we will decode all the data first.

Overrides:

supportLazyDecode in class AbstractColumnReader<WritableBooleanVector>

afterReadPage

protected void afterReadPage()

Description copied from class: AbstractColumnReader

After read a page, we may need some initialization.

Overrides:

afterReadPage in class AbstractColumnReader<WritableBooleanVector>

readBatchFromDictionaryIds

protected void readBatchFromDictionaryIds(int rowId,
                                          int num,
                                          WritableBooleanVector 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<WritableBooleanVector>

readBatch

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

Description copied from class: AbstractColumnReader

Read batch from AbstractColumnReader.runLenDecoder and AbstractColumnReader.dataInputStream.

Specified by:

readBatch in class AbstractColumnReader<WritableBooleanVector>