org.apache.flink.orc.vector

Class AbstractOrcColumnVector

java.lang.Object

org.apache.flink.orc.vector.AbstractOrcColumnVector

All Implemented Interfaces:

ColumnVector

Direct Known Subclasses:

OrcBytesColumnVector, OrcDecimalColumnVector, OrcDoubleColumnVector, OrcLegacyTimestampColumnVector, OrcLongColumnVector, OrcTimestampColumnVector

public abstract class AbstractOrcColumnVector
extends Object
implements ColumnVector

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

Method Summary

Modifier and Type	Method and Description
static ColumnVector	createFlinkVector(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector, LogicalType logicalType)
static ColumnVector	createFlinkVectorFromConstant(LogicalType type, Object value, int batchSize) Create flink vector by hive vector from constant.
boolean	isNullAt(int i)

Methods inherited from class java.lang.Object

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

Method Detail

isNullAt

public boolean isNullAt(int i)

Specified by:

isNullAt in interface ColumnVector

createFlinkVector

public static ColumnVector createFlinkVector(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector,
                                             LogicalType logicalType)

createFlinkVectorFromConstant

public static ColumnVector createFlinkVectorFromConstant(LogicalType type,
                                                         Object value,
                                                         int batchSize)

Create flink vector by hive vector from constant.