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

Class FixedWidthRepeatedReader

java.lang.Object

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

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

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

public class FixedWidthRepeatedReader
extends VarLengthColumn<RepeatedValueVector>

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
int	capacity()
protected boolean	checkVectorCapacityReached()
void	clear()
int	getRecordsReadInCurrentPass()
void	hitRowGroupEnd()
void	postPageRead()
protected boolean	readAndStoreValueSizeInformation()
protected void	readField(long recordsToRead)
protected void	readRecords(int valuesToRead)
void	reset()
boolean	skipReadyToReadPositionUpdate()
protected int	totalValuesReadAndReadyToReadInPage()
void	updatePosition()
void	updateReadyToReadPosition()

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

processPageData

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

determineSize, processPages, processPagesAsync, readIntLittleEndian, readPage, readPageAsync, readRecordsAsync, readRecordsInBulk, readValues, recordsRequireDecoding

Methods inherited from class java.lang.Object

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

Method Details

reset

public void reset()

Overrides:

reset in class VarLengthColumn<RepeatedValueVector>

getRecordsReadInCurrentPass

public int getRecordsReadInCurrentPass()

Overrides:

getRecordsReadInCurrentPass in class ColumnReader<RepeatedValueVector>

readField

protected void readField(long recordsToRead)

Specified by:

readField in class ColumnReader<RepeatedValueVector>

skipReadyToReadPositionUpdate

public boolean skipReadyToReadPositionUpdate()

Specified by:

skipReadyToReadPositionUpdate in class VarLengthColumn<RepeatedValueVector>

updateReadyToReadPosition

public void updateReadyToReadPosition()

Overrides:

updateReadyToReadPosition in class ColumnReader<RepeatedValueVector>

updatePosition

public void updatePosition()

Overrides:

updatePosition in class ColumnReader<RepeatedValueVector>

hitRowGroupEnd

public void hitRowGroupEnd()

Overrides:

hitRowGroupEnd in class ColumnReader<RepeatedValueVector>

postPageRead

public void postPageRead()

Overrides:

postPageRead in class ColumnReader<RepeatedValueVector>

totalValuesReadAndReadyToReadInPage

protected int totalValuesReadAndReadyToReadInPage()

Overrides:

totalValuesReadAndReadyToReadInPage in class ColumnReader<RepeatedValueVector>

checkVectorCapacityReached

protected boolean checkVectorCapacityReached()

Overrides:

checkVectorCapacityReached in class ColumnReader<RepeatedValueVector>

readAndStoreValueSizeInformation

protected boolean readAndStoreValueSizeInformation()

Specified by:

readAndStoreValueSizeInformation in class VarLengthColumn<RepeatedValueVector>

readRecords

protected void readRecords(int valuesToRead)

Overrides:

readRecords in class ColumnReader<RepeatedValueVector>

capacity

public int capacity()

Overrides:

capacity in class ColumnReader<RepeatedValueVector>

clear

public void clear()

Overrides:

clear in class ColumnReader<RepeatedValueVector>