Package org.apache.drill.exec.work.batch

Interface RawBatchBuffer

All Superinterfaces:
AutoCloseable, RawFragmentBatchProvider
All Known Implementing Classes:
BaseRawBatchBuffer, SpoolingRawBatchBuffer, UnlimitedRawBatchBuffer
public interface RawBatchBuffer extends RawFragmentBatchProvider
A batch buffer is responsible for queuing incoming batches until a consumer is ready to receive them. It will also inform upstream if the batch cannot be accepted.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final org.slf4j.Logger
    logger
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    enqueue(RawFragmentBatch batch)
    Add the next new raw fragment batch to the buffer.

    Methods inherited from interface org.apache.drill.exec.record.RawFragmentBatchProvider

    close, getNext, kill

  • Field Details

    • logger

      static final org.slf4j.Logger logger

  • Method Details