org.apache.flink.formats.parquet.vector

Class ParquetDecimalVector

java.lang.Object

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

All Implemented Interfaces:

ColumnVector, DecimalColumnVector

@Internal
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.

Constructor Summary

Constructors

Constructor and Description
ParquetDecimalVector(ColumnVector vector)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ParquetDecimalVector

public ParquetDecimalVector(ColumnVector vector)

Method Detail

getDecimal

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

Specified by:

getDecimal in interface DecimalColumnVector

getVector

public ColumnVector getVector()

isNullAt

public boolean isNullAt(int i)

Specified by:

isNullAt in interface ColumnVector