org.apache.flink.orc.vector

Class OrcTimestampColumnVector

java.lang.Object

org.apache.flink.orc.vector.AbstractOrcColumnVector

org.apache.flink.orc.vector.OrcTimestampColumnVector

All Implemented Interfaces:

ColumnVector, TimestampColumnVector

public class OrcTimestampColumnVector
extends AbstractOrcColumnVector
implements TimestampColumnVector

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

Constructor Summary

Constructors

Constructor and Description
OrcTimestampColumnVector(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector)

Method Summary

Modifier and Type	Method and Description
static org.apache.hadoop.hive.ql.exec.vector.ColumnVector	createFromConstant(int batchSize, Object value)
TimestampData	getTimestamp(int i, int precision)

Methods inherited from class org.apache.flink.orc.vector.AbstractOrcColumnVector

createFlinkVector, createFlinkVectorFromConstant, isNullAt

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.data.vector.ColumnVector

isNullAt

Constructor Detail

OrcTimestampColumnVector

public OrcTimestampColumnVector(org.apache.hadoop.hive.ql.exec.vector.ColumnVector vector)

Method Detail

getTimestamp

public TimestampData getTimestamp(int i,
                                  int precision)

Specified by:

getTimestamp in interface TimestampColumnVector

createFromConstant

public static org.apache.hadoop.hive.ql.exec.vector.ColumnVector createFromConstant(int batchSize,
                                                                                    Object value)