Package org.apache.flink.table.runtime.arrow.vectors

Class ArrowDecimalColumnVector

java.lang.Object

org.apache.flink.table.runtime.arrow.vectors.ArrowDecimalColumnVector

All Implemented Interfaces:

org.apache.flink.table.data.columnar.vector.ColumnVector, org.apache.flink.table.data.columnar.vector.DecimalColumnVector

@Internal
public final class ArrowDecimalColumnVector
extends Object
implements org.apache.flink.table.data.columnar.vector.DecimalColumnVector

Arrow column vector for DecimalData.

Constructor Summary

Constructors

Constructor	Description
ArrowDecimalColumnVector(org.apache.arrow.vector.DecimalVector decimalVector)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.table.data.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

Constructor Detail

ArrowDecimalColumnVector

public ArrowDecimalColumnVector(org.apache.arrow.vector.DecimalVector decimalVector)

Method Detail

getDecimal

public org.apache.flink.table.data.DecimalData getDecimal(int i,
                                                          int precision,
                                                          int scale)

Specified by:

getDecimal in interface org.apache.flink.table.data.columnar.vector.DecimalColumnVector

isNullAt

public boolean isNullAt(int i)

Specified by:

isNullAt in interface org.apache.flink.table.data.columnar.vector.ColumnVector