Class SpoolingRawBatchBuffer

java.lang.Object
org.apache.drill.exec.work.batch.BaseRawBatchBuffer<org.apache.drill.exec.work.batch.SpoolingRawBatchBuffer.RawFragmentBatchWrapper>
org.apache.drill.exec.work.batch.SpoolingRawBatchBuffer
All Implemented Interfaces:
AutoCloseable, RawFragmentBatchProvider, RawBatchBuffer

public class SpoolingRawBatchBuffer extends BaseRawBatchBuffer<org.apache.drill.exec.work.batch.SpoolingRawBatchBuffer.RawFragmentBatchWrapper>
This implementation of RawBatchBuffer starts writing incoming batches to disk once the buffer size reaches a threshold. The order of the incoming buffers is maintained.