Package | Description |
---|---|
org.apache.paimon.format.parquet.newreader |
Modifier and Type | Method and Description |
---|---|
void |
VectorizedRleValuesReader.readBatch(ParquetReadState state,
WritableColumnVector values,
WritableIntVector defLevels,
VectorizedValuesReader valueReader,
ParquetVectorUpdater updater)
Reads a batch of definition levels and values into vector 'defLevels' and 'values'
respectively.
|
void |
VectorizedRleValuesReader.readBatchRepeated(ParquetReadState state,
WritableIntVector repLevels,
VectorizedRleValuesReader defLevelsReader,
WritableIntVector defLevels,
WritableColumnVector values,
VectorizedValuesReader valueReader,
ParquetVectorUpdater updater)
Reads a batch of repetition levels, definition levels and values into 'repLevels',
'defLevels' and 'values' respectively.
|
void |
VectorizedRleValuesReader.readBatchRepeatedInternal(ParquetReadState state,
WritableIntVector repLevels,
VectorizedRleValuesReader defLevelsReader,
WritableIntVector defLevels,
WritableColumnVector values,
WritableColumnVector nulls,
boolean valuesReused,
VectorizedValuesReader valueReader,
ParquetVectorUpdater updater)
Keep reading repetition level values from the page until either: 1) we've read enough
top-level rows to fill the current batch, or 2) we've drained the data page completely.
|
void |
VectorizedRleValuesReader.readIntegers(ParquetReadState state,
WritableColumnVector values,
WritableColumnVector nulls,
WritableIntVector defLevels,
VectorizedValuesReader valueReader)
Decoding for dictionary ids.
|
void |
VectorizedRleValuesReader.readIntegersRepeated(ParquetReadState state,
WritableIntVector repLevels,
VectorizedRleValuesReader defLevelsReader,
WritableIntVector defLevels,
WritableColumnVector values,
WritableColumnVector nulls,
VectorizedValuesReader valueReader)
Reads a batch of repetition levels, definition levels and integer values into 'repLevels',
'defLevels', 'values' and 'nulls' respectively.
|
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.