org.apache.drill.exec.vector

Interface VarLenBulkInput.BulkInputCallback<T extends VarLenBulkEntry>

Enclosing interface:

VarLenBulkInput<T extends VarLenBulkEntry>

public 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	onEndBulkInput() Indicates the bulk input is done
void	onNewBulkEntry(T entry) Invoked when a new bulk entry is read (entry is immutable)

Method Detail

onNewBulkEntry

void onNewBulkEntry(T entry)

Invoked when a new bulk entry is read (entry is immutable)

Parameters:

entry - bulk entry

onEndBulkInput

void onEndBulkInput()

Indicates the bulk input is done