Package 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	Description
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.
static int	getMinVLColumnMemorySize()
final int	getStartIndex()
boolean	hasNext()
final VarLenBulkEntry	next()
final 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 Details

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<V extends ValueVector>

next

public final VarLenBulkEntry next()

Specified by:

next in interface Iterator<V extends ValueVector>

remove

public final void remove()

Specified by:

remove in interface Iterator<V extends ValueVector>

getStartIndex

public final int getStartIndex()

Specified by:

getStartIndex in interface VarLenBulkInput<V extends ValueVector>

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<V extends ValueVector>

getMinVLColumnMemorySize

public static int getMinVLColumnMemorySize()

Returns:

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