org.apache.paimon.format.parquet.reader

Class FixedLenBytesColumnReader<VECTOR extends WritableColumnVector>

java.lang.Object

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

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

All Implemented Interfaces:

ColumnReader<VECTOR>

Direct Known Subclasses:

FixedLenBytesBinaryColumnReader, FixedLenBytesDecimalColumnReader

public abstract class FixedLenBytesColumnReader<VECTOR extends WritableColumnVector>
extends AbstractColumnReader<VECTOR>

Fixed length bytes ColumnReader, just for Decimal.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	precision

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

descriptor, dictionary, maxDefLevel

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected org.apache.parquet.io.api.Binary	readDataBinary(int len)
protected void	skipDataBinary(int len)

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

afterReadPage, checkTypeName, readBatch, readBatchFromDictionaryIds, readToVector, skipBatch, supportLazyDecode

Methods inherited from class java.lang.Object

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

Field Detail

precision

protected final int precision

Constructor Detail

FixedLenBytesColumnReader

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

Throws:

IOException

Method Detail

skipDataBinary

protected void skipDataBinary(int len)

readDataBinary

protected org.apache.parquet.io.api.Binary readDataBinary(int len)