Package org.apache.flink.orc.nohive.shim

Class OrcNoHiveShim

java.lang.Object

org.apache.flink.orc.nohive.shim.OrcNoHiveShim

All Implemented Interfaces:

Serializable, org.apache.flink.orc.shim.OrcShim<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch>

public class OrcNoHiveShim
extends Object
implements org.apache.flink.orc.shim.OrcShim<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch>

Shim for orc reader without hive dependents.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
OrcNoHiveShim()

Method Summary

Modifier and Type	Method	Description
OrcNoHiveBatchWrapper	createBatchWrapper(org.apache.orc.TypeDescription schema, int batchSize)
org.apache.orc.RecordReader	createRecordReader(org.apache.hadoop.conf.Configuration conf, org.apache.orc.TypeDescription schema, int[] selectedFields, List<org.apache.flink.orc.OrcFilters.Predicate> conjunctPredicates, org.apache.flink.core.fs.Path path, long splitStart, long splitLength)
boolean	nextBatch(org.apache.orc.RecordReader reader, org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch rowBatch)

Methods inherited from class java.lang.Object

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

Constructor Detail

OrcNoHiveShim

public OrcNoHiveShim()

Method Detail

createRecordReader

public org.apache.orc.RecordReader createRecordReader(org.apache.hadoop.conf.Configuration conf,
                                                      org.apache.orc.TypeDescription schema,
                                                      int[] selectedFields,
                                                      List<org.apache.flink.orc.OrcFilters.Predicate> conjunctPredicates,
                                                      org.apache.flink.core.fs.Path path,
                                                      long splitStart,
                                                      long splitLength)
                                               throws IOException

Specified by:

createRecordReader in interface org.apache.flink.orc.shim.OrcShim<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch>

Throws:

IOException

createBatchWrapper

public OrcNoHiveBatchWrapper createBatchWrapper(org.apache.orc.TypeDescription schema,
                                                int batchSize)

Specified by:

createBatchWrapper in interface org.apache.flink.orc.shim.OrcShim<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch>

nextBatch

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

Specified by:

nextBatch in interface org.apache.flink.orc.shim.OrcShim<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch>

Throws:

IOException