public class OrcShimV200 extends Object implements OrcShim
Constructor and Description |
---|
OrcShimV200() |
Modifier and Type | Method and Description |
---|---|
protected org.apache.orc.Reader |
createReader(org.apache.hadoop.fs.Path path,
Configuration conf) |
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... |
protected org.apache.orc.RecordReader |
createRecordReader(org.apache.orc.Reader reader,
org.apache.orc.Reader.Options options) |
static Tuple2<Long,Long> |
getOffsetAndLengthForSplit(long splitStart,
long splitLength,
List<org.apache.orc.StripeInformation> stripes) |
boolean |
nextBatch(org.apache.orc.RecordReader reader,
org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch rowBatch)
Read the next row batch.
|
protected org.apache.orc.Reader.Options |
readOrcConf(org.apache.orc.Reader.Options options,
Configuration conf) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createShim, defaultShim
protected org.apache.orc.Reader createReader(org.apache.hadoop.fs.Path path, Configuration conf) throws IOException
IOException
protected org.apache.orc.RecordReader createRecordReader(org.apache.orc.Reader reader, org.apache.orc.Reader.Options options) throws IOException
IOException
protected org.apache.orc.Reader.Options readOrcConf(org.apache.orc.Reader.Options options, Configuration conf)
public 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
OrcShim
RecordReader
from conf, schema and etc...createRecordReader
in interface OrcShim
IOException
public boolean nextBatch(org.apache.orc.RecordReader reader, org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch rowBatch) throws IOException
OrcShim
nextBatch
in interface OrcShim
IOException
@VisibleForTesting public static Tuple2<Long,Long> getOffsetAndLengthForSplit(long splitStart, long splitLength, List<org.apache.orc.StripeInformation> stripes)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.