Package 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
    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 Details

    • 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