org.apache.paimon.format.parquet.reader

Class FixedLenBytesBinaryColumnReader<VECTOR extends WritableColumnVector>

java.lang.Object

org.apache.paimon.format.parquet.reader.AbstractColumnReader<VECTOR>

org.apache.paimon.format.parquet.reader.FixedLenBytesColumnReader<VECTOR>

org.apache.paimon.format.parquet.reader.FixedLenBytesBinaryColumnReader<VECTOR>

All Implemented Interfaces:

ColumnReader<VECTOR>

public class FixedLenBytesBinaryColumnReader<VECTOR extends WritableColumnVector>
extends FixedLenBytesColumnReader<VECTOR>

Fixed length bytes ColumnReader, just for Binary.

Field Summary

Fields inherited from class org.apache.paimon.format.parquet.reader.FixedLenBytesColumnReader

precision

Fields inherited from class org.apache.paimon.format.parquet.reader.AbstractColumnReader

descriptor, dictionary, maxDefLevel

Constructor Summary

Constructors

Constructor and Description
FixedLenBytesBinaryColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor, org.apache.parquet.column.page.PageReadStore pageReadStore, int precision)

Method Summary

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

Methods inherited from class org.apache.paimon.format.parquet.reader.FixedLenBytesColumnReader

readDataBinary, skipDataBinary

Methods inherited from class org.apache.paimon.format.parquet.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

FixedLenBytesBinaryColumnReader

public FixedLenBytesBinaryColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor,
                                       org.apache.parquet.column.page.PageReadStore pageReadStore,
                                       int precision)
                                throws IOException

Throws:

IOException

Method Detail

readBatch

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

Description copied from class: AbstractColumnReader

Read batch from AbstractColumnReader.runLenDecoder and AbstractColumnReader.dataInputStream.

Specified by:

readBatch in class AbstractColumnReader<VECTOR extends WritableColumnVector>

skipBatch

protected void skipBatch(int num)

Specified by:

skipBatch in class AbstractColumnReader<VECTOR extends WritableColumnVector>

readBatchFromDictionaryIds

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