Method StartProducing

cpp/src/arrow/acero/sink_node.cc:326–341

  const char* kind_name() const override { return "ConsumingSinkNode"; }

  Status StartProducing() override {
    NoteStartProducing(ToStringExtra());
    DCHECK_GT(inputs_.size(), 0);
    auto output_schema = inputs_[0]->output_schema();
    if (names_.size() > 0) {
      int num_fields = output_schema->num_fields();
      if (names_.size() != static_cast<size_t>(num_fields)) {
        return Status::Invalid(
            "A plan was created with custom field names but the number of names did not "
            "match the number of output columns");
      }
      ARROW_ASSIGN_OR_RAISE(output_schema, output_schema->WithNames(names_));
    }
    RETURN_NOT_OK(consumer_->Init(output_schema, this, plan_));
    return Status::OK();
  }

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