Method FinishedCallback

cpp/src/arrow/acero/tpch_node.cc:3408–3413

  }

  Status FinishedCallback(int64_t total_num_batches) {
    ARROW_RETURN_NOT_OK(
        output_->InputFinished(this, static_cast<int>(total_num_batches)));
    finished_generating_.store(true);
    return Status::OK();
  }

  Status ScheduleTaskCallback(std::function<Status(size_t)> func) {
    if (finished_generating_.load()) return Status::OK();