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

Class VarLengthColumnReaders.VarDecimalColumn

java.lang.Object

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

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

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

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

Enclosing class:

VarLengthColumnReaders

public static class VarLengthColumnReaders.VarDecimalColumn
extends VarLengthValuesColumn<VarDecimalVector>

Field Summary

Fields

Modifier and Type	Field	Description
protected VarDecimalVector.Mutator	mutator
protected VarDecimalVector	varDecimalVector

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

DICTIONARY_ENCODINGS, VALUE_ENCODINGS, vectorData

Method Summary

Modifier and Type	Method	Description
int	capacity()
protected VarLenColumnBulkInput<VarDecimalVector>	newVLBulkInput(int recordsToRead)
boolean	setSafe(int index, DrillBuf value, int start, int length)	Store a variable length entry if there is enough memory.
protected void	setSafe(VarLenBulkInput<VarLenBulkEntry> bulkInput)	Store a set of variable entries in bulk; this method will automatically extend the underlying value vector if needed.

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

readAndStoreValueSizeInformation, readField, readRecordsInBulk, skipReadyToReadPositionUpdate, updatePosition, updateReadyToReadPosition

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

processPageData, reset

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

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

Methods inherited from class java.lang.Object

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

Field Details

varDecimalVector

protected VarDecimalVector varDecimalVector

mutator

protected VarDecimalVector.Mutator mutator

Method Details

setSafe

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

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 int capacity()

Overrides:

capacity in class ColumnReader

setSafe

protected void setSafe(VarLenBulkInput<VarLenBulkEntry> bulkInput)

Store a set of variable entries in bulk; this method will automatically extend the underlying value vector if needed.

Specified by:

setSafe in class VarLengthValuesColumn<VarDecimalVector>

Parameters:

bulkInput - set of variable length entries

newVLBulkInput

protected VarLenColumnBulkInput<VarDecimalVector> newVLBulkInput(int recordsToRead)
                                                          throws IOException

Specified by:

newVLBulkInput in class VarLengthValuesColumn<VarDecimalVector>

Returns:

new variable bulk input object

Throws:

IOException