Home
last modified time | relevance | path

Searched refs:cf_opts (Results 1 – 23 of 23) sorted by relevance

/rocksdb-6.9/utilities/options/
Doptions_util_test.cc54 std::vector<ColumnFamilyOptions> cf_opts; in TEST_F() local
59 cf_opts.emplace_back(); in TEST_F()
78 cf_opts[i], loaded_cf_descs[i].options)); in TEST_F()
81 cf_opts[i].table_factory.get(), in TEST_F()
86 cf_opts[i], loaded_cf_descs[i].options)); in TEST_F()
90 if (cf_opts[i].compaction_filter) { in TEST_F()
91 delete cf_opts[i].compaction_filter; in TEST_F()
105 std::vector<ColumnFamilyOptions> cf_opts; in TEST_F() local
109 cf_opts.push_back(default_column_family_opt); in TEST_F()
113 cf_opts.push_back(cf_opt_sample); in TEST_F()
[all …]
Doptions_util.cc30 const std::vector<ColumnFamilyOptions>& cf_opts = *parser.cf_opts(); in LoadOptionsFromFile() local
32 for (size_t i = 0; i < cf_opts.size(); ++i) { in LoadOptionsFromFile()
33 cf_descs->push_back({cf_names[i], cf_opts[i]}); in LoadOptionsFromFile()
35 TableFactory* tf = cf_opts[i].table_factory.get(); in LoadOptionsFromFile()
99 std::vector<ColumnFamilyOptions> cf_opts; in CheckOptionsCompatibility() local
102 cf_opts.push_back(cf_desc.options); in CheckOptionsCompatibility()
109 db_options, cf_names, cf_opts, dbpath + "/" + options_file_name, &fs, in CheckOptionsCompatibility()
/rocksdb-6.9/options/
Doptions_parser.cc42 if (cf_names.size() != cf_opts.size()) { in PersistRocksDBOptions()
78 for (size_t i = 0; i < cf_opts.size(); ++i) { in PersistRocksDBOptions()
90 auto* tf = cf_opts[i].table_factory.get(); in PersistRocksDBOptions()
107 db_opt, cf_names, cf_opts, file_name, fs); in PersistRocksDBOptions()
660 const std::vector<ColumnFamilyOptions>& cf_opts, in VerifyRocksDBOptionsFromFile() argument
691 } else if (cf_opts.size() > parser.cf_opts()->size()) { in VerifyRocksDBOptionsFromFile()
708 if (cf_opts.size() != parser.cf_opts()->size()) { in VerifyRocksDBOptionsFromFile()
714 } else if (cf_opts.size() > parser.cf_opts()->size()) { in VerifyRocksDBOptionsFromFile()
721 for (size_t i = 0; i < cf_opts.size(); ++i) { in VerifyRocksDBOptionsFromFile()
722 s = VerifyCFOptions(cf_opts[i], parser.cf_opts()->at(i), in VerifyRocksDBOptionsFromFile()
[all …]
Doptions_helper.cc155 ColumnFamilyOptions cf_opts(options); in BuildColumnFamilyOptions() local
163 cf_opts.memtable_whole_key_filtering = in BuildColumnFamilyOptions()
167 cf_opts.inplace_update_num_locks = in BuildColumnFamilyOptions()
172 cf_opts.disable_auto_compactions = in BuildColumnFamilyOptions()
182 cf_opts.level0_stop_writes_trigger = in BuildColumnFamilyOptions()
186 cf_opts.target_file_size_multiplier = in BuildColumnFamilyOptions()
188 cf_opts.max_bytes_for_level_base = in BuildColumnFamilyOptions()
192 cf_opts.ttl = mutable_cf_options.ttl; in BuildColumnFamilyOptions()
193 cf_opts.periodic_compaction_seconds = in BuildColumnFamilyOptions()
203 cf_opts.compaction_options_universal = in BuildColumnFamilyOptions()
[all …]
Doptions_parser.h37 const std::vector<ColumnFamilyOptions>& cf_opts,
62 const std::vector<ColumnFamilyOptions>* cf_opts() const { return &cf_opts_; } in cf_opts() function
76 const std::vector<ColumnFamilyOptions>& cf_opts,
Doptions_test.cc1618 std::shared_ptr<TableFactory> ttf = (*parser.cf_opts())[4].table_factory; in TEST_F()
1755 Status SanityCheckCFOptions(const ColumnFamilyOptions& cf_opts, in SanityCheckCFOptions() argument
1758 DBOptions(), {"default"}, {cf_opts}, kOptionsFileName, fs_.get(), in SanityCheckCFOptions()
1762 Status PersistCFOptions(const ColumnFamilyOptions& cf_opts) { in PersistCFOptions() argument
1767 return PersistRocksDBOptions(DBOptions(), {"default"}, {cf_opts}, in PersistCFOptions()
/rocksdb-6.9/java/rocksjni/
Doptions.cc3661 auto* cf_opts = in Java_org_rocksdb_ColumnFamilyOptions_setCompressionType() local
3675 auto* cf_opts = in Java_org_rocksdb_ColumnFamilyOptions_compressionType() local
4509 auto* cf_opts = in Java_org_rocksdb_ColumnFamilyOptions_setCompactionPriority() local
4523 auto* cf_opts = in Java_org_rocksdb_ColumnFamilyOptions_compactionPriority() local
4536 auto* cf_opts = in Java_org_rocksdb_ColumnFamilyOptions_setReportBgIoStats() local
4548 auto* cf_opts = in Java_org_rocksdb_ColumnFamilyOptions_reportBgIoStats() local
4560 auto* cf_opts = in Java_org_rocksdb_ColumnFamilyOptions_setTtl() local
4572 auto* cf_opts = in Java_org_rocksdb_ColumnFamilyOptions_ttl() local
4585 auto* cf_opts = in Java_org_rocksdb_ColumnFamilyOptions_setCompactionOptionsUniversal() local
4600 auto* cf_opts = in Java_org_rocksdb_ColumnFamilyOptions_setCompactionOptionsFIFO() local
[all …]
/rocksdb-6.9/table/block_based/
Dblock_based_table_factory.cc238 const DBOptions& db_opts, const ColumnFamilyOptions& cf_opts) const { in SanitizeOptions()
240 cf_opts.prefix_extractor == nullptr) { in SanitizeOptions()
262 if (table_options_.block_align && (cf_opts.compression != kNoCompression)) { in SanitizeOptions()
283 if (db_opts.unordered_write && cf_opts.max_successive_merges > 0) { in SanitizeOptions()
Dblock_based_table_factory.h65 const ColumnFamilyOptions& cf_opts) const override;
/rocksdb-6.9/tools/
Dldb_cmd.cc584 ColumnFamilyOptions* cf_opts; in PrepareOptionsForOpenDB() local
591 cf_opts = &column_families_iter->options; in PrepareOptionsForOpenDB()
637 cf_opts->compression = kNoCompression; in PrepareOptionsForOpenDB()
639 cf_opts->compression = kSnappyCompression; in PrepareOptionsForOpenDB()
641 cf_opts->compression = kZlibCompression; in PrepareOptionsForOpenDB()
643 cf_opts->compression = kBZip2Compression; in PrepareOptionsForOpenDB()
645 cf_opts->compression = kLZ4Compression; in PrepareOptionsForOpenDB()
647 cf_opts->compression = kLZ4HCCompression; in PrepareOptionsForOpenDB()
649 cf_opts->compression = kXpressCompression; in PrepareOptionsForOpenDB()
651 cf_opts->compression = kZSTD; in PrepareOptionsForOpenDB()
[all …]
/rocksdb-6.9/db/
Drepair.cc142 const auto* cf_opts = GetColumnFamilyOptions(cf_name); in AddColumnFamily() local
143 if (cf_opts == nullptr) { in AddColumnFamily()
147 Options opts(db_options_, *cf_opts); in AddColumnFamily()
161 false /* new_descriptor_log */, cf_opts); in AddColumnFamily()
Dcolumn_family_test.cc2495 std::vector<ColumnFamilyOptions> cf_opts; in TEST_P() local
2498 cf_opts.emplace_back(); in TEST_P()
2500 cf_opts.back().comparator = comparators.back(); in TEST_P()
2531 {cf_opts[0], cf_opts[1], cf_opts[2], cf_opts[3]}); in TEST_P()
Dc_test.c1222 const rocksdb_options_t* cf_opts[2] = {cf_options, cf_options}; in main() local
1224 db = rocksdb_open_column_families(db_options, dbname, 2, cf_names, cf_opts, handles, &err); in main()
1736 const rocksdb_options_t* cf_opts[3] = {cf_options, cf_options, cf_options}; in main() local
1741 db_options, dbname, 3, cf_names, cf_opts, cf_handles, &err); in main()
Dlistener_test.cc409 ColumnFamilyOptions cf_opts(options); in TEST_F() local
421 db->CreateColumnFamily(cf_opts, cf_names[c], &handle); in TEST_F()
Ddb_test_util.cc584 ColumnFamilyOptions cf_opts(options); in CreateColumnFamilies() local
588 Status s = db_->CreateColumnFamily(cf_opts, cf, &handles_[cfi++]); in CreateColumnFamilies()
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DSstFileWriterTest.java221 try(final ColumnFamilyOptions cf_opts = new ColumnFamilyOptions() in ingestSstFile_cf() argument
224 new ColumnFamilyDescriptor("new_cf".getBytes(), cf_opts))) { in ingestSstFile_cf()
/rocksdb-6.9/examples/
Dmulti_processes_example.cc160 ColumnFamilyOptions cf_opts(options); in CreateDB() local
164 s = db->CreateColumnFamily(cf_opts, cf_name, &handle); in CreateDB()
/rocksdb-6.9/monitoring/
Dstats_history_test.cc524 ColumnFamilyOptions cf_opts(options); in TEST_F() local
526 ASSERT_NOK(db_->CreateColumnFamily(cf_opts, kPersistentStatsColumnFamilyName, in TEST_F()
531 ASSERT_NOK(db_->CreateColumnFamily(cf_opts, kPersistentStatsColumnFamilyName, in TEST_F()
/rocksdb-6.9/include/rocksdb/
Dtable.h557 const ColumnFamilyOptions& cf_opts) const = 0;
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_test.cc110 ColumnFamilyOptions cf_opts(options); in CreateColumnFamilies() local
114 ASSERT_OK(db_->CreateColumnFamily(cf_opts, cf, &handles_[cfi++])); in CreateColumnFamilies()
/rocksdb-6.9/db/db_impl/
Ddb_impl_open.cc1111 autovector<const MutableCFOptions*> cf_opts; in RecoverLogFiles() local
1115 cf_opts.push_back(cfd->GetLatestMutableCFOptions()); in RecoverLogFiles()
1121 status = versions_->LogAndApply(cfds, cf_opts, edit_lists, &mutex_, in RecoverLogFiles()
Ddb_impl.cc3665 std::vector<ColumnFamilyOptions> cf_opts; in WriteOptionsFile() local
3673 cf_opts.push_back(cfd->GetLatestCFOptions()); in WriteOptionsFile()
3687 Status s = PersistRocksDBOptions(db_options, cf_names, cf_opts, file_name, in WriteOptionsFile()
/rocksdb-6.9/db/compaction/
Dcompaction_job_stats_test.cc135 ColumnFamilyOptions cf_opts(options); in CreateColumnFamilies() local
139 ASSERT_OK(db_->CreateColumnFamily(cf_opts, cf, &handles_[cfi++])); in CreateColumnFamilies()