Home
last modified time | relevance | path

Searched refs:props (Results 1 – 25 of 33) sorted by relevance

12

/rocksdb-6.9/table/
Dmeta_blocks.cc78 if (props.index_partitions != 0) { in AddTableProperty()
84 props.index_value_is_delta_encoded); in AddTableProperty()
96 if (props.file_creation_time > 0) { in AddTableProperty()
100 if (!props.filter_policy_name.empty()) { in AddTableProperty()
103 if (!props.comparator_name.empty()) { in AddTableProperty()
107 if (!props.merge_operator_name.empty()) { in AddTableProperty()
112 props.prefix_extractor_name); in AddTableProperty()
116 props.property_collectors_names); in AddTableProperty()
118 if (!props.column_family_name.empty()) { in AddTableProperty()
122 if (!props.compression_name.empty()) { in AddTableProperty()
[all …]
Dtable_test.cc1313 pos != props.end() && in TEST_F()
1328 ASSERT_TRUE(pos == props.end() || in TEST_F()
1384 props.data_size); in TEST_P()
2782 props.AssertIndexBlockStat(0, 0); in TEST_P()
2969 props.AssertFilterBlockStat(0, 0); in TEST_P()
3375 TableProperties* props = nullptr; in TEST_F() local
3382 ASSERT_EQ(0ul, props->index_size); in TEST_F()
4108 delete props; in TEST_P()
4279 uint64_t data_block_size = props->data_size / props->num_data_blocks; in TEST_P()
4281 ASSERT_EQ(props->data_size, data_block_size * props->num_data_blocks); in TEST_P()
[all …]
Dtable_properties.cc23 std::string& props, in AppendProperty() argument
28 props.append(key); in AppendProperty()
29 props.append(kv_delim); in AppendProperty()
30 props.append(value); in AppendProperty()
31 props.append(prop_delim); in AppendProperty()
36 std::string& props, in AppendProperty() argument
42 props, key, ToString(value), prop_delim, kv_delim in AppendProperty()
Dmeta_blocks.h58 void AddTableProperty(const TableProperties& props);
/rocksdb-6.9/db/
Dtable_properties_collector.cc16 uint64_t GetUint64Property(const UserCollectedProperties& props, in GetUint64Property() argument
19 auto pos = props.find(property_name); in GetUint64Property()
20 if (pos == props.end()) { in GetUint64Property()
62 const UserCollectedProperties& props) { in GetDeletedKeys() argument
64 return GetUint64Property(props, TablePropertiesNames::kDeletedKeys, in GetDeletedKeys()
68 uint64_t GetMergeOperands(const UserCollectedProperties& props, in GetMergeOperands() argument
71 props, TablePropertiesNames::kMergeOperands, property_present); in GetMergeOperands()
Ddb_table_properties_test.cc30 TablePropertiesCollection props; in VerifyTableProperties() local
31 ASSERT_OK(db->GetPropertiesOfAllTables(&props)); in VerifyTableProperties()
33 ASSERT_EQ(4U, props.size()); in VerifyTableProperties()
38 for (const auto& item : props) { in VerifyTableProperties()
43 ASSERT_EQ(props.size(), unique_entries.size()); in VerifyTableProperties()
101 TablePropertiesCollection props; in TestGetPropertiesOfTablesInRange() local
103 db_->DefaultColumnFamily(), &ranges[0], ranges.size(), &props)); in TestGetPropertiesOfTablesInRange()
117 EXPECT_GT(props.count(fn), 0); in TestGetPropertiesOfTablesInRange()
121 EXPECT_EQ(props.count(fn), 0); in TestGetPropertiesOfTablesInRange()
126 *num_properties = props.size(); in TestGetPropertiesOfTablesInRange()
[all …]
Dtable_properties_collector_test.cc293 TableProperties* props; in TestCustomizedTablePropertiesCollector() local
295 magic_number, ioptions, &props, in TestCustomizedTablePropertiesCollector()
297 std::unique_ptr<TableProperties> props_guard(props); in TestCustomizedTablePropertiesCollector()
300 auto user_collected = props->user_collected_properties; in TestCustomizedTablePropertiesCollector()
434 TableProperties* props; in TestInternalKeyPropertiesCollector() local
437 ioptions, &props, true /* compression_type_missing */); in TestInternalKeyPropertiesCollector()
440 std::unique_ptr<TableProperties> props_guard(props); in TestInternalKeyPropertiesCollector()
441 auto user_collected = props->user_collected_properties; in TestInternalKeyPropertiesCollector()
Dexternal_sst_file_ingestion_job.cc406 auto props = table_reader->GetTableProperties(); in GetIngestedFileInfo() local
407 const auto& uprops = props->user_collected_properties; in GetIngestedFileInfo()
426 auto offsets_iter = props->properties_offsets.find( in GetIngestedFileInfo()
428 if (offsets_iter == props->properties_offsets.end() || in GetIngestedFileInfo()
447 file_to_ingest->num_entries = props->num_entries; in GetIngestedFileInfo()
448 file_to_ingest->num_range_deletions = props->num_range_deletions; in GetIngestedFileInfo()
519 file_to_ingest->cf_id = static_cast<uint32_t>(props->column_family_id); in GetIngestedFileInfo()
521 file_to_ingest->table_properties = *props; in GetIngestedFileInfo()
Dimport_column_family_job.cc233 auto props = table_reader->GetTableProperties(); in GetIngestedFileInfo() local
239 file_to_import->num_entries = props->num_entries; in GetIngestedFileInfo()
267 file_to_import->cf_id = static_cast<uint32_t>(props->column_family_id); in GetIngestedFileInfo()
269 file_to_import->table_properties = *props; in GetIngestedFileInfo()
Dplain_table_db_test.cc291 TableProperties* props = const_cast<TableProperties*>(table_properties); in TestPlainTableReader() local
293 EXPECT_EQ(column_family_name, props->column_family_name); in TestPlainTableReader()
295 auto bloom_version_ptr = props->user_collected_properties.find( in TestPlainTableReader()
297 EXPECT_TRUE(bloom_version_ptr != props->user_collected_properties.end()); in TestPlainTableReader()
300 auto num_blocks_ptr = props->user_collected_properties.find( in TestPlainTableReader()
302 EXPECT_TRUE(num_blocks_ptr != props->user_collected_properties.end()); in TestPlainTableReader()
305 table_properties_.reset(props); in TestPlainTableReader()
344 TableProperties* props = nullptr; in NewTableReader() local
347 table_reader_options.ioptions, &props, in NewTableReader()
367 auto& user_props = props->user_collected_properties; in NewTableReader()
[all …]
Drepair.cc483 std::shared_ptr<const TableProperties> props; in ScanTable() local
486 &props); in ScanTable()
489 t->column_family_id = static_cast<uint32_t>(props->column_family_id); in ScanTable()
504 AddColumnFamily(props->column_family_name, t->column_family_id); in ScanTable()
506 t->meta.oldest_ancester_time = props->creation_time; in ScanTable()
511 if (cfd->GetName() != props->column_family_name) { in ScanTable()
517 t->meta.fd.GetNumber(), props->column_family_name.c_str(), in ScanTable()
Dversion_set.h652 Status GetPropertiesOfAllTables(TablePropertiesCollection* props);
653 Status GetPropertiesOfAllTables(TablePropertiesCollection* props, int level);
655 TablePropertiesCollection* props) const;
Dexternal_sst_file_test.cc741 TablePropertiesCollection props; in TEST_F() local
742 ASSERT_OK(db_->GetPropertiesOfAllTables(&props)); in TEST_F()
743 ASSERT_EQ(props.size(), 2); in TEST_F()
744 for (auto file_props : props) { in TEST_F()
765 ASSERT_OK(db_->GetPropertiesOfAllTables(&props)); in TEST_F()
766 ASSERT_EQ(props.size(), 3); in TEST_F()
767 for (auto file_props : props) { in TEST_F()
Dversion_set.cc1262 Status Version::GetPropertiesOfAllTables(TablePropertiesCollection* props) { in GetPropertiesOfAllTables() argument
1265 s = GetPropertiesOfAllTables(props, level); in GetPropertiesOfAllTables()
1328 Status Version::GetPropertiesOfAllTables(TablePropertiesCollection* props, in GetPropertiesOfAllTables() argument
1339 props->insert({fname, table_properties}); in GetPropertiesOfAllTables()
1349 const Range* range, std::size_t n, TablePropertiesCollection* props) const { in GetPropertiesOfTablesInRange()
1362 if (props->count(fname) == 0) { in GetPropertiesOfTablesInRange()
1368 props->insert({fname, table_properties}); in GetPropertiesOfTablesInRange()
1382 TablePropertiesCollection props; in GetAggregatedTableProperties() local
1385 s = GetPropertiesOfAllTables(&props); in GetAggregatedTableProperties()
1387 s = GetPropertiesOfAllTables(&props, level); in GetAggregatedTableProperties()
[all …]
/rocksdb-6.9/table/block_based/
Dblock_based_table_builder.cc314 TableProperties props; member
512 if (r->props.num_entries > r->props.num_range_deletions) { in Add()
572 r->props.num_entries++; in Add()
576 r->props.num_deletions++; in Add()
578 r->props.num_deletions++; in Add()
579 r->props.num_range_deletions++; in Add()
581 r->props.num_merge_operands++; in Add()
716 ++r->props.num_data_blocks; in WriteBlock()
931 rep_->props.index_size = in WritePropertiesBlock()
940 rep_->props.compression_name = in WritePropertiesBlock()
[all …]
Dblock_based_filter_block.cc24 void AppendItem(std::string* props, const std::string& key, in AppendItem() argument
47 props->append(result + ": " + value_str + "\n"); in AppendItem()
51 void AppendItem(std::string* props, const TKey& key, const std::string& value) { in AppendItem() argument
53 AppendItem(props, key_str, value); in AppendItem()
Dblock_based_table_reader.cc461 auto& props = table_properties.user_collected_properties; in IsFeatureSupported() local
462 auto pos = props.find(user_prop_name); in IsFeatureSupported()
464 if (pos != props.end()) { in IsFeatureSupported()
479 const auto& props = table_properties.user_collected_properties; in GetGlobalSequenceNumber() local
484 if (version_pos == props.end()) { in GetGlobalSequenceNumber()
485 if (seqno_pos != props.end()) { in GetGlobalSequenceNumber()
499 if (seqno_pos != props.end() || version != 1) { in GetGlobalSequenceNumber()
515 if (seqno_pos != props.end()) { in GetGlobalSequenceNumber()
843 auto& props = rep_->table_properties->user_collected_properties; in ReadPropertiesBlock() local
844 auto pos = props.find(BlockBasedTablePropertyNames::kIndexType); in ReadPropertiesBlock()
[all …]
/rocksdb-6.9/table/plain/
Dplain_table_reader.cc134 std::shared_ptr<TableProperties> props(props_ptr); in Open() local
140 auto& user_props = props->user_collected_properties; in Open()
141 auto prefix_extractor_in_file = props->prefix_extractor_name; in Open()
168 encoding_type, file_size, props.get(), prefix_extractor)); in Open()
176 s = new_reader->PopulateIndex(props.get(), bloom_bits_per_key, in Open()
188 new_reader->table_properties_ = props; in Open()
297 Status PlainTableReader::PopulateIndex(TableProperties* props, in PopulateIndex() argument
302 assert(props != nullptr); in PopulateIndex()
362 static_cast<uint32_t>(props->num_entries), in PopulateIndex()
421 props->user_collected_properties["plain_table_sub_index_size"] = in PopulateIndex()
[all …]
Dplain_table_reader.h134 Status PopulateIndex(TableProperties* props, int bloom_bits_per_key,
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_builder_test.cc66 TableProperties* props = nullptr; in CheckFileContents() local
74 std::string unused_key = props->user_collected_properties[ in CheckFileContents()
77 props->fixed_key_len), unused_key); in CheckFileContents()
83 ASSERT_EQ(props->raw_value_size, values.size()*value_len_found); in CheckFileContents()
101 ASSERT_EQ(props->num_entries, keys.size()); in CheckFileContents()
102 ASSERT_EQ(props->num_deletions, num_deletions); in CheckFileContents()
104 ASSERT_EQ(props->data_size, expected_unused_bucket.size() * in CheckFileContents()
106 ASSERT_EQ(props->raw_key_size, keys.size()*props->fixed_key_len); in CheckFileContents()
107 ASSERT_EQ(props->column_family_id, 0); in CheckFileContents()
108 ASSERT_EQ(props->column_family_name, kDefaultColumnFamilyName); in CheckFileContents()
[all …]
Dcuckoo_table_reader.cc59 TableProperties* props = nullptr; in CuckooTableReader() local
61 ioptions, &props, true /* compression_type_missing */); in CuckooTableReader()
65 table_props_.reset(props); in CuckooTableReader()
66 auto& user_props = props->user_collected_properties; in CuckooTableReader()
80 key_length_ = static_cast<uint32_t>(props->fixed_key_len); in CuckooTableReader()
/rocksdb-6.9/include/rocksdb/
Dtable_properties.h246 extern uint64_t GetDeletedKeys(const UserCollectedProperties& props);
247 extern uint64_t GetMergeOperands(const UserCollectedProperties& props,
Ddb.h1533 TablePropertiesCollection* props) = 0;
1534 virtual Status GetPropertiesOfAllTables(TablePropertiesCollection* props) { in GetPropertiesOfAllTables() argument
1535 return GetPropertiesOfAllTables(DefaultColumnFamily(), props); in GetPropertiesOfAllTables()
1539 TablePropertiesCollection* props) = 0;
/rocksdb-6.9/include/rocksdb/utilities/
Dstackable_db.h422 TablePropertiesCollection* props) override { in GetPropertiesOfAllTables() argument
423 return db_->GetPropertiesOfAllTables(column_family, props); in GetPropertiesOfAllTables()
429 TablePropertiesCollection* props) override { in GetPropertiesOfTablesInRange() argument
430 return db_->GetPropertiesOfTablesInRange(column_family, range, n, props); in GetPropertiesOfTablesInRange()
/rocksdb-6.9/tools/
Dsst_dump_tool.cc298 auto& props = table_properties_->user_collected_properties; in SetTableOptionsByMagicNumber() local
299 auto pos = props.find(BlockBasedTablePropertyNames::kIndexType); in SetTableOptionsByMagicNumber()
300 if (pos != props.end()) { in SetTableOptionsByMagicNumber()

12