public class BooleanColumnReader extends AbstractColumnReader<WritableBooleanVector>
ColumnReader
.descriptor, dictionary, maxDefLevel, runLenDecoder
Constructor and Description |
---|
BooleanColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor,
org.apache.parquet.column.page.PageReader pageReader) |
Modifier and Type | Method and 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.
|
checkTypeName, readToVector
public BooleanColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor, org.apache.parquet.column.page.PageReader pageReader) throws IOException
IOException
protected boolean supportLazyDecode()
AbstractColumnReader
ParquetDictionary
. If return false,
we will decode all the data first.supportLazyDecode
in class AbstractColumnReader<WritableBooleanVector>
protected void afterReadPage()
AbstractColumnReader
afterReadPage
in class AbstractColumnReader<WritableBooleanVector>
protected void readBatchFromDictionaryIds(int rowId, int num, WritableBooleanVector column, WritableIntVector dictionaryIds)
AbstractColumnReader
AbstractColumnReader.runLenDecoder
and AbstractColumnReader.dictionaryIdsDecoder
.readBatchFromDictionaryIds
in class AbstractColumnReader<WritableBooleanVector>
protected void readBatch(int rowId, int num, WritableBooleanVector column)
AbstractColumnReader
AbstractColumnReader.runLenDecoder
and AbstractColumnReader.dataInputStream
.readBatch
in class AbstractColumnReader<WritableBooleanVector>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.