Home
last modified time | relevance | path

Searched refs:RowValue (Results 1 – 9 of 9) sorted by relevance

/rocksdb-6.9/utilities/cassandra/
Dformat.h148 class RowValue {
153 RowValue(Columns columns,
155 RowValue(const RowValue& /*that*/) = delete;
156 RowValue(RowValue&& /*that*/) noexcept = default;
157 RowValue& operator=(const RowValue& /*that*/) = delete;
158 RowValue& operator=(RowValue&& /*that*/) = default;
166 RowValue RemoveExpiredColumns(bool* changed) const;
167 RowValue ConvertExpiredColumnsToTombstones(bool* changed) const;
168 RowValue RemoveTombstones(int32_t gc_grace_period) const;
171 static RowValue Deserialize(const char* src, std::size_t size);
[all …]
Dformat.cc205 RowValue::RowValue(int32_t local_deletion_time, int64_t marked_for_delete_at) in RowValue() function in ROCKSDB_NAMESPACE::cassandra::RowValue
210 RowValue::RowValue(Columns columns, in RowValue() function in ROCKSDB_NAMESPACE::cassandra::RowValue
216 std::size_t RowValue::Size() const { in Size()
233 bool RowValue::IsTombstone() const { in IsTombstone()
245 RowValue RowValue::RemoveExpiredColumns(bool* changed) const { in RemoveExpiredColumns()
264 RowValue RowValue::ConvertExpiredColumnsToTombstones(bool* changed) const { in ConvertExpiredColumnsToTombstones()
284 RowValue RowValue::RemoveTombstones(int32_t gc_grace_period) const { in RemoveTombstones()
301 bool RowValue::Empty() const { in Empty()
305 RowValue RowValue::Deserialize(const char *src, std::size_t size) { in Deserialize()
338 RowValue RowValue::Merge(std::vector<RowValue>&& values) { in Merge()
[all …]
Dmerge_operator.cc25 std::vector<RowValue> row_values; in FullMergeV2()
28 RowValue::Deserialize(merge_in.existing_value->data(), in FullMergeV2()
33 row_values.push_back(RowValue::Deserialize(operand.data(), operand.size())); in FullMergeV2()
36 RowValue merged = RowValue::Merge(std::move(row_values)); in FullMergeV2()
51 std::vector<RowValue> row_values; in PartialMergeMulti()
53 row_values.push_back(RowValue::Deserialize(operand.data(), operand.size())); in PartialMergeMulti()
55 RowValue merged = RowValue::Merge(std::move(row_values)); in PartialMergeMulti()
Dcassandra_row_merge_test.cc15 std::vector<RowValue> row_values; in TEST()
42 RowValue merged = RowValue::Merge(std::move(row_values)); in TEST()
53 std::vector<RowValue> 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()
Dcassandra_functional_test.cc33 bool Append(const std::string& key, const RowValue& val){ in Append()
47 bool Put(const std::string& key, const RowValue& val) { in Put()
70 std::tuple<bool, RowValue> Get(const std::string& key){ in Get()
76 RowValue::Deserialize(result.data(), in Get()
84 return std::make_tuple(false, RowValue(0, 0)); in Get()
166 RowValue& merged = std::get<1>(ret); in TEST_F()
198 RowValue& merged = std::get<1>(ret); in TEST_F()
231 RowValue& merged = std::get<1>(ret); in TEST_F()
286 RowValue& gced = std::get<1>(ret); in TEST_F()
Dtest_utils.cc38 RowValue CreateTestRowValue( in CreateTestRowValue()
48 return RowValue(std::move(columns), last_modified_time); in CreateTestRowValue()
51 RowValue CreateRowTombstone(int64_t timestamp) { in CreateRowTombstone()
52 return RowValue(ToSeconds(timestamp), timestamp); in CreateRowTombstone()
Dcassandra_compaction_filter.cc23 RowValue row_value = RowValue::Deserialize( in FilterV2()
25 RowValue compacted = in FilterV2()
Dcassandra_format_test.cc190 RowValue r = RowValue(local_deletion_time, marked_for_delete_at); in TEST()
208 RowValue r1 = RowValue::Deserialize(dest.c_str(), r.Size()); in TEST()
248 RowValue r = RowValue(std::move(columns), last_modified_time); in TEST()
306 RowValue r1 = RowValue::Deserialize(dest.c_str(), r.Size()); in TEST()
Dtest_utils.h30 RowValue CreateTestRowValue(
33 RowValue CreateRowTombstone(int64_t timestamp);