public abstract class BaseVectorizedColumnReader extends Object implements ColumnReader<WritableColumnVector>
Modifier and Type | Class and Description |
---|---|
protected static class |
BaseVectorizedColumnReader.NullIntIterator
Reading zero always.
|
protected static class |
BaseVectorizedColumnReader.RLEIntIterator
Reading int from
RunLengthBitPackingHybridDecoder . |
protected static class |
BaseVectorizedColumnReader.ValuesReaderIntIterator
Reading int from
ValuesReader . |
Modifier and Type | Field and Description |
---|---|
protected ParquetDataColumnReader |
dataColumn |
protected int |
definitionLevel |
protected org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader.IntIterator |
definitionLevelColumn |
protected org.apache.parquet.column.ColumnDescriptor |
descriptor |
protected ParquetDataColumnReader |
dictionary
The dictionary, if this column has dictionary encoding.
|
protected long |
endOfPageValueCount
value that indicates the end of the current page.
|
protected boolean |
isCurrentPageDictionaryEncoded
If true, the current page is dictionary encoded.
|
protected boolean |
isUtcTimestamp |
protected LogicalType |
logicalType |
protected int |
maxDefLevel
Maximum definition level for this column.
|
protected org.apache.parquet.column.page.PageReader |
pageReader |
protected int |
pageValueCount
Total values in the current page.
|
protected int |
repetitionLevel |
protected org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader.IntIterator |
repetitionLevelColumn
Repetition/Definition/Value readers.
|
protected org.apache.parquet.schema.Type |
type |
protected long |
valuesRead
Total number of values read.
|
Constructor and Description |
---|
BaseVectorizedColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor,
org.apache.parquet.column.page.PageReader pageReader,
boolean isUtcTimestamp,
org.apache.parquet.schema.Type parquetType,
LogicalType logicalType) |
Modifier and Type | Method and Description |
---|---|
protected void |
readPage() |
protected void |
readRepetitionAndDefinitionLevels() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
readToVector
protected boolean isUtcTimestamp
protected long valuesRead
protected long endOfPageValueCount
protected final ParquetDataColumnReader dictionary
protected boolean isCurrentPageDictionaryEncoded
protected final int maxDefLevel
protected int definitionLevel
protected int repetitionLevel
protected org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader.IntIterator repetitionLevelColumn
protected org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader.IntIterator definitionLevelColumn
protected ParquetDataColumnReader dataColumn
protected int pageValueCount
protected final org.apache.parquet.column.page.PageReader pageReader
protected final org.apache.parquet.column.ColumnDescriptor descriptor
protected final org.apache.parquet.schema.Type type
protected final LogicalType logicalType
public BaseVectorizedColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor, org.apache.parquet.column.page.PageReader pageReader, boolean isUtcTimestamp, org.apache.parquet.schema.Type parquetType, LogicalType logicalType) throws IOException
IOException
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.