Searched refs:kCommonTask (Results 1 – 3 of 3) sorted by relevance
| /third_party/mindspore/mindspore/ccsrc/minddata/mindrecord/include/common/ |
| D | shard_utils.h | 78 kCommonTask = 0, enumerator
|
| /third_party/mindspore/mindspore/ccsrc/minddata/mindrecord/io/ |
| D | shard_reader.cc | 1086 categoryTasks[categoryNo].InsertTask(TaskType::kCommonTask, shard_id, group_id, in CreateTasksByCategory()
1130 … tasks_.InsertTask(offset, TaskType::kCommonTask, offsets[shard_id][i][0], offsets[shard_id][i][1], in CreateTasksByRow()
1170 tasks_.InsertTask(i, TaskType::kCommonTask, shard_id, i - current_offset, {}, json()); in CreateLazyTasksByRow()
1302 *task_content_ptr = std::make_shared<TASK_CONTENT>(TaskType::kCommonTask, std::move(batch)); in ConsumerOneTask()
1325 …std::make_shared<TASK_CONTENT>(TaskType::kCommonTask, std::vector<std::tuple<std::vector<uint8_t>,… in ConsumerByRow()
1373 …std::make_shared<TASK_CONTENT>(TaskType::kCommonTask, std::vector<std::tuple<std::vector<uint8_t>,… in GetNextById()
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/source/ |
| D | mindrecord_op.cc | 211 if (task_type == mindrecord::TaskType::kCommonTask) { in GetRowFromReader()
|