Home
last modified time | relevance | path

Searched refs:Merge (Results 1 – 25 of 93) sorted by relevance

1234

/rocksdb-6.9/db/
Ddb_merge_operand_test.cc76 ASSERT_OK(Merge("k1", "a")); in TEST_F()
78 ASSERT_OK(Merge("k1", "b")); in TEST_F()
79 ASSERT_OK(Merge("k1", "c")); in TEST_F()
80 ASSERT_OK(Merge("k1", "d")); in TEST_F()
112 ASSERT_OK(Merge("k2", "q")); in TEST_F()
113 ASSERT_OK(Merge("k2", "w")); in TEST_F()
114 ASSERT_OK(Merge("k2", "e")); in TEST_F()
115 ASSERT_OK(Merge("k2", "r")); in TEST_F()
153 ASSERT_OK(Merge("k3", "ab")); in TEST_F()
219 ASSERT_OK(Merge("k5", "i")); in TEST_F()
[all …]
Ddb_merge_operator_test.cc90 ASSERT_OK(Merge("k1", "a")); in TEST_F()
91 ASSERT_OK(Merge("k1", "b")); in TEST_F()
92 ASSERT_OK(Merge("k1", "c")); in TEST_F()
93 ASSERT_OK(Merge("k1", "d")); in TEST_F()
101 ASSERT_OK(Merge("k2", "a")); in TEST_F()
102 ASSERT_OK(Merge("k2", "b")); in TEST_F()
103 ASSERT_OK(Merge("k2", "c")); in TEST_F()
104 ASSERT_OK(Merge("k2", "d")); in TEST_F()
110 ASSERT_OK(Merge("k3", "ab")); in TEST_F()
112 ASSERT_OK(Merge("k3", "bc")); in TEST_F()
[all …]
Dwrite_batch_base.cc77 Status WriteBatchBase::Merge(ColumnFamilyHandle* column_family, in Merge() function in ROCKSDB_NAMESPACE::WriteBatchBase
83 return Merge(column_family, key_slice, value_slice); in Merge()
86 Status WriteBatchBase::Merge(const SliceParts& key, const SliceParts& value) { in Merge() function in ROCKSDB_NAMESPACE::WriteBatchBase
91 return Merge(key_slice, value_slice); in Merge()
Ddb_iterator_test.cc1149 ASSERT_OK(Merge("a1", "x1")); in TEST_P()
1150 ASSERT_OK(Merge("b1", "y1")); in TEST_P()
1151 ASSERT_OK(Merge("c0", "z1")); in TEST_P()
1153 ASSERT_OK(Merge("a2", "x2")); in TEST_P()
1154 ASSERT_OK(Merge("b2", "y2")); in TEST_P()
1155 ASSERT_OK(Merge("c0", "z2")); in TEST_P()
1239 ASSERT_OK(Merge("a", "x1")); in TEST_P()
1240 ASSERT_OK(Merge("c", "y1")); in TEST_P()
1241 ASSERT_OK(Merge("e", "z1")); in TEST_P()
1243 ASSERT_OK(Merge("c", "y2")); in TEST_P()
[all …]
Dmerge_operator.cc62 if (!Merge(merge_in.key, existing_value, operand, &temp_value, in FullMergeV2()
83 return Merge(key, &left_operand, right_operand, new_value, logger); in PartialMerge()
Dwrite_batch_test.cc349 batch.Merge(Slice("foo"), Slice("bar")); in TEST_F()
366 batch.Merge(Slice("foo"), Slice("bar")); in TEST_F()
567 batch.Merge(Slice("foo"), Slice("bar")); in TEST_F()
630 batch.Merge(&three, Slice("threethree"), Slice("3three")); in TEST_F()
632 batch.Merge(Slice("omom"), Slice("nom")); in TEST_F()
658 batch.Merge(&three, Slice("threethree"), Slice("3three")); in TEST_F()
660 batch.Merge(Slice("omom"), Slice("nom")); in TEST_F()
Dcompacted_db_impl.h44 using DBImpl::Merge;
45 virtual Status Merge(const WriteOptions& /*options*/, in Merge() function
/rocksdb-6.9/examples/
Dcompaction_filter_example.cc77 db->Merge(wopts, "0", "bad"); // This is filtered out in main()
78 db->Merge(wopts, "1", "data1"); in main()
79 db->Merge(wopts, "1", "bad"); in main()
80 db->Merge(wopts, "1", "data2"); in main()
81 db->Merge(wopts, "1", "bad"); in main()
82 db->Merge(wopts, "3", "data3"); in main()
/rocksdb-6.9/include/rocksdb/
Dwrite_batch.h126 using WriteBatchBase::Merge;
129 Status Merge(ColumnFamilyHandle* column_family, const Slice& key,
131 Status Merge(const Slice& key, const Slice& value) override { in Merge() function
132 return Merge(nullptr, key, value); in Merge()
136 Status Merge(ColumnFamilyHandle* column_family, const SliceParts& key,
138 Status Merge(const SliceParts& key, const SliceParts& value) override { in Merge() function
139 return Merge(nullptr, key, value); in Merge()
230 Merge(key, value); in MergeCF()
236 virtual void Merge(const Slice& /*key*/, const Slice& /*value*/) {} in Merge() function
Dwrite_batch_base.h44 virtual Status Merge(ColumnFamilyHandle* column_family, const Slice& key,
46 virtual Status Merge(const Slice& key, const Slice& value) = 0;
49 virtual Status Merge(ColumnFamilyHandle* column_family, const SliceParts& key,
51 virtual Status Merge(const SliceParts& key, const SliceParts& value);
/rocksdb-6.9/utilities/cassandra/
Dcassandra_row_merge_test.cc14 TEST(RowValueMergeTest, Merge) { in TEST() argument
42 RowValue merged = RowValue::Merge(std::move(row_values)); in TEST()
84 RowValue merged = RowValue::Merge(std::move(row_values)); in TEST()
101 merged = RowValue::Merge(std::move(row_values)); in TEST()
Dmerge_operator.cc36 RowValue merged = RowValue::Merge(std::move(row_values)); in FullMergeV2()
55 RowValue merged = RowValue::Merge(std::move(row_values)); in PartialMergeMulti()
Dformat.h173 static RowValue Merge(std::vector<RowValue>&& values);
183 FRIEND_TEST(RowValueMergeTest, Merge);
/rocksdb-6.9/monitoring/
Dhistogram_windowing.cc66 void HistogramWindowingImpl::Merge(const Histogram& other) { in Merge() function in ROCKSDB_NAMESPACE::HistogramWindowingImpl
68 Merge( in Merge()
74 void HistogramWindowingImpl::Merge(const HistogramWindowingImpl& other) { in Merge() function in ROCKSDB_NAMESPACE::HistogramWindowingImpl
76 stats_.Merge(other.stats_); in Merge()
95 window_stats_[windex].Merge( in Merge()
Dhistogram.h64 void Merge(const HistogramStat& other);
104 virtual void Merge(const Histogram&) = 0;
128 virtual void Merge(const Histogram& other) override;
129 void Merge(const HistogramImpl& other);
Dhistogram.cc111 void HistogramStat::Merge(const HistogramStat& other) { in Merge() function in ROCKSDB_NAMESPACE::HistogramStat
252 void HistogramImpl::Merge(const Histogram& other) { in Merge() function in ROCKSDB_NAMESPACE::HistogramImpl
254 Merge( in Merge()
259 void HistogramImpl::Merge(const HistogramImpl& other) { in Merge() function in ROCKSDB_NAMESPACE::HistogramImpl
261 stats_.Merge(other.stats_); in Merge()
Dhistogram_windowing.h33 virtual void Merge(const Histogram& other) override;
34 void Merge(const HistogramWindowingImpl& other);
/rocksdb-6.9/db/blob/
Ddb_blob_index_test.cc193 ASSERT_OK(Merge("key2", "a")); in TEST_F()
194 ASSERT_OK(Merge("key2", "b")); in TEST_F()
195 ASSERT_OK(Merge("key2", "c")); in TEST_F()
199 ASSERT_OK(Merge("key5", "a")); in TEST_F()
200 ASSERT_OK(Merge("key5", "b")); in TEST_F()
201 ASSERT_OK(Merge("key5", "c")); in TEST_F()
348 ASSERT_OK(Merge(key, value)); in TEST_F()
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index_test.cc406 batch.Merge(&cf1, "ddd", ""); in TEST_F()
969 batch.Merge("z", "z"); in TEST_F()
1002 batch.Merge("x", ToString(i)); in TEST_F()
1009 batch.Merge("z", "z"); in TEST_F()
1170 batch.Merge("a", "a1"); in TEST_F()
1171 batch.Merge("a", "a2"); in TEST_F()
1172 batch.Merge("b", "b2"); in TEST_F()
1173 batch.Merge("d", "d1"); in TEST_F()
1174 batch.Merge("e", "e0"); in TEST_F()
1286 batch.Merge("A", "xxx"); in TEST_F()
[all …]
/rocksdb-6.9/utilities/merge_operators/
Dsortlist.cc22 left = Merge(left, right); in FullMergeV2()
38 left = Merge(left, right); in PartialMerge()
65 std::vector<int> SortList::Merge(std::vector<int>& left, in Merge() function in ROCKSDB_NAMESPACE::SortList
/rocksdb-6.9/include/rocksdb/utilities/
Dwrite_batch_with_index.h112 using WriteBatchBase::Merge;
113 Status Merge(ColumnFamilyHandle* column_family, const Slice& key,
116 Status Merge(const Slice& key, const Slice& value) override;
/rocksdb-6.9/db/db_impl/
Ddb_impl_readonly.h48 using DBImpl::Merge;
49 virtual Status Merge(const WriteOptions& /*options*/, in Merge() function
/rocksdb-6.9/utilities/ttl/
Ddb_ttl_impl.cc262 Status DBWithTTLImpl::Merge(const WriteOptions& options, in Merge() function in ROCKSDB_NAMESPACE::DBWithTTLImpl
266 batch.Merge(column_family, key, value); in Merge()
295 WriteBatchInternal::Merge(&updates_ttl, column_family_id, key, in Write()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_stat.h79 void Merge(const Stats& other) { in Merge() function
80 hist_.Merge(other.hist_); in Merge()
/rocksdb-6.9/utilities/transactions/
Dtransaction_base.h136 Status Merge(ColumnFamilyHandle* column_family, const Slice& key,
138 Status Merge(const Slice& key, const Slice& value) override { in Merge() function
139 return Merge(nullptr, key, value); in Merge()

1234