Searched refs:writeBatch (Results 1 – 5 of 5) sorted by relevance
| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | ColumnFamilyTest.java | 286 public void writeBatch() throws RocksDBException { in writeBatch() method in ColumnFamilyTest
301 final WriteBatch writeBatch = new WriteBatch(); in writeBatch() argument
304 writeBatch.put("key".getBytes(), "value".getBytes()); in writeBatch()
305 writeBatch.put(db.getDefaultColumnFamily(), in writeBatch()
307 writeBatch.merge(db.getDefaultColumnFamily(), "mergeKey".getBytes(), in writeBatch()
309 writeBatch.put(columnFamilyHandleList.get(1), "newcfkey".getBytes(), in writeBatch()
311 writeBatch.put(columnFamilyHandleList.get(1), "newcfkey2".getBytes(), in writeBatch()
313 writeBatch.delete("xyz".getBytes()); in writeBatch()
314 writeBatch.delete(columnFamilyHandleList.get(1), "xyz".getBytes()); in writeBatch()
315 db.write(writeOpt, writeBatch); in writeBatch()
|
| D | AbstractTransactionTest.java | 709 final WriteBatchWithIndex writeBatch = txn.getWriteBatch(); in getWriteBatch() local
710 assertThat(writeBatch).isNotNull(); in getWriteBatch()
711 assertThat(writeBatch.isOwningHandle()).isFalse(); in getWriteBatch()
712 assertThat(writeBatch.count()).isEqualTo(1); in getWriteBatch()
801 try(final WriteBatch writeBatch = new WriteBatch()) { in rebuildFromWriteBatch() argument
802 writeBatch.put(k2, v2); in rebuildFromWriteBatch()
803 writeBatch.put(k3, v3); in rebuildFromWriteBatch()
804 txn.rebuildFromWriteBatch(writeBatch); in rebuildFromWriteBatch()
825 assertThat(writeBatch).isNotNull(); in getCommitTimeWriteBatch()
826 assertThat(writeBatch.isOwningHandle()).isFalse(); in getCommitTimeWriteBatch()
[all …]
|
| /rocksdb-6.9/tools/rdb/ |
| D | API.md | 91 db_obj.writeBatch(cf_batches)
152 db_obj.writeBatch([
165 db_obj.writeBatch([
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | Transaction.java | 1666 public void rebuildFromWriteBatch(final WriteBatch writeBatch) in rebuildFromWriteBatch() argument
1669 rebuildFromWriteBatch(nativeHandle_, writeBatch.nativeHandle_); in rebuildFromWriteBatch()
1679 final WriteBatch writeBatch = in getCommitTimeWriteBatch() local
1681 return writeBatch; in getCommitTimeWriteBatch()
|
| D | TransactionLogIterator.java | 98 public WriteBatch writeBatch() { in writeBatch() method in TransactionLogIterator.BatchResult
|