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

Class VarLengthColumnReaders.NullableVarBinaryColumn

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

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

Enclosing class:

VarLengthColumnReaders

public static final class VarLengthColumnReaders.NullableVarBinaryColumn
extends NullableVarLengthValuesColumn<org.apache.drill.exec.vector.NullableVarBinaryVector>

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.NullableVarBinaryVector>	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.NullableVarLengthValuesColumn

postPageRead, readAndStoreValueSizeInformation, readField, reset, updatePosition, updateReadyToReadPosition

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

readRecordsInBulk, 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 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 NullableVarLengthValuesColumn<org.apache.drill.exec.vector.NullableVarBinaryVector>

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

Specified by:

capacity in class NullableVarLengthValuesColumn<org.apache.drill.exec.vector.NullableVarBinaryVector>

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.NullableVarBinaryVector>

Parameters:

bulkInput - set of variable length entries

newVLBulkInput

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

Specified by:

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

Returns:

new variable bulk input object

Throws:

IOException