Method EdgeLoadingTask

graphlearn/src/actor/graph/loading_task.cc:54–59

}

EdgeLoadingTask::EdgeLoadingTask(io::EdgeLoader* reader,
                                 unsigned id,
                                 unsigned batch_size)
    : alien_task(), reader_(reader), source_(nullptr),
      batch_size_(batch_size), output_handle_(id) {
}

void EdgeLoadingTask::run() {
  Status s = BeginNextFile();