org.apache.drill.exec.vector

Interface VarLenBulkInput<T extends VarLenBulkEntry>

All Superinterfaces:

Iterator<T>

All Known Implementing Classes:

VarLenColumnBulkInput

public interface VarLenBulkInput<T extends VarLenBulkEntry>
extends Iterator<T>

Allows caller to provide input in a bulk manner while abstracting the underlying data structure to provide performance optimizations opportunities.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	VarLenBulkInput.BulkInputCallback<T extends VarLenBulkEntry> Enables caller (such as wrapper vector objects) to include more processing logic as the data is being streamed.

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.
int	getStartIndex()

Methods inherited from interface java.util.Iterator

forEachRemaining, hasNext, next, remove

Method Detail

getStartIndex

int getStartIndex()

Returns:

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

done

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.