Package org.apache.flink.orc.vector

Class AbstractOrcColumnVector

java.lang.Object

org.apache.flink.orc.vector.AbstractOrcColumnVector

All Implemented Interfaces:

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

Direct Known Subclasses:

OrcArrayColumnVector, OrcBytesColumnVector, OrcDecimalColumnVector, OrcDoubleColumnVector, OrcLegacyTimestampColumnVector, OrcLongColumnVector, OrcMapColumnVector, OrcRowColumnVector, OrcTimestampColumnVector

public abstract class AbstractOrcColumnVector
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.hadoop.hive.ql.exec.vector.ColumnVector vector, org.apache.flink.table.types.logical.LogicalType logicalType)
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.hadoop.hive.ql.exec.vector.ColumnVector vector,
                                                                                         org.apache.flink.table.types.logical.LogicalType logicalType)

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.