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

Class NullableFixedByteAlignedReaders.NullableIntervalReader

java.lang.Object

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

org.apache.drill.exec.store.parquet.columnreaders.NullableFixedByteAlignedReaders.NullableIntervalReader

Enclosing class:

NullableFixedByteAlignedReaders

public static class NullableFixedByteAlignedReaders.NullableIntervalReader
extends ColumnReader<V>

Field Summary

Fields

Modifier and Type	Field and Description
protected DrillBuf	bytebuf
protected BaseDataValueVector	castedBaseVector
protected NullableVectorDefinitionSetter	castedVectorMutator
protected int	dataTypeLengthInBytes

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

DICTIONARY_ENCODINGS, VALUE_ENCODINGS, vectorData

Method Summary

Modifier and Type	Method and Description
void	processPages(long recordsToReadInThisPass)
protected void	readField(long recordsToReadInThisPass)

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

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

Methods inherited from class java.lang.Object

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

Field Detail

dataTypeLengthInBytes

protected int dataTypeLengthInBytes

bytebuf

protected DrillBuf bytebuf

castedBaseVector

protected BaseDataValueVector castedBaseVector

castedVectorMutator

protected NullableVectorDefinitionSetter castedVectorMutator

Method Detail

readField

protected void readField(long recordsToReadInThisPass)

processPages

public void processPages(long recordsToReadInThisPass)
                  throws IOException

Overrides:

processPages in class ColumnReader<V extends ValueVector>

Throws:

IOException