org.apache.flink.orc.shim

Class OrcShimV210

java.lang.Object

org.apache.flink.orc.shim.OrcShimV200

org.apache.flink.orc.shim.OrcShimV210

All Implemented Interfaces:

Serializable, OrcShim<org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>

Direct Known Subclasses:

OrcShimV230

public class OrcShimV210
extends OrcShimV200

Shim orc for Hive version 2.1.0 and upper versions.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
OrcShimV210()

Method Summary

Modifier and Type	Method and Description
boolean	nextBatch(org.apache.orc.RecordReader reader, org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch rowBatch) Read the next row batch.

Methods inherited from class org.apache.flink.orc.shim.OrcShimV200

computeProjectionMask, createBatchWrapper, createReader, createRecordReader, createRecordReader, getOffsetAndLengthForSplit, readOrcConf

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.orc.shim.OrcShim

createShim, defaultShim

Constructor Detail

OrcShimV210

public OrcShimV210()

Method Detail

nextBatch

public boolean nextBatch(org.apache.orc.RecordReader reader,
                         org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch rowBatch)
                  throws IOException

Description copied from interface: OrcShim

Read the next row batch.

Specified by:

nextBatch in interface OrcShim<org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>

Overrides:

nextBatch in class OrcShimV200

Throws:

IOException