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

Class NullableVarLengthValuesColumn<V extends ValueVector>

java.lang.Object

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

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

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

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

Direct Known Subclasses:

VarLengthColumnReaders.NullableVarBinaryColumn, VarLengthColumnReaders.NullableVarCharColumn, VarLengthColumnReaders.NullableVarDecimalColumn

public abstract class NullableVarLengthValuesColumn<V extends ValueVector>
extends VarLengthValuesColumn<V>

Field Summary

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

bulkReaderState

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

vectorData

Method Summary

Modifier and Type	Method and Description
abstract int	capacity()
protected void	postPageRead()
protected boolean	readAndStoreValueSizeInformation()
protected void	readField(long recordsToRead)
void	reset()
abstract boolean	setSafe(int index, DrillBuf value, int start, int length) Store a variable length entry if there is enough memory.
void	updatePosition()
void	updateReadyToReadPosition()

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

newVLBulkInput, readRecordsInBulk, setSafe, skipReadyToReadPositionUpdate

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

checkVectorCapacityReached, clear, determineSize, getRecordsReadInCurrentPass, hitRowGroupEnd, processPages, processPagesAsync, readIntLittleEndian, readPage, readPageAsync, readRecords, readRecordsAsync, readValues, totalValuesReadAndReadyToReadInPage

Methods inherited from class java.lang.Object

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

Method Detail

setSafe

public abstract boolean setSafe(int index,
                                DrillBuf value,
                                int start,
                                int length)

Description copied from class: VarLengthValuesColumn

Store a variable length entry if there is enough memory.

Specified by:

setSafe in class VarLengthValuesColumn<V extends ValueVector>

Parameters:

index - entry's index

value - byte array container

start - start offset

length - entry's length

Returns:

true if the entry was successfully inserted; false otherwise

capacity

public abstract int capacity()

Overrides:

capacity in class ColumnReader

reset

public void reset()

Overrides:

reset in class VarLengthColumn

postPageRead

protected void postPageRead()

Overrides:

postPageRead in class ColumnReader

readAndStoreValueSizeInformation

protected boolean readAndStoreValueSizeInformation()
                                            throws IOException

Overrides:

readAndStoreValueSizeInformation in class VarLengthValuesColumn<V extends ValueVector>

Throws:

IOException

updateReadyToReadPosition

public void updateReadyToReadPosition()

Overrides:

updateReadyToReadPosition in class VarLengthValuesColumn<V extends ValueVector>

updatePosition

public void updatePosition()

Overrides:

updatePosition in class VarLengthValuesColumn<V extends ValueVector>

readField

protected void readField(long recordsToRead)

Overrides:

readField in class VarLengthValuesColumn<V extends ValueVector>