public interface OrcShim extends Serializable
Modifier and Type | Method and Description |
---|---|
org.apache.orc.RecordReader |
createRecordReader(Configuration conf,
org.apache.orc.TypeDescription schema,
int[] selectedFields,
List<OrcSplitReader.Predicate> conjunctPredicates,
Path path,
long splitStart,
long splitLength)
Create orc
RecordReader from conf, schema and etc... |
static OrcShim |
createShim(String hiveVersion)
Create shim from hive version.
|
static OrcShim |
defaultShim()
Default with orc dependent, we should use v2.3.0.
|
boolean |
nextBatch(org.apache.orc.RecordReader reader,
org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch rowBatch)
Read the next row batch.
|
org.apache.orc.RecordReader createRecordReader(Configuration conf, org.apache.orc.TypeDescription schema, int[] selectedFields, List<OrcSplitReader.Predicate> conjunctPredicates, Path path, long splitStart, long splitLength) throws IOException
RecordReader
from conf, schema and etc...IOException
boolean nextBatch(org.apache.orc.RecordReader reader, org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch rowBatch) throws IOException
IOException
static OrcShim defaultShim()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.