Searched refs:shard_no (Results 1 – 2 of 2) sorted by relevance
| /third_party/mindspore/mindspore/ccsrc/minddata/mindrecord/io/ |
| D | shard_index_generator.cc | 226 Status ShardIndexGenerator::CreateDatabase(int shard_no, sqlite3 **db) { in CreateDatabase() argument
227 std::string shard_address = shard_header_.GetShardAddressByID(shard_no); in CreateDatabase()
228 …CK_FAIL_RETURN_UNEXPECTED(!shard_address.empty(), "Shard address is empty, shard No: " + shard_no); in CreateDatabase()
405 Status ShardIndexGenerator::GenerateRowData(int shard_no, const std::map<int, int> &blob_id_to_page… in GenerateRowData() argument
410 RETURN_IF_NOT_OK(shard_header_.GetPage(shard_no, raw_page_id, &page_ptr)); in GenerateRowData()
420 RETURN_IF_NOT_OK(shard_header_.GetPage(shard_no, iter->second, &blob_page_ptr)); in GenerateRowData()
490 Status ShardIndexGenerator::ExecuteTransaction(const int &shard_no, sqlite3 *db, const std::vector<… in ExecuteTransaction() argument
493 std::string shard_address = shard_header_.GetShardAddressByID(shard_no); in ExecuteTransaction()
509 …RELEASE_AND_RETURN_IF_NOT_OK(GenerateRowData(shard_no, blob_id_to_page_id, raw_page_id, in, &row_d… in ExecuteTransaction()
553 int shard_no = task_++; in DatabaseWriter() local
[all …]
|
| /third_party/mindspore/mindspore/ccsrc/minddata/mindrecord/include/ |
| D | shard_index_generator.h | 70 Status CreateDatabase(int shard_no, sqlite3 **db);
86 …Status GenerateRowData(int shard_no, const std::map<int, int> &blob_id_to_page_id, int raw_page_id…
97 Status ExecuteTransaction(const int &shard_no, sqlite3 *db, const std::vector<int> &raw_page_ids,
|