Method GetBatch

be/src/runtime/blocking-row-batch-queue.cc:51–55

}

unique_ptr<RowBatch> BlockingRowBatchQueue::GetBatch() {
  unique_ptr<RowBatch> result;
  if (batch_queue_->BlockingGet(&result)) return result;
  return unique_ptr<RowBatch>();
}

bool BlockingRowBatchQueue::IsFull() const {
  return batch_queue_->AtCapacity();