Method Cleanup

be/src/runtime/blocking-row-batch-queue.cc:65–73

}

void BlockingRowBatchQueue::Cleanup() {
  unique_ptr<RowBatch> batch = nullptr;
  while ((batch = GetBatch()) != nullptr) {
    batch.reset();
  }

  lock_guard<SpinLock> l(lock_);
  cleanup_queue_.clear();
}
}