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

Class VarLengthColumnReaders.VarBinaryColumn

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<org.apache.drill.exec.vector.VarBinaryVector>

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

Enclosing class:

VarLengthColumnReaders

public static final class VarLengthColumnReaders.VarBinaryColumn
extends VarLengthValuesColumn<org.apache.drill.exec.vector.VarBinaryVector>

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
int	capacity()
protected VarLenColumnBulkInput<org.apache.drill.exec.vector.VarBinaryVector>	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, totalValuesReadAndReadyToReadInPage

Methods inherited from class java.lang.Object

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

Method Detail

setSafe

public final 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<org.apache.drill.exec.vector.VarBinaryVector>

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<org.apache.drill.exec.vector.VarBinaryVector>

Parameters:

bulkInput - set of variable length entries

newVLBulkInput

protected VarLenColumnBulkInput<org.apache.drill.exec.vector.VarBinaryVector> newVLBulkInput(int recordsToRead)
                                                                                      throws IOException

Specified by:

newVLBulkInput in class VarLengthValuesColumn<org.apache.drill.exec.vector.VarBinaryVector>

Returns:

new variable bulk input object

Throws:

IOException