| 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 { |
nothing calls this directly
no test coverage detected