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

Class AbstractOrcNoHiveVector

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

OrcNoHiveBytesVector, OrcNoHiveDecimalVector, OrcNoHiveDoubleVector, OrcNoHiveLongVector, OrcNoHiveTimestampVector

public abstract class AbstractOrcNoHiveVector
extends Object
implements org.apache.flink.table.data.columnar.vector.ColumnVector

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

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.table.data.columnar.vector.ColumnVector	createFlinkVector(org.apache.orc.storage.ql.exec.vector.ColumnVector vector)
static org.apache.flink.table.data.columnar.vector.ColumnVector	createFlinkVectorFromConstant(org.apache.flink.table.types.logical.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 org.apache.flink.table.data.columnar.vector.ColumnVector

createFlinkVector

public static org.apache.flink.table.data.columnar.vector.ColumnVector createFlinkVector(org.apache.orc.storage.ql.exec.vector.ColumnVector vector)

createFlinkVectorFromConstant

public static org.apache.flink.table.data.columnar.vector.ColumnVector createFlinkVectorFromConstant(org.apache.flink.table.types.logical.LogicalType type,
                                                                                                     Object value,
                                                                                                     int batchSize)

Create flink vector by hive vector from constant.