Method InputFinished

cpp/src/arrow/acero/fetch_node.cc:112–126

  const Ordering& ordering() const override { return inputs_[0]->ordering(); }

  Status InputFinished(ExecNode* input, int total_batches) override {
    DCHECK_EQ(input, inputs_[0]);
    EVENT_ON_CURRENT_SPAN("InputFinished", {{"batches.length", total_batches}});
    // Normally we will finish in InputFinished because we sent count_ rows. However, it
    // is possible that the input does not contain count_ rows and so we have to end from
    // here
    if (in_batch_counter_.SetTotal(total_batches)) {
      if (!finished_) {
        finished_ = true;
        ARROW_RETURN_NOT_OK(inputs_[0]->StopProducing());
        ARROW_RETURN_NOT_OK(output_->InputFinished(this, out_batch_count_));
      }
    }
    return Status::OK();
  }

  Status Validate() const override {
    ARROW_RETURN_NOT_OK(ExecNode::Validate());