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

Class StructBatchReader

java.lang.Object

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

org.apache.orc.impl.reader.tree.StructBatchReader

public class StructBatchReader
extends BatchReader

Handles the Struct rootType for batch handling. The handling assumes that the root TreeReaderFactory.StructTreeReader no nulls. Root Struct vector is not represented as part of the final VectorizedRowBatch.

Field Summary

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

rootType, vectorColumnCount

Constructor Summary

Constructors

Constructor	Description
StructBatchReader(TypeReader rowReader, TreeReaderFactory.Context context)

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 readerCategory)
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

StructBatchReader

public StructBatchReader(TypeReader rowReader,
 TreeReaderFactory.Context context)

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 readerCategory)
              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