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

    • 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.