Home
last modified time | relevance | path

Searched refs:ColumnFamilyHandle (Results 1 – 25 of 166) sorted by relevance

1234567

/rocksdb-6.9/include/rocksdb/
Ddb.h74 class ColumnFamilyHandle {
76 virtual ~ColumnFamilyHandle() {} in ~ColumnFamilyHandle()
526 std::vector<ColumnFamilyHandle*> cf;
548 std::vector<ColumnFamilyHandle*> cf;
590 std::vector<ColumnFamilyHandle*> cf;
610 std::vector<ColumnFamilyHandle*> cf;
1123 ColumnFamilyHandle* column_family,
1366 ColumnFamilyHandle* column_family,
1413 ColumnFamilyHandle** handle) = 0;
1421 ColumnFamilyHandle* column_family,
[all …]
Dwrite_batch_base.h19 class ColumnFamilyHandle; variable
31 virtual Status Put(ColumnFamilyHandle* column_family, const Slice& key,
38 virtual Status Put(ColumnFamilyHandle* column_family, const SliceParts& key,
44 virtual Status Merge(ColumnFamilyHandle* column_family, const Slice& key,
49 virtual Status Merge(ColumnFamilyHandle* column_family, const SliceParts& key,
54 virtual Status Delete(ColumnFamilyHandle* column_family,
59 virtual Status Delete(ColumnFamilyHandle* column_family,
65 virtual Status SingleDelete(ColumnFamilyHandle* column_family,
70 virtual Status SingleDelete(ColumnFamilyHandle* column_family,
76 virtual Status DeleteRange(ColumnFamilyHandle* column_family,
[all …]
Dwrite_batch.h38 class ColumnFamilyHandle; variable
69 Status Put(ColumnFamilyHandle* column_family, const Slice& key,
78 Status Put(ColumnFamilyHandle* column_family, const SliceParts& key,
86 Status Delete(ColumnFamilyHandle* column_family, const Slice& key) override;
90 Status Delete(ColumnFamilyHandle* column_family,
96 Status SingleDelete(ColumnFamilyHandle* column_family,
103 Status SingleDelete(ColumnFamilyHandle* column_family,
111 Status DeleteRange(ColumnFamilyHandle* column_family, const Slice& begin_key,
118 Status DeleteRange(ColumnFamilyHandle* column_family,
129 Status Merge(ColumnFamilyHandle* column_family, const Slice& key,
[all …]
/rocksdb-6.9/include/rocksdb/utilities/
Dstackable_db.h53 std::vector<ColumnFamilyHandle*>* handles) override { in CreateColumnFamilies()
59 std::vector<ColumnFamilyHandle*>* handles) override { in CreateColumnFamilies()
73 ColumnFamilyHandle* column_family) override { in DestroyColumnFamilyHandle()
112 ColumnFamilyHandle* column_family,
122 ColumnFamilyHandle* column_family, in IngestExternalFile()
139 ColumnFamilyHandle** handle) override { in CreateColumnFamilyWithImport()
160 ColumnFamilyHandle* column_family, in Delete()
252 ColumnFamilyHandle* column_family,
288 ColumnFamilyHandle* column_family) override { in MaxMemCompactionLevel()
294 ColumnFamilyHandle* column_family) override { in Level0StopWriteTrigger()
[all …]
Dtransaction.h205 const std::vector<ColumnFamilyHandle*>& column_family,
216 ColumnFamilyHandle* column_family,
254 ColumnFamilyHandle* column_family,
262 ColumnFamilyHandle* column_family,
284 const std::vector<ColumnFamilyHandle*>& column_family,
345 virtual Status Delete(ColumnFamilyHandle* column_family,
350 virtual Status SingleDelete(ColumnFamilyHandle* column_family,
354 virtual Status SingleDelete(ColumnFamilyHandle* column_family,
367 virtual Status PutUntracked(ColumnFamilyHandle* column_family,
370 virtual Status PutUntracked(ColumnFamilyHandle* column_family,
[all …]
Dwrite_batch_with_index.h28 class ColumnFamilyHandle; variable
107 Status Put(ColumnFamilyHandle* column_family, const Slice& key,
113 Status Merge(ColumnFamilyHandle* column_family, const Slice& key,
119 Status Delete(ColumnFamilyHandle* column_family, const Slice& key) override;
123 Status SingleDelete(ColumnFamilyHandle* column_family,
128 Status DeleteRange(ColumnFamilyHandle* /* column_family */, in DeleteRange() argument
156 WBWIIterator* NewIterator(ColumnFamilyHandle* column_family);
175 Iterator* NewIteratorWithBase(ColumnFamilyHandle* column_family,
184 Status GetFromBatch(ColumnFamilyHandle* column_family,
223 ColumnFamilyHandle* column_family,
[all …]
/rocksdb-6.9/utilities/transactions/
Dtransaction_base.h87 const std::vector<ColumnFamilyHandle*>& column_family,
94 return MultiGet(options, std::vector<ColumnFamilyHandle*>( in MultiGet()
106 const std::vector<ColumnFamilyHandle*>& column_family,
114 std::vector<ColumnFamilyHandle*>( in MultiGetForUpdate()
121 ColumnFamilyHandle* column_family) override;
123 Status Put(ColumnFamilyHandle* column_family, const Slice& key,
136 Status Merge(ColumnFamilyHandle* column_family, const Slice& key,
178 Status DeleteUntracked(ColumnFamilyHandle* column_family,
183 Status DeleteUntracked(ColumnFamilyHandle* column_family,
189 Status SingleDeleteUntracked(ColumnFamilyHandle* column_family,
[all …]
Dwrite_unprepared_txn.h121 virtual Status Put(ColumnFamilyHandle* column_family, const Slice& key,
124 virtual Status Put(ColumnFamilyHandle* column_family, const SliceParts& key,
129 virtual Status Merge(ColumnFamilyHandle* column_family, const Slice& key,
134 virtual Status Delete(ColumnFamilyHandle* column_family, const Slice& key,
136 virtual Status Delete(ColumnFamilyHandle* column_family,
141 virtual Status SingleDelete(ColumnFamilyHandle* column_family,
144 virtual Status SingleDelete(ColumnFamilyHandle* column_family,
189 ColumnFamilyHandle* column_family, const Slice& key,
194 ColumnFamilyHandle* column_family,
202 ColumnFamilyHandle* column_family) override;
[all …]
Dpessimistic_transaction_db.h43 const std::vector<ColumnFamilyHandle*>& handles);
51 ColumnFamilyHandle* column_family, const Slice& key,
56 ColumnFamilyHandle* column_family,
61 ColumnFamilyHandle* column_family,
66 ColumnFamilyHandle* column_family, const Slice& key,
95 ColumnFamilyHandle** handle) override;
98 virtual Status DropColumnFamily(ColumnFamilyHandle* column_family) override;
107 void AddColumnFamily(const ColumnFamilyHandle* handle);
143 virtual void UpdateCFComparatorMap(const std::vector<ColumnFamilyHandle*>&) {} in UpdateCFComparatorMap() argument
144 virtual void UpdateCFComparatorMap(ColumnFamilyHandle*) {} in UpdateCFComparatorMap() argument
Dtransaction_base.cc101 Status TransactionBaseImpl::TryLock(ColumnFamilyHandle* column_family, in TryLock()
242 ColumnFamilyHandle* column_family, in Get()
255 ColumnFamilyHandle* column_family, in Get()
308 const std::vector<ColumnFamilyHandle*>& column_family, in MultiGet()
323 ColumnFamilyHandle* column_family, in MultiGet()
334 const std::vector<ColumnFamilyHandle*>& column_family, in MultiGetForUpdate()
376 Status TransactionBaseImpl::Put(ColumnFamilyHandle* column_family, in Put()
393 Status TransactionBaseImpl::Put(ColumnFamilyHandle* column_family, in Put()
410 Status TransactionBaseImpl::Merge(ColumnFamilyHandle* column_family, in Merge()
427 Status TransactionBaseImpl::Delete(ColumnFamilyHandle* column_family, in Delete()
[all …]
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DRocksDB.java204 final List<ColumnFamilyHandle> columnFamilyHandles) in open()
282 final List<ColumnFamilyHandle> columnFamilyHandles) in open()
505 public ColumnFamilyHandle createColumnFamily( in createColumnFamily()
525 public List<ColumnFamilyHandle> createColumnFamilies( in createColumnFamilies()
532 final List<ColumnFamilyHandle> columnFamilyHandles = in createColumnFamilies()
550 public List<ColumnFamilyHandle> createColumnFamilies( in createColumnFamilies()
2454 final ColumnFamilyHandle columnFamilyHandle, in keyMayExist()
2542 final ColumnFamilyHandle columnFamilyHandle, in keyMayExist()
2575 final ColumnFamilyHandle columnFamilyHandle, in keyMayExist()
2653 final ColumnFamilyHandle columnFamilyHandle) { in newIterator()
[all …]
DTransaction.java273 public byte[] get(final ColumnFamilyHandle columnFamilyHandle, in get()
340 final List<ColumnFamilyHandle> columnFamilyHandles, in multiGet()
545 final List<ColumnFamilyHandle> columnFamilyHandles, in multiGetForUpdate()
636 final ColumnFamilyHandle columnFamilyHandle) { in getIterator()
755 public void put(final ColumnFamilyHandle columnFamilyHandle, in put()
777 public void put(final ColumnFamilyHandle columnFamilyHandle, in put()
832 public void merge(final ColumnFamilyHandle columnFamilyHandle, in merge()
865 public void merge(final ColumnFamilyHandle columnFamilyHandle, in merge()
927 public void delete(final ColumnFamilyHandle columnFamilyHandle, in delete()
958 public void delete(final ColumnFamilyHandle columnFamilyHandle, in delete()
[all …]
DWriteBatchInterface.java42 void put(ColumnFamilyHandle columnFamilyHandle, in put()
69 void put(ColumnFamilyHandle columnFamilyHandle, ByteBuffer key, ByteBuffer value) in put()
93 void merge(ColumnFamilyHandle columnFamilyHandle, in merge()
117 void remove(ColumnFamilyHandle columnFamilyHandle, byte[] key) in remove()
135 void delete(ColumnFamilyHandle columnFamilyHandle, byte[] key) in delete()
185 void singleDelete(final ColumnFamilyHandle columnFamilyHandle, in singleDelete()
205 void remove(ColumnFamilyHandle columnFamilyHandle, ByteBuffer key) throws RocksDBException; in remove()
240 void deleteRange(ColumnFamilyHandle columnFamilyHandle, byte[] beginKey, in deleteRange()
DAbstractWriteBatch.java28 public void put(ColumnFamilyHandle columnFamilyHandle, byte[] key, in put()
40 public void merge(ColumnFamilyHandle columnFamilyHandle, byte[] key, in merge()
54 public void remove(ColumnFamilyHandle columnFamilyHandle, byte[] key) in remove()
68 public void put(ColumnFamilyHandle columnFamilyHandle, ByteBuffer key, ByteBuffer value) in put()
83 public void delete(ColumnFamilyHandle columnFamilyHandle, byte[] key) in delete()
95 public void singleDelete(ColumnFamilyHandle columnFamilyHandle, byte[] key) in singleDelete()
107 public void deleteRange(ColumnFamilyHandle columnFamilyHandle, in deleteRange()
119 public void remove(ColumnFamilyHandle columnFamilyHandle, ByteBuffer key) in remove()
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DColumnFamilyTest.java134 final List<ColumnFamilyHandle> columnFamilyHandleList = in openWithColumnFamilies()
166 for (final ColumnFamilyHandle columnFamilyHandle : in openWithColumnFamilies()
206 for (final ColumnFamilyHandle columnFamilyHandle : in getWithOutValueAndCf()
226 ColumnFamilyHandle tmpColumnFamilyHandle = null; in createWriteDropColumnFamily()
257 ColumnFamilyHandle tmpColumnFamilyHandle = null; in createWriteDropColumnFamilies()
258 ColumnFamilyHandle tmpColumnFamilyHandle2 = null; in createWriteDropColumnFamilies()
371 for (final ColumnFamilyHandle columnFamilyHandle : in iteratorOnColumnFamily()
415 for (final ColumnFamilyHandle columnFamilyHandle : in multiGet()
459 for (final ColumnFamilyHandle columnFamilyHandle : in multiGetAsList()
688 ColumnFamilyHandle cf1 = null, cf2 = null; in testCFNamesWithZeroBytes()
[all …]
DReadOnlyTest.java90 for (final ColumnFamilyHandle columnFamilyHandle : in readOnlyOpen()
97 for (final ColumnFamilyHandle columnFamilyHandle : in readOnlyOpen()
104 for (final ColumnFamilyHandle columnFamilyHandle : in readOnlyOpen()
129 final List<ColumnFamilyHandle> readOnlyColumnFamilyHandleList = in failToWriteInReadOnly()
138 for (final ColumnFamilyHandle columnFamilyHandle : in failToWriteInReadOnly()
159 final List<ColumnFamilyHandle> readOnlyColumnFamilyHandleList = in failToCFWriteInReadOnly()
168 for (final ColumnFamilyHandle columnFamilyHandle : in failToCFWriteInReadOnly()
199 for (final ColumnFamilyHandle columnFamilyHandle : in failToRemoveInReadOnly()
230 for (final ColumnFamilyHandle columnFamilyHandle : in failToCFRemoveInReadOnly()
263 for (final ColumnFamilyHandle columnFamilyHandle : in failToWriteBatchReadOnly()
[all …]
/rocksdb-6.9/db/db_impl/
Ddb_impl.h296 ColumnFamilyHandle* column_family,
313 ColumnFamilyHandle* column_family,
325 ColumnFamilyHandle* column_family) override;
401 Status PromoteL0(ColumnFamilyHandle* column_family,
406 ColumnFamilyHandle* column_family,
419 ColumnFamilyHandle** handle) override;
442 ColumnFamilyHandle* column_family,
453 ColumnFamilyHandle* column_family = nullptr;
586 ColumnFamilyHandle* column_family = nullptr);
907 ColumnFamilyHandle* column_family = nullptr);
[all …]
Ddb_impl_readonly.h28 ColumnFamilyHandle* column_family, const Slice& key,
35 ColumnFamilyHandle* column_family) override;
39 const std::vector<ColumnFamilyHandle*>& column_families,
44 ColumnFamilyHandle* /*column_family*/, in Put() argument
50 ColumnFamilyHandle* /*column_family*/, in Merge() argument
56 ColumnFamilyHandle* /*column_family*/, in Delete() argument
62 ColumnFamilyHandle* /*column_family*/, in SingleDelete() argument
72 ColumnFamilyHandle* /*column_family*/, in CompactRange() argument
81 ColumnFamilyHandle* /*column_family*/,
116 ColumnFamilyHandle* /*column_family*/, in IngestExternalFile() argument
[all …]
Ddb_impl_secondary.h86 Status Get(const ReadOptions& options, ColumnFamilyHandle* column_family,
94 ColumnFamilyHandle* column_family) override;
107 ColumnFamilyHandle* /*column_family*/, const Slice& /*key*/, in Put() argument
114 ColumnFamilyHandle* /*column_family*/, const Slice& /*key*/, in Merge() argument
121 ColumnFamilyHandle* /*column_family*/, in Delete() argument
128 ColumnFamilyHandle* /*column_family*/, in SingleDelete() argument
140 ColumnFamilyHandle* /*column_family*/, in CompactRange() argument
148 ColumnFamilyHandle* /*column_family*/,
172 ColumnFamilyHandle* /*column_family*/) override { in Flush() argument
186 ColumnFamilyHandle* /*cfd*/, in SetOptions() argument
[all …]
/rocksdb-6.9/utilities/blob_db/
Dblob_db.h90 ColumnFamilyHandle* column_family, const Slice& key, in Put()
101 ColumnFamilyHandle* column_family, in Delete()
128 ColumnFamilyHandle* column_family, const Slice& key, in PutUntil()
139 ColumnFamilyHandle* column_family, const Slice& key,
144 ColumnFamilyHandle* column_family, const Slice& key,
158 const std::vector<ColumnFamilyHandle*>& column_families, in MultiGet()
172 ColumnFamilyHandle* /*column_family*/,
184 ColumnFamilyHandle* /*column_family*/, in SingleDelete() argument
191 ColumnFamilyHandle* /*column_family*/, in Merge() argument
217 ColumnFamilyHandle* column_family,
[all …]
/rocksdb-6.9/db/
Dcompacted_db_impl.h29 ColumnFamilyHandle* column_family, const Slice& key,
34 const std::vector<ColumnFamilyHandle*>&,
40 ColumnFamilyHandle* /*column_family*/, in Put() argument
46 ColumnFamilyHandle* /*column_family*/, in Merge() argument
52 ColumnFamilyHandle* /*column_family*/, in Delete() argument
62 ColumnFamilyHandle* /*column_family*/, in CompactRange() argument
82 ColumnFamilyHandle* /*column_family*/) override { in Flush() argument
87 ColumnFamilyHandle* /*column_family*/, in IngestExternalFile() argument
98 ColumnFamilyHandle** /*handle*/) override { in CreateColumnFamilyWithImport() argument
/rocksdb-6.9/java/rocksjni/
Drocksjni.cc283 ROCKSDB_NAMESPACE::ColumnFamilyHandle* cf_handle; in Java_org_rocksdb_RocksDB_createColumnFamily()
1821 ROCKSDB_NAMESPACE::ColumnFamilyHandle* cf_handle; in key_may_exist_helper()
2126 ROCKSDB_NAMESPACE::ColumnFamilyHandle* cf_handle; in Java_org_rocksdb_RocksDB_getProperty()
2163 ROCKSDB_NAMESPACE::ColumnFamilyHandle* cf_handle; in Java_org_rocksdb_RocksDB_getMapProperty()
2200 ROCKSDB_NAMESPACE::ColumnFamilyHandle* cf_handle; in Java_org_rocksdb_RocksDB_getLongProperty()
2287 ROCKSDB_NAMESPACE::ColumnFamilyHandle* cf_handle; in Java_org_rocksdb_RocksDB_getApproximateSizes()
2339 ROCKSDB_NAMESPACE::ColumnFamilyHandle* cf_handle; in Java_org_rocksdb_RocksDB_getApproximateMemTableStats()
2423 ROCKSDB_NAMESPACE::ColumnFamilyHandle* cf_handle; in Java_org_rocksdb_RocksDB_compactRange()
2586 ROCKSDB_NAMESPACE::ColumnFamilyHandle* cf_handle; in Java_org_rocksdb_RocksDB_compactFiles()
2669 ROCKSDB_NAMESPACE::ColumnFamilyHandle* cf_handle; in Java_org_rocksdb_RocksDB_numberLevels()
[all …]
Dtransaction.cc221 ROCKSDB_NAMESPACE::ColumnFamilyHandle*, in Java_org_rocksdb_Transaction_get__JJ_3BIJ()
445 ROCKSDB_NAMESPACE::ColumnFamilyHandle*, in Java_org_rocksdb_Transaction_getForUpdate__JJ_3BIJZZ()
605 ROCKSDB_NAMESPACE::ColumnFamilyHandle*, in Java_org_rocksdb_Transaction_put__J_3BI_3BIJZ()
748 ROCKSDB_NAMESPACE::ColumnFamilyHandle*, in Java_org_rocksdb_Transaction_put__J_3_3BI_3_3BIJZ()
789 ROCKSDB_NAMESPACE::ColumnFamilyHandle*, in Java_org_rocksdb_Transaction_merge__J_3BI_3BIJZ()
854 ROCKSDB_NAMESPACE::ColumnFamilyHandle*, in Java_org_rocksdb_Transaction_delete__J_3BIJZ()
949 ROCKSDB_NAMESPACE::ColumnFamilyHandle*, in Java_org_rocksdb_Transaction_delete__J_3_3BIJZ()
986 ROCKSDB_NAMESPACE::ColumnFamilyHandle*, in Java_org_rocksdb_Transaction_singleDelete__J_3BIJZ()
1025 ROCKSDB_NAMESPACE::ColumnFamilyHandle*, in Java_org_rocksdb_Transaction_singleDelete__J_3_3BIJZ()
1066 ROCKSDB_NAMESPACE::ColumnFamilyHandle*, in Java_org_rocksdb_Transaction_putUntracked__J_3BI_3BIJ()
[all …]
/rocksdb-6.9/db_stress_tool/
Ddb_stress_test_base.h42 Status AssertSame(DB* db, ColumnFamilyHandle* cf,
111 ColumnFamilyHandle* column_family);
116 ColumnFamilyHandle* column_family,
122 virtual ColumnFamilyHandle* GetControlCfh(ThreadState* /* thread*/, in GetControlCfh()
131 ColumnFamilyHandle* cfh,
135 ColumnFamilyHandle*, size_t) { in GetWhiteBoxKeys() argument
163 void VerifyIterator(ThreadState* thread, ColumnFamilyHandle* cmp_cfh,
176 void TestCompactFiles(ThreadState* thread, ColumnFamilyHandle* column_family);
216 std::vector<ColumnFamilyHandle*> column_families_;
226 std::vector<std::vector<ColumnFamilyHandle*>> secondary_cfh_lists_;
[all …]
/rocksdb-6.9/utilities/ttl/
Ddb_ttl_impl.cc78 std::vector<ColumnFamilyHandle*> handles; in Open()
93 std::vector<ColumnFamilyHandle*>* handles, DBWithTTL** dbptr, in Open()
127 ColumnFamilyHandle** handle, int ttl) { in CreateColumnFamilyWithTtl()
137 ColumnFamilyHandle** handle) { in CreateColumnFamily()
210 ColumnFamilyHandle* column_family, const Slice& key, in Put()
218 ColumnFamilyHandle* column_family, const Slice& key, in Get()
233 const std::vector<ColumnFamilyHandle*>& column_family, in MultiGet()
250 ColumnFamilyHandle* column_family, in KeyMayExist()
263 ColumnFamilyHandle* column_family, const Slice& key, in Merge()
319 ColumnFamilyHandle* column_family) { in NewIterator()
[all …]

1234567