Method ProcessBatch

cpp/src/arrow/acero/source_node_test.cc:54–61

  const char* kind_name() const override { return ThisNode::kKindName; }
  Result<ExecBatch> ProcessBatch(ExecBatch batch) override {
    if (num_pass == 1) {
      inputs()[0]->PauseProducing(this, 1);
      ARROW_RETURN_NOT_OK(static_cast<ThisNode*>(this)->DoStopProducing());
    }
    if (num_pass > 0) --num_pass;
    return batch;
  }

  int num_pass;
};