Method Close

cpp/src/arrow/acero/exec_plan.cc:1067–1084

    }

    Status Close() override {
      if (!iterator_) {
        // Already closed
        return Status::OK();
      }
      // End plan and read from generator until finished
      plan_->StopProducing();
      std::shared_ptr<RecordBatch> batch;
      do {
        Status st = ReadNext(&batch);
        if (!st.ok()) {
          if (st.IsCancelled()) break;  // plan cancelled, so closing is done
          return st;
        }
      } while (batch != nullptr);
      iterator_.reset();
      return Status::OK();
    }

    std::shared_ptr<ExecPlan> plan_;
    std::shared_ptr<Schema> schema_;