Package org.apache.orc.impl.reader.tree

Class PrimitiveBatchReader

java.lang.Object

org.apache.orc.impl.reader.tree.BatchReader

org.apache.orc.impl.reader.tree.PrimitiveBatchReader

public class PrimitiveBatchReader
extends BatchReader

Field Summary

Fields inherited from class org.apache.orc.impl.reader.tree.BatchReader

rootType, vectorColumnCount

Constructor Summary

Constructors

Constructor	Description
PrimitiveBatchReader(TypeReader rowReader)

Method Summary

Modifier and Type	Method	Description
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.
void	seek(PositionProvider[] index, TypeReader.ReadPhase readPhase)
void	skipRows(long rows, TypeReader.ReadPhase readPhase)
void	startStripe(StripePlanner planner, TypeReader.ReadPhase readPhase)

Methods inherited from class org.apache.orc.impl.reader.tree.BatchReader

resetBatch, setVectorColumnCount

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PrimitiveBatchReader

public PrimitiveBatchReader(TypeReader rowReader)

Method Details

nextBatch

public void nextBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch,
 int batchSize,
 TypeReader.ReadPhase readPhase)
               throws IOException

Description copied from class: BatchReader

Read the next batch of data from the file.

Specified by:

nextBatch in class BatchReader

Parameters:

batch - the batch to read into

batchSize - the number of rows to read

readPhase - defines the read phase

Throws:

IOException - errors reading the file

startStripe

public void startStripe(StripePlanner planner,
 TypeReader.ReadPhase readPhase)
                 throws IOException

Specified by:

startStripe in class BatchReader

Throws:

IOException

skipRows

public void skipRows(long rows,
 TypeReader.ReadPhase readPhase)
              throws IOException

Specified by:

skipRows in class BatchReader

Throws:

IOException

seek

public void seek(PositionProvider[] index,
 TypeReader.ReadPhase readPhase)
          throws IOException

Specified by:

seek in class BatchReader

Throws:

IOException