Package org.apache.flink.orc.nohive.vector

Class AbstractOrcNoHiveVector

java.lang.Object

org.apache.flink.orc.nohive.vector.AbstractOrcNoHiveVector

All Implemented Interfaces:

ColumnVector

Direct Known Subclasses:

OrcNoHiveBytesVector, OrcNoHiveDecimalVector, OrcNoHiveDoubleVector, OrcNoHiveLongVector, OrcNoHiveTimestampVector

public abstract class AbstractOrcNoHiveVector
extends Object
implements ColumnVector

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

Method Summary

Modifier and Type	Method	Description
static ColumnVector	createFlinkVector(org.apache.orc.storage.ql.exec.vector.ColumnVector vector)
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.orc.storage.ql.exec.vector.ColumnVector vector)

createFlinkVectorFromConstant

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

Create flink vector by hive vector from constant.