Method AddBatchWithTimeout

be/src/runtime/blocking-row-batch-queue.cc:45–49

}

bool BlockingRowBatchQueue::AddBatchWithTimeout(
    unique_ptr<RowBatch>&& batch, int64_t timeout_micros) {
  return batch_queue_->BlockingPutWithTimeout(
      forward<unique_ptr<RowBatch>>(batch), timeout_micros);
}

unique_ptr<RowBatch> BlockingRowBatchQueue::GetBatch() {
  unique_ptr<RowBatch> result;