org.apache.flink.formats.parquet.vector

Class ParquetDecimalVector

java.lang.Object

org.apache.flink.formats.parquet.vector.ParquetDecimalVector

All Implemented Interfaces:

ColumnVector, DecimalColumnVector

public class ParquetDecimalVector
extends Object
implements DecimalColumnVector

Parquet write decimal as int32 and int64 and binary, this class wrap the real vector to provide DecimalColumnVector interface.

Method Summary

Modifier and Type	Method and Description
DecimalData	getDecimal(int i, int precision, int scale)
boolean	isNullAt(int i)

Methods inherited from class java.lang.Object

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

Method Detail

getDecimal

public DecimalData getDecimal(int i,
                              int precision,
                              int scale)

Specified by:

getDecimal in interface DecimalColumnVector

isNullAt

public boolean isNullAt(int i)

Specified by:

isNullAt in interface ColumnVector