NullableFixedByteAlignedReaders.NullableCorruptDateReader (Drill : 1.22.0 API)

java.lang.Object

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

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

Enclosing class:: NullableFixedByteAlignedReaders

public static class NullableFixedByteAlignedReaders.NullableCorruptDateReader extends ColumnReader<NullableDateVector>

Old versions of Drill were writing a non-standard format for date. See DRILL-4203

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