Package org.apache.drill.exec.store.parquet.columnreaders

Class BatchReader

java.lang.Object

org.apache.drill.exec.store.parquet.columnreaders.BatchReader

Direct Known Subclasses:

BatchReader.FixedWidthReader, BatchReader.MockBatchReader, BatchReader.VariableWidthReader

public abstract class BatchReader
extends Object

Base strategy for reading a batch of Parquet records.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BatchReader.FixedWidthReader	Strategy for reading a record batch when all columns are fixed-width.
static class	BatchReader.MockBatchReader	Strategy for reading mock records.
static class	BatchReader.VariableWidthReader	Strategy for reading a record batch when at last one column is variable width.

Field Summary

Fields

Modifier and Type	Field	Description
protected final ReadState	readState

Constructor Summary

Constructors

Constructor	Description
BatchReader(ReadState readState)

Method Summary

Modifier and Type	Method	Description
protected void	readAllFixedFields(long recordsToRead)
protected void	readAllFixedFieldsParallel(long recordsToRead)
protected void	readAllFixedFieldsSerial(long recordsToRead)
int	readBatch()
protected abstract int	readRecords(ColumnReader<?> firstColumnStatus, long recordsToRead)

Methods inherited from class java.lang.Object

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

Field Details

readState

protected final ReadState readState

Constructor Details

BatchReader

public BatchReader(ReadState readState)

Method Details

readBatch

public int readBatch()
              throws Exception

Throws:

Exception

readRecords

protected abstract int readRecords(ColumnReader<?> firstColumnStatus,
 long recordsToRead)
                            throws Exception

Throws:

Exception

readAllFixedFields

protected void readAllFixedFields(long recordsToRead)
                           throws Exception

Throws:

Exception

readAllFixedFieldsSerial

protected void readAllFixedFieldsSerial(long recordsToRead)
                                 throws IOException

Throws:

IOException

readAllFixedFieldsParallel

protected void readAllFixedFieldsParallel(long recordsToRead)
                                   throws Exception

Throws:

Exception