Method StartProducing

cpp/src/arrow/dataset/scan_node.cc:439–452

  }

  Status StartProducing() override {
    NoteStartProducing(ToStringExtra());
    batches_throttle_ = util::ThrottledAsyncTaskScheduler::Make(
        plan_->query_context()->async_scheduler(), options_.target_bytes_readahead + 1);
    plan_->query_context()->async_scheduler()->AddSimpleTask(
        [this] {
          return GetFragments(options_.dataset.get(), options_.filter)
              .Then([this](const AsyncGenerator<std::shared_ptr<Fragment>>& frag_gen) {
                ScanFragments(frag_gen);
              });
        },
        "ScanNode::ListDataset::GetFragments"sv);
    return Status::OK();
  }

  void PauseProducing(ExecNode* output, int32_t counter) override {
    // TODO(ARROW-17755)