Method Make

cpp/src/arrow/acero/sink_node.cc:147–157

  ~SinkNode() override { *node_destroyed_ = true; }

  static Result<ExecNode*> Make(ExecPlan* plan, std::vector<ExecNode*> inputs,
                                const ExecNodeOptions& options) {
    RETURN_NOT_OK(ValidateExecNodeInputs(plan, inputs, 1, "SinkNode"));

    const auto& sink_options = checked_cast<const SinkNodeOptions&>(options);
    RETURN_NOT_OK(ValidateOptions(sink_options));
    return plan->EmplaceNode<SinkNode>(plan, std::move(inputs), sink_options.generator,
                                       sink_options.schema, sink_options.backpressure,
                                       sink_options.backpressure_monitor,
                                       sink_options.sequence_output);
  }

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