columns.push_back(sharding_def[i].name);
} else {
for (size_t j = 0; j < sharding_def[i].shard_cnt; j++) {
- columns.push_back(sharding_def[i].name + "-" + to_string(j));
+ columns.push_back(sharding_def[i].name + "-" + std::to_string(j));
}
}
}
if (p.shard_cnt == 1)
cf_name = p.name;
else
- cf_name = p.name + "-" + to_string(idx);
+ cf_name = p.name + "-" + std::to_string(idx);
rocksdb::ColumnFamilyHandle *cf;
status = db->CreateColumnFamily(cf_opt, cf_name, &cf);
if (!status.ok()) {
emplace_cf(column, 0, column.name, cf_opt);
} else {
for (size_t i = 0; i < column.shard_cnt; i++) {
- std::string cf_name = column.name + "-" + to_string(i);
+ std::string cf_name = column.name + "-" + std::to_string(i);
emplace_cf(column, i, cf_name, cf_opt);
}
}
if (iters[0]->Valid()) {
if (iters[i]->Valid()) {
if (keyless(iters[0], iters[i])) {
- swap(iters[0], iters[i]);
+ std::swap(iters[0], iters[i]);
}
} else {
//iters[i] empty
}
} else {
if (iters[i]->Valid()) {
- swap(iters[0], iters[i]);
+ std::swap(iters[0], iters[i]);
}
}
//it might happen that cf was empty
new_sharding_columns.push_back(name);
} else {
for (size_t i = 0; i < handle.handles.size(); i++) {
- new_sharding_columns.push_back(name + "-" + to_string(i));
+ new_sharding_columns.push_back(name + "-" + std::to_string(i));
}
}
}
*/
public:
struct ColumnFamily {
- string name; //< name of this individual column family
+ std::string name; //< name of this individual column family
size_t shard_cnt; //< count of shards
- string options; //< configure option string for this CF
+ std::string options; //< configure option string for this CF
uint32_t hash_l; //< first character to take for hash calc.
uint32_t hash_h; //< last character to take for hash calc.
- ColumnFamily(const string &name, size_t shard_cnt, const string &options,
+ ColumnFamily(const std::string &name, size_t shard_cnt, const std::string &options,
uint32_t hash_l, uint32_t hash_h)
: name(name), shard_cnt(shard_cnt), options(options), hash_l(hash_l), hash_h(hash_h) {}
};
static void sharding_def_to_columns(const std::vector<ColumnFamily>& sharding_def,
std::vector<std::string>& columns);
int create_shards(const rocksdb::Options& opt,
- const vector<ColumnFamily>& sharding_def);
+ const std::vector<ColumnFamily>& sharding_def);
int apply_sharding(const rocksdb::Options& opt,
const std::string& sharding_text);
int verify_sharding(const rocksdb::Options& opt,
return static_cast<int64_t>(bbt_opts.block_cache->GetUsage());
}
- virtual int64_t get_cache_usage(string prefix) const override {
+ virtual int64_t get_cache_usage(std::string prefix) const override {
auto it = cf_bbt_opts.find(prefix);
if (it != cf_bbt_opts.end() && it->second.block_cache) {
return static_cast<int64_t>(it->second.block_cache->GetUsage());
virtual std::shared_ptr<PriorityCache::PriCache>
get_priority_cache() const override {
- return dynamic_pointer_cast<PriorityCache::PriCache>(
+ return std::dynamic_pointer_cast<PriorityCache::PriCache>(
bbt_opts.block_cache);
}
virtual std::shared_ptr<PriorityCache::PriCache>
- get_priority_cache(string prefix) const override {
+ get_priority_cache(std::string prefix) const override {
auto it = cf_bbt_opts.find(prefix);
if (it != cf_bbt_opts.end()) {
- return dynamic_pointer_cast<PriorityCache::PriCache>(
+ return std::dynamic_pointer_cast<PriorityCache::PriCache>(
it->second.block_cache);
}
return nullptr;