Method HandleBatch

cpp/src/arrow/dataset/scan_node.cc:259–271

    }

    Status HandleBatch(const std::shared_ptr<RecordBatch>& batch) {
      ARROW_ASSIGN_OR_RAISE(
          compute::ExecBatch evolved_batch,
          scan_->fragment_evolution->EvolveBatch(
              batch, node_->options_.columns, *scan_->scan_request.fragment_selection));
      compute::ExecBatch with_known_values = AddKnownValues(std::move(evolved_batch));
      node_->plan_->query_context()->ScheduleTask(
          [node = node_, output_batch = std::move(with_known_values)] {
            return node->output_->InputReceived(node, output_batch);
          },
          "ScanNode::ProcessMorsel");
      return Status::OK();
    }

    int cost() const override { return cost_; }