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

Class OrcNoHiveShim

java.lang.Object

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

All Implemented Interfaces:

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

public class OrcNoHiveShim
extends Object
implements 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<OrcFilters.Predicate> conjunctPredicates, Path path, long splitStart, long splitLength)	Create orc RecordReader from conf, schema and etc...
boolean	nextBatch(org.apache.orc.RecordReader reader, org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch rowBatch)	Read the next row batch.

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<OrcFilters.Predicate> conjunctPredicates,
                                                      Path path,
                                                      long splitStart,
                                                      long splitLength)
                                               throws IOException

Description copied from interface: OrcShim

Create orc RecordReader from conf, schema and etc...

Specified by:

createRecordReader in interface 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 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

Description copied from interface: OrcShim

Read the next row batch.

Specified by:

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

Throws:

IOException