Method LoadData

euler/core/graph/graph_builder.cc:174–205

}

bool GraphBuilder::LoadData(TaskInfo* task_info) {
  auto& files = *task_info->files;
  int start = task_info->start;
  int end = std::min(task_info->end, static_cast<int>(files.size()));
  for (; start < end; ++start) {
    auto reader = task_info->dir->Open(files[start], true);
    std::string file_name =
        JoinPath(TaskTypeString(task_info->type), files[start]);
    if (reader == nullptr) {
      EULER_LOG(ERROR) << "Open file " << file_name << " failed!!";
      return false;
    }
    bool success;
    switch (task_info->type) {
      case kLoadNodeTask:
        success = ParseNodes(reader.get(), &task_info->node_vec);
        break;
      case kLoadEdgeTask:
        success = ParseEdges(reader.get(), &task_info->edge_vec);
        break;
      default:
        assert(false);
    }
    if (!success) {
      EULER_LOG(ERROR) << file_name << " data error!";
      return false;
    }
    EULER_LOG(INFO) << "load data file ok: " << file_name;
  }

  return true;
}

Status GraphBuilder::BuildSampler(Graph* graph,
                                  GlobalSamplerType sampler_type) {