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 Link icon

    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 Link icon

    • onNewBulkEntry Link icon

      void onNewBulkEntry(T entry)
      Invoked when a new bulk entry is read (entry is immutable)
      Parameters:
      entry - bulk entry

    • onEndBulkInput Link icon

      void onEndBulkInput()
      Indicates the bulk input is done