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

Class VarLengthColumn<V extends ValueVector>

java.lang.Object

org.apache.drill.exec.store.parquet.columnreaders.ColumnReader<V>

org.apache.drill.exec.store.parquet.columnreaders.VarLengthColumn<V>

Direct Known Subclasses:

FixedWidthRepeatedReader, VarLengthValuesColumn

public abstract class VarLengthColumn<V extends ValueVector>
extends ColumnReader<V>

Field Summary

Fields inherited from class org.apache.drill.exec.store.parquet.columnreaders.ColumnReader

DICTIONARY_ENCODINGS, VALUE_ENCODINGS, vectorData

Method Summary

Modifier and Type	Method	Description
protected boolean	processPageData(int recordsToReadInThisPass)
protected abstract boolean	readAndStoreValueSizeInformation()
void	reset()
abstract boolean	skipReadyToReadPositionUpdate()

Methods inherited from class org.apache.drill.exec.store.parquet.columnreaders.ColumnReader

capacity, checkVectorCapacityReached, clear, determineSize, getRecordsReadInCurrentPass, hitRowGroupEnd, postPageRead, processPages, processPagesAsync, readField, readIntLittleEndian, readPage, readPageAsync, readRecords, readRecordsAsync, readRecordsInBulk, readValues, recordsRequireDecoding, totalValuesReadAndReadyToReadInPage, updatePosition, updateReadyToReadPosition

Methods inherited from class java.lang.Object

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

Method Details

processPageData

protected boolean processPageData(int recordsToReadInThisPass)
                           throws IOException

Overrides:

processPageData in class ColumnReader<V extends ValueVector>

Throws:

IOException

reset

public void reset()

Overrides:

reset in class ColumnReader<V extends ValueVector>

readAndStoreValueSizeInformation

protected abstract boolean readAndStoreValueSizeInformation()
                                                     throws IOException

Throws:

IOException

skipReadyToReadPositionUpdate

public abstract boolean skipReadyToReadPositionUpdate()