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

Class VarLenColumnBulkInput<V extends ValueVector>

java.lang.Object

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

All Implemented Interfaces:

Iterator<VarLenBulkEntry>, VarLenBulkInput<VarLenBulkEntry>

public final class VarLenColumnBulkInput<V extends ValueVector>
extends Object
implements VarLenBulkInput<VarLenBulkEntry>

Implements the VarLenBulkInput interface to optimize data copy

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.drill.exec.vector.VarLenBulkInput

VarLenBulkInput.BulkInputCallback<T extends VarLenBulkEntry>

Method Summary

Modifier and Type	Method and Description
void	done() Indicates we're done processing (processor might stop processing when memory buffers are depleted); this allows caller to re-submit any unprocessed data.
static int	getMinVLColumnMemorySize()
int	getStartIndex()
boolean	hasNext()
VarLenBulkEntry	next()
void	remove()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<VarLenBulkEntry>

next

public final VarLenBulkEntry next()

Specified by:

next in interface Iterator<VarLenBulkEntry>

remove

public final void remove()

Specified by:

remove in interface Iterator<VarLenBulkEntry>

getStartIndex

public final int getStartIndex()

Specified by:

getStartIndex in interface VarLenBulkInput<VarLenBulkEntry>

Returns:

start index of this bulk input (relative to this VL container)

done

public final void done()

Indicates we're done processing (processor might stop processing when memory buffers are depleted); this allows caller to re-submit any unprocessed data.

Specified by:

done in interface VarLenBulkInput<VarLenBulkEntry>

getMinVLColumnMemorySize

public static int getMinVLColumnMemorySize()

Returns:

minimum memory size required to process a variable column in a columnar manner