public abstract class OrcSplitReader<T> extends Object implements Closeable
Modifier and Type | Class and Description |
---|---|
static class |
OrcSplitReader.Between
An BETWEEN predicate that can be evaluated by the OrcInputFormat.
|
static class |
OrcSplitReader.Equals
An EQUALS predicate that can be evaluated by the OrcInputFormat.
|
static class |
OrcSplitReader.In
An IN predicate that can be evaluated by the OrcInputFormat.
|
static class |
OrcSplitReader.IsNull
An IS_NULL predicate that can be evaluated by the OrcInputFormat.
|
static class |
OrcSplitReader.LessThan
A LESS_THAN predicate that can be evaluated by the OrcInputFormat.
|
static class |
OrcSplitReader.LessThanEquals
A LESS_THAN_EQUALS predicate that can be evaluated by the OrcInputFormat.
|
static class |
OrcSplitReader.Not
A NOT predicate to negate a predicate that can be evaluated by the OrcInputFormat.
|
static class |
OrcSplitReader.NullSafeEquals
An EQUALS predicate that can be evaluated with Null safety by the OrcInputFormat.
|
static class |
OrcSplitReader.Or
An OR predicate that can be evaluated by the OrcInputFormat.
|
static class |
OrcSplitReader.Predicate
A filter predicate that can be evaluated by the OrcInputFormat.
|
Modifier and Type | Field and Description |
---|---|
protected int |
nextRow |
protected org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch |
rowBatch |
Constructor and Description |
---|
OrcSplitReader(OrcShim shim,
Configuration conf,
org.apache.orc.TypeDescription schema,
int[] selectedFields,
List<OrcSplitReader.Predicate> conjunctPredicates,
int batchSize,
Path path,
long splitStart,
long splitLength) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected abstract int |
fillRows()
Fills an ORC batch into an array of Row.
|
org.apache.orc.RecordReader |
getRecordReader() |
abstract T |
nextRecord(T reuse)
Reads the next record from the input.
|
boolean |
reachedEnd()
Method used to check if the end of the input is reached.
|
protected final org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch rowBatch
protected int nextRow
public OrcSplitReader(OrcShim shim, Configuration conf, org.apache.orc.TypeDescription schema, int[] selectedFields, List<OrcSplitReader.Predicate> conjunctPredicates, int batchSize, Path path, long splitStart, long splitLength) throws IOException
IOException
@VisibleForTesting public org.apache.orc.RecordReader getRecordReader()
public boolean reachedEnd() throws IOException
IOException
- Thrown, if an I/O error occurred.protected abstract int fillRows()
public abstract T nextRecord(T reuse) throws IOException
reuse
- Object that may be reused.IOException
- Thrown, if an I/O error occurred.public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.