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 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

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, 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