Method executeSerial

bolt/exec/tests/TaskTest.cpp:483–528

  }

  static std::pair<std::shared_ptr<exec::Task>, std::vector<RowVectorPtr>>
  executeSerial(
      core::PlanFragment plan,
      const std::unordered_map<std::string, std::vector<std::string>>&
          filePaths = {}) {
    auto task = Task::create(
        "single.execution.task.0",
        plan,
        0,
        core::QueryCtx::create(),
        Task::ExecutionMode::kSerial);

    for (const auto& [nodeId, paths] : filePaths) {
      for (const auto& path : paths) {
        task->addSplit(nodeId, exec::Split(makeHiveConnectorSplit(path)));
      }
      task->noMoreSplits(nodeId);
    }

    BOLT_CHECK(task->supportSerialExecutionMode());

    vector_size_t numRows = 0;
    std::vector<RowVectorPtr> results;
    for (;;) {
      auto result = task->next();
      if (!result) {
        break;
      }

      for (auto& child : result->children()) {
        child->loadedVector();
      }
      results.push_back(result);
      numRows += result->size();
    }

    BOLT_CHECK(waitForTaskCompletion(task.get()));

    auto planNodeStats = toPlanStats(task->taskStats());
    BOLT_CHECK(planNodeStats.count(plan.planNode->id()));
    BOLT_CHECK_EQ(numRows, planNodeStats.at(plan.planNode->id()).outputRows);
    BOLT_CHECK_EQ(
        results.size(), planNodeStats.at(plan.planNode->id()).outputVectors);

    return {task, results};
  }
};

TEST_F(TaskTest, sparkTaskAttemptId) {