|
23 | 23 | #include "storage/src/base_data_key_format.h" |
24 | 24 | #include "storage/src/base_meta_value_format.h" |
25 | 25 | #include "storage/src/lists_meta_value_format.h" |
| 26 | +#include "storage/src/custom_comparator.h" |
26 | 27 |
|
27 | 28 | // Utility function to check if a directory exists |
28 | 29 | bool DirectoryExists(const std::string& path) { |
@@ -356,7 +357,7 @@ void AnalyzeSets(const std::string& path, std::vector<KeyInfo>& key_infos, const |
356 | 357 | rocksdb::DBOptions db_options; |
357 | 358 | std::vector<rocksdb::ColumnFamilyDescriptor> column_families; |
358 | 359 | column_families.emplace_back(rocksdb::kDefaultColumnFamilyName, rocksdb::ColumnFamilyOptions()); |
359 | | - column_families.emplace_back("data_cf", rocksdb::ColumnFamilyOptions()); |
| 360 | + column_families.emplace_back("member_cf", rocksdb::ColumnFamilyOptions()); |
360 | 361 |
|
361 | 362 | std::vector<rocksdb::ColumnFamilyHandle*> handles; |
362 | 363 | rocksdb::DB* db; |
@@ -651,7 +652,10 @@ void AnalyzeLists(const std::string& path, std::vector<KeyInfo>& key_infos, cons |
651 | 652 | rocksdb::DBOptions db_options; |
652 | 653 | std::vector<rocksdb::ColumnFamilyDescriptor> column_families; |
653 | 654 | column_families.emplace_back(rocksdb::kDefaultColumnFamilyName, rocksdb::ColumnFamilyOptions()); |
654 | | - column_families.emplace_back("data_cf", rocksdb::ColumnFamilyOptions()); |
| 655 | + |
| 656 | + rocksdb::ColumnFamilyOptions data_cf_ops; |
| 657 | + data_cf_ops.comparator = storage::ListsDataKeyComparator(); |
| 658 | + column_families.emplace_back("data_cf", data_cf_ops); |
655 | 659 |
|
656 | 660 | std::vector<rocksdb::ColumnFamilyHandle*> handles; |
657 | 661 | rocksdb::DB* db; |
|
0 commit comments