public class OrcRowSplitReader extends OrcSplitReader<Row,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>
OrcSplitReader
to read ORC files into Row
.nextRow, rowBatchWrapper
Constructor and Description |
---|
OrcRowSplitReader(Configuration conf,
org.apache.orc.TypeDescription schema,
int[] selectedFields,
List<OrcFilters.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.
|
Row |
nextRecord(Row reuse)
Reads the next record from the input.
|
close, getRecordReader, reachedEnd, seekToRow
public OrcRowSplitReader(Configuration conf, org.apache.orc.TypeDescription schema, int[] selectedFields, List<OrcFilters.Predicate> conjunctPredicates, int batchSize, Path path, long splitStart, long splitLength) throws IOException
IOException
protected int fillRows()
OrcSplitReader
fillRows
in class OrcSplitReader<Row,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>
public Row nextRecord(Row reuse)
OrcSplitReader
nextRecord
in class OrcSplitReader<Row,org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>
reuse
- Object that may be reused.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.