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

Class NullableFixedByteAlignedReaders.CorruptionDetectingNullableDateReader

java.lang.Object

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

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

Enclosing class:

NullableFixedByteAlignedReaders

public static class NullableFixedByteAlignedReaders.CorruptionDetectingNullableDateReader
extends ColumnReader<V>

Old versions of Drill were writing a non-standard format for date. See DRILL-4203 For files that lack enough metadata to determine if the dates are corrupt, we must just correct values when they look corrupt during this low level read.

Field Summary

Fields

Modifier and Type	Field	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	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 Details

dataTypeLengthInBytes

protected int dataTypeLengthInBytes

bytebuf

protected DrillBuf bytebuf

castedBaseVector

protected BaseDataValueVector castedBaseVector

castedVectorMutator

protected NullableVectorDefinitionSetter castedVectorMutator

Method Details

readField

protected void readField(long recordsToReadInThisPass)

processPages

public void processPages(long recordsToReadInThisPass)
                  throws IOException

Overrides:

processPages in class ColumnReader<V extends ValueVector>

Throws:

IOException