Function RunCTXSSSP

analytical_engine/test/run_string_oid.cc:38–60

    gs::ArrowProjectedFragment<std::string, uint64_t, double, int64_t>;

void RunCTXSSSP(std::shared_ptr<ProjectedFragmentType> fragment,
                const grape::CommSpec& comm_spec,
                const std::string& out_prefix) {
  using AppType = grape::SSSP<ProjectedFragmentType>;
  auto app = std::make_shared<AppType>();
  auto worker = AppType::CreateWorker(app, fragment);
  auto spec = grape::DefaultParallelEngineSpec();
  worker->Init(comm_spec, spec);
  MPI_Barrier(comm_spec.comm());
  worker->Query("v4");

  auto ctx = worker->GetContext();

  worker->Finalize();

  std::ofstream ostream;
  std::string output_path =
      grape::GetResultFilename(out_prefix, fragment->fid());
  LOG(INFO) << "to write to: " << output_path;
  ostream.open(output_path);
  ctx->Output(ostream);
  ostream.close();
}

void Run(vineyard::Client& client, const grape::CommSpec& comm_spec,
         vineyard::ObjectID id) {