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 and 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 and Description
protected ReadState	readState

Constructor Summary

Constructors

Constructor and Description
BatchReader(ReadState readState)

Method Summary

Modifier and Type	Method and 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 Detail

readState

protected final ReadState readState

Constructor Detail

BatchReader

public BatchReader(ReadState readState)

Method Detail

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