Package org.apache.drill.exec.work.batch
package org.apache.drill.exec.work.batch
-
ClassDescriptionDetermines when a particular fragment has enough data for each of its receiving exchanges to commence execution.A batch buffer is responsible for queuing incoming batches until a consumer is ready to receive them.This implementation of RawBatchBuffer starts writing incoming batches to disk once the buffer size reaches a threshold.