MCPcopy Create free account
hub / github.com/apache/arrow / Make

Method Make

cpp/src/arrow/acero/source_node_test.cc:42–51  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

40 : MapNode(plan, inputs, output_schema), num_pass(options.num_pass) {}
41
42 static Result<ExecNode*> Make(ExecPlan* plan, std::vector<ExecNode*> inputs,
43 const ExecNodeOptions& options) {
44 RETURN_NOT_OK(ValidateExecNodeInputs(plan, inputs, 1, ThisNode::kKindName));
45 auto bp_options = static_cast<const PauseThenStopNodeOptions&>(options);
46 if (bp_options.num_pass < 2) {
47 return Status::Invalid("num_pass must be at least 2");
48 }
49 return plan->EmplaceNode<ThisNode>(plan, inputs, inputs[0]->output_schema(),
50 bp_options);
51 }
52
53 const char* kind_name() const override { return ThisNode::kKindName; }
54 Result<ExecBatch> ProcessBatch(ExecBatch batch) override {

Callers

nothing calls this directly

Calls 2

ValidateExecNodeInputsFunction · 0.85
InvalidFunction · 0.50

Tested by

no test coverage detected