public class RecordReaderImpl extends org.apache.orc.impl.RecordReaderImpl implements RecordReader
Modifier | Constructor and Description |
---|---|
protected |
RecordReaderImpl(ReaderImpl fileReader,
org.apache.orc.Reader.Options options) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch |
createRowBatch() |
long |
getRowNumber() |
boolean |
hasNext()
Does the reader have more rows available.
|
Object |
next(Object previous)
Read the next row.
|
boolean |
nextBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch theirBatch) |
void |
seekToRow(long row) |
encodeTranslatedSargColumn, evaluatePredicate, getCompressionCodec, getProgress, mapSargColumnsToOrcInternalColIdx, mapSargColumnsToOrcInternalColIdx, mapTranslatedSargColumns, pickRowGroups, readRowIndex, readRowIndex, readStripeFooter
protected RecordReaderImpl(ReaderImpl fileReader, org.apache.orc.Reader.Options options) throws IOException
IOException
public org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch createRowBatch()
public long getRowNumber()
getRowNumber
in interface org.apache.orc.RecordReader
getRowNumber
in class org.apache.orc.impl.RecordReaderImpl
public boolean hasNext() throws IOException
RecordReader
IOException
public void seekToRow(long row) throws IOException
seekToRow
in interface org.apache.orc.RecordReader
seekToRow
in class org.apache.orc.impl.RecordReaderImpl
IOException
public Object next(Object previous) throws IOException
RecordReader
previous
- a row object that can be reused by the readerIOException
public boolean nextBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch theirBatch) throws IOException
nextBatch
in interface org.apache.orc.RecordReader
nextBatch
in class org.apache.orc.impl.RecordReaderImpl
IOException
public void close() throws IOException
close
in interface org.apache.orc.RecordReader
close
in class org.apache.orc.impl.RecordReaderImpl
IOException
Copyright © 2021 The Apache Software Foundation. All rights reserved.