org.apache.flink.orc.vector

Class OrcDecimalColumnVector

java.lang.Object

org.apache.flink.orc.vector.AbstractOrcColumnVector

org.apache.flink.orc.vector.OrcDecimalColumnVector

All Implemented Interfaces:

ColumnVector, DecimalColumnVector

public class OrcDecimalColumnVector
extends AbstractOrcColumnVector
implements DecimalColumnVector

This column vector is used to adapt hive's DecimalColumnVector to Flink's DecimalColumnVector.

Constructor Summary

Constructors

Constructor and Description
OrcDecimalColumnVector(org.apache.hadoop.hive.ql.exec.vector.DecimalColumnVector vector)

Method Summary

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

Methods inherited from class org.apache.flink.orc.vector.AbstractOrcColumnVector

createFlinkVector, createFlinkVectorFromConstant, isNullAt

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.data.vector.ColumnVector

isNullAt

Constructor Detail

OrcDecimalColumnVector

public OrcDecimalColumnVector(org.apache.hadoop.hive.ql.exec.vector.DecimalColumnVector vector)

Method Detail

getDecimal

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

Specified by:

getDecimal in interface DecimalColumnVector