Package org.apache.flink.orc.shim

Class OrcShimV230

java.lang.Object

org.apache.flink.orc.shim.OrcShimV200

org.apache.flink.orc.shim.OrcShimV210

org.apache.flink.orc.shim.OrcShimV230

All Implemented Interfaces:

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

public class OrcShimV230
extends OrcShimV210

Shim orc for Hive version 2.1.0 and upper versions.

After hive 2.3 and later, the orc API is basically stable, so we can call it directly.

Since hive 2.2 not include orc classes, so we can use hive orc 2.3 to read from hive 2.2.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
OrcShimV230()

Method Summary

Modifier and Type	Method	Description
protected org.apache.orc.Reader	createReader(org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration conf)
protected org.apache.orc.RecordReader	createRecordReader(org.apache.orc.Reader reader, org.apache.orc.Reader.Options options)
protected org.apache.orc.Reader.Options	readOrcConf(org.apache.orc.Reader.Options options, org.apache.hadoop.conf.Configuration conf)

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

nextBatch

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

computeProjectionMask, createBatchWrapper, createRecordReader, getOffsetAndLengthForSplit

Methods inherited from class java.lang.Object

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

Constructor Detail

OrcShimV230

public OrcShimV230()

Method Detail

createReader

protected org.apache.orc.Reader createReader(org.apache.hadoop.fs.Path path,
                                             org.apache.hadoop.conf.Configuration conf)
                                      throws IOException

Overrides:

createReader in class OrcShimV200

Throws:

IOException

createRecordReader

protected org.apache.orc.RecordReader createRecordReader(org.apache.orc.Reader reader,
                                                         org.apache.orc.Reader.Options options)
                                                  throws IOException

Overrides:

createRecordReader in class OrcShimV200

Throws:

IOException

readOrcConf

protected org.apache.orc.Reader.Options readOrcConf(org.apache.orc.Reader.Options options,
                                                    org.apache.hadoop.conf.Configuration conf)

Overrides:

readOrcConf in class OrcShimV200