Package org.apache.orc.impl.reader.tree
Class BatchReader
java.lang.Object
org.apache.orc.impl.reader.tree.BatchReader
- Direct Known Subclasses:
PrimitiveBatchReader
,StructBatchReader
The top level interface that the reader uses to read the columns from the
ORC file.
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionabstract void
nextBatch
(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch, int batchSize, TypeReader.ReadPhase readPhase) Read the next batch of data from the file.protected void
resetBatch
(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch, int batchSize) abstract void
seek
(PositionProvider[] index, TypeReader.ReadPhase readPhase) void
setVectorColumnCount
(int vectorColumnCount) abstract void
skipRows
(long rows, TypeReader.ReadPhase readPhase) abstract void
startStripe
(StripePlanner planner, TypeReader.ReadPhase readPhase)
-
Field Details
-
rootType
-
vectorColumnCount
protected int vectorColumnCount
-
-
Constructor Details
-
BatchReader
-
-
Method Details
-
startStripe
public abstract void startStripe(StripePlanner planner, TypeReader.ReadPhase readPhase) throws IOException - Throws:
IOException
-
setVectorColumnCount
public void setVectorColumnCount(int vectorColumnCount) -
nextBatch
public abstract void nextBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch, int batchSize, TypeReader.ReadPhase readPhase) throws IOException Read the next batch of data from the file.- Parameters:
batch
- the batch to read intobatchSize
- the number of rows to readreadPhase
- defines the read phase- Throws:
IOException
- errors reading the file
-
resetBatch
protected void resetBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch, int batchSize) -
skipRows
- Throws:
IOException
-
seek
public abstract void seek(PositionProvider[] index, TypeReader.ReadPhase readPhase) throws IOException - Throws:
IOException
-