| /rocksdb-6.9/java/samples/src/main/java/ |
| D | OptimisticTransactionSample.java | 61 final byte key1[] = "abc".getBytes(UTF_8); in readCommitted()
70 byte[] value = txn.get(readOptions, key1); in readCommitted()
74 txn.put(key1, value1); in readCommitted()
77 value = txnDb.get(readOptions, key1); in readCommitted()
97 final byte key1[] = "ghi".getBytes(UTF_8); in repeatableRead()
109 txnDb.put(writeOptions, key1, value1); in repeatableRead()
113 final byte[] value = txn.getForUpdate(readOptions, key1, true); in repeatableRead()
|
| D | TransactionSample.java | 62 final byte key1[] = "abc".getBytes(UTF_8); in readCommitted()
71 byte[] value = txn.get(readOptions, key1); in readCommitted()
75 txn.put(key1, value1); in readCommitted()
78 value = txnDb.get(readOptions, key1); in readCommitted()
98 final byte key1[] = "ghi".getBytes(UTF_8); in repeatableRead()
110 txnDb.put(writeOptions, key1, value1); in repeatableRead()
117 final byte[] value = txn.getForUpdate(readOptions, key1, true); in repeatableRead()
|
| /rocksdb-6.9/utilities/write_batch_with_index/ |
| D | write_batch_with_index_internal.cc | 118 Slice key1, key2; in operator ()() local
120 key1 = Slice(write_batch_->Data().data() + entry1->key_offset, in operator ()()
123 key1 = *(entry1->search_key); in operator ()()
132 int cmp = CompareKey(entry1->column_family, key1, key2); in operator ()()
144 const Slice& key1, in CompareKey() argument
148 return cf_comparators_[column_family]->Compare(key1, key2); in CompareKey()
150 return default_comparator_->Compare(key1, key2); in CompareKey()
|
| D | write_batch_with_index_internal.h | 106 int CompareKey(uint32_t column_family, const Slice& key1,
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | CompactionFilterFactoryTest.java | 46 final byte[] key1 = "key1".getBytes(); in columnFamilyOptions_setCompactionFilterFactory()
52 rocksDb.put(cfHandles.get(1), key1, value1); in columnFamilyOptions_setCompactionFilterFactory()
57 assertThat(rocksDb.get(cfHandles.get(1), key1)).isEqualTo(value1); in columnFamilyOptions_setCompactionFilterFactory()
|
| D | BlockBasedTableConfigTest.java | 169 final byte[] key1 = "some-key1".getBytes(StandardCharsets.UTF_8); in blockCacheCompressedIntegration()
196 db.put(writeOptions, key1, value); in blockCacheCompressedIntegration()
202 db.get(readOptions, key1); in blockCacheCompressedIntegration()
|
| D | RocksDBTest.java | 1176 final byte key1[] = "key1".getBytes(UTF_8); in getApproximateSizes()
1182 db.put(key1, key1); in getApproximateSizes()
1188 new Range(new Slice(key1), new Slice(key2)), in getApproximateSizes()
1203 final byte key1[] = "key1".getBytes(UTF_8); in getApproximateMemTableStats()
1209 db.put(key1, key1); in getApproximateMemTableStats()
1215 new Range(new Slice(key1), new Slice(key3))); in getApproximateMemTableStats()
|
| /rocksdb-6.9/docs/_docs/ |
| D | getting-started.md | 61 …/query the database. For example, the following code moves the value stored under `key1` to `key2`.
65 rocksdb::Status s = db->Get(rocksdb::ReadOptions(), key1, &value);
67 if (s.ok()) s = db->Delete(rocksdb::WriteOptions(), key1);
|
| /rocksdb-6.9/utilities/simulator_cache/ |
| D | cache_simulator_test.cc | 97 const std::string key1 = "test1"; in TEST_F() local
103 EXPECT_FALSE(ghost_cache->Admit(key1)); in TEST_F()
104 EXPECT_TRUE(ghost_cache->Admit(key1)); in TEST_F()
105 EXPECT_TRUE(ghost_cache->Admit(key1)); in TEST_F()
|
| /rocksdb-6.9/db/ |
| D | db_bloom_filter_test.cc | 976 std::string key1("AAAABBBB"); in TEST_F() local
984 ASSERT_OK(Put(key1, value1, WriteOptions())); in TEST_F()
1099 std::string key1("AAAA"); in TEST_P() local
1105 ASSERT_OK(Put(key1, value1, WriteOptions())); in TEST_P()
1109 ASSERT_EQ(value1, Get(key1)); in TEST_P()
1130 ASSERT_EQ(value1, Get(key1)); in TEST_P()
1141 std::string key1("AAAA"); in TEST_P() local
1147 ASSERT_OK(Put(key1, value1, WriteOptions())); in TEST_P()
1153 iter->Seek(key1); in TEST_P()
1178 iter->Seek(key1); in TEST_P()
|
| D | db_test.cc | 707 std::string key1(kKeySize, 'c'); in TEST_F() local
718 ASSERT_OK(Put(key1, raw)); in TEST_F()
728 Status s = db_->Get(ReadOptions(), key1, &value); in TEST_F()
745 s = db_->Get(ReadOptions(), key1, &value); in TEST_F()
5140 int key1 = key_start + 1; in TEST_F() local
5145 ASSERT_OK(Put(Key(key1), RandomString(&rnd, 8))); in TEST_F()
5149 iter->Seek(Key(key1)); in TEST_F()
5151 ASSERT_EQ(iter->key().compare(Key(key1)), 0); in TEST_F()
|
| /rocksdb-6.9/db_stress_tool/ |
| D | db_stress_test_base.cc | 1273 int64_t key1 = rand_keys[0]; in TestApproximateSize() local
1278 if (key2 < key1) { in TestApproximateSize()
1279 std::swap(key1, key2); in TestApproximateSize()
1285 key2 = key1 + static_cast<int64_t>(thread->rand.Uniform(1000)); in TestApproximateSize()
1287 std::string key1_str = Key(key1); in TestApproximateSize()
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2015-02-27-write-batch-with-index.markdown | 16 …s can buffer their updates to a `WriteBatch` by calling `write_batch.Put("key1", "value1")` or `wr…
|