public class OrcColumnarRowSplitReader extends OrcSplitReader<BaseRow>
OrcSplitReader
to read ORC files into BaseRow
.Modifier and Type | Class and Description |
---|---|
static interface |
OrcColumnarRowSplitReader.ColumnBatchGenerator
Interface to gen
VectorizedColumnBatch . |
OrcSplitReader.Between, OrcSplitReader.Equals, OrcSplitReader.In, OrcSplitReader.IsNull, OrcSplitReader.LessThan, OrcSplitReader.LessThanEquals, OrcSplitReader.Not, OrcSplitReader.NullSafeEquals, OrcSplitReader.Or, OrcSplitReader.Predicate
nextRow, rowBatch
Constructor and Description |
---|
OrcColumnarRowSplitReader(OrcShim shim,
Configuration conf,
org.apache.orc.TypeDescription schema,
int[] selectedFields,
OrcColumnarRowSplitReader.ColumnBatchGenerator batchGenerator,
List<OrcSplitReader.Predicate> conjunctPredicates,
int batchSize,
Path path,
long splitStart,
long splitLength) |
Modifier and Type | Method and Description |
---|---|
protected int |
fillRows()
Fills an ORC batch into an array of Row.
|
BaseRow |
nextRecord(BaseRow reuse)
Reads the next record from the input.
|
close, getRecordReader, reachedEnd
public OrcColumnarRowSplitReader(OrcShim shim, Configuration conf, org.apache.orc.TypeDescription schema, int[] selectedFields, OrcColumnarRowSplitReader.ColumnBatchGenerator batchGenerator, List<OrcSplitReader.Predicate> conjunctPredicates, int batchSize, Path path, long splitStart, long splitLength) throws IOException
IOException
protected int fillRows()
OrcSplitReader
fillRows
in class OrcSplitReader<BaseRow>
public BaseRow nextRecord(BaseRow reuse)
OrcSplitReader
nextRecord
in class OrcSplitReader<BaseRow>
reuse
- Object that may be reused.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.