Package org.apache.flink.formats.parquet.vector.reader

Class ShortColumnReader

java.lang.Object

org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader<org.apache.flink.table.data.columnar.vector.writable.WritableShortVector>

org.apache.flink.formats.parquet.vector.reader.ShortColumnReader

All Implemented Interfaces:

ColumnReader<org.apache.flink.table.data.columnar.vector.writable.WritableShortVector>

public class ShortColumnReader
extends AbstractColumnReader<org.apache.flink.table.data.columnar.vector.writable.WritableShortVector>

Short ColumnReader. Using INT32 to store short, so just cast int to short.

Field Summary

Fields inherited from class org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader

descriptor, dictionary, maxDefLevel, runLenDecoder

Constructor Summary

Constructors

Constructor	Description
ShortColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor, org.apache.parquet.column.page.PageReader pageReader)

Method Summary

Modifier and Type	Method	Description
protected void	readBatch(int rowId, int num, org.apache.flink.table.data.columnar.vector.writable.WritableShortVector column)	Read batch from AbstractColumnReader.runLenDecoder and AbstractColumnReader.dataInputStream.
protected void	readBatchFromDictionaryIds(int rowId, int num, org.apache.flink.table.data.columnar.vector.writable.WritableShortVector column, org.apache.flink.table.data.columnar.vector.writable.WritableIntVector dictionaryIds)	Decode dictionary ids to data.

Methods inherited from class org.apache.flink.formats.parquet.vector.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

ShortColumnReader

public ShortColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor,
                         org.apache.parquet.column.page.PageReader pageReader)
                  throws IOException

Throws:

IOException

Method Detail

readBatch

protected void readBatch(int rowId,
                         int num,
                         org.apache.flink.table.data.columnar.vector.writable.WritableShortVector column)

Description copied from class: AbstractColumnReader

Read batch from AbstractColumnReader.runLenDecoder and AbstractColumnReader.dataInputStream.

Specified by:

readBatch in class AbstractColumnReader<org.apache.flink.table.data.columnar.vector.writable.WritableShortVector>

readBatchFromDictionaryIds

protected void readBatchFromDictionaryIds(int rowId,
                                          int num,
                                          org.apache.flink.table.data.columnar.vector.writable.WritableShortVector column,
                                          org.apache.flink.table.data.columnar.vector.writable.WritableIntVector dictionaryIds)

Description copied from class: AbstractColumnReader

Decode dictionary ids to data. From AbstractColumnReader.runLenDecoder and AbstractColumnReader.dictionaryIdsDecoder.

Specified by:

readBatchFromDictionaryIds in class AbstractColumnReader<org.apache.flink.table.data.columnar.vector.writable.WritableShortVector>