Home
last modified time | relevance | path

Searched refs:put (Results 1 – 25 of 100) sorted by relevance

1234

/rocksdb-6.9/tools/rdb/
Dunit_test.js59 assert.equal(a.put(1), false)
60 assert.equal(a.put(['a']), false)
61 assert.equal(a.put('a', 1), false)
62 assert.equal(a.put(1, 'a'), false)
63 assert.equal(a.put(1, 1), false)
76 assert.equal(a.put(), false)
77 assert.equal(a.put('a'), false)
80 assert(a.put('a', 'axe'))
81 assert(a.put('a', 'first'))
86 assert(a.put('a', 'apple', 'b'))
[all …]
DAPI.md43 # column_family (string) - Which column family to put the key-value pair
49 db_obj.put(key, value, column_family = { default })
138 * 'put' => Array of ['string1', 'string1'] pairs, each of which signifies that
154 put: [ ['firstname', 'Saghm'], ['lastname', 'Rossi'] ]
167 put: [ ['number_of_people', '2'] ],
171 put: [ ['name', 'Saghm Rossi'] ],
175 put: [ ['name', Matt Blaze'] ],
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DWriteBatchWithIndexTest.java42 db.put(k1, v1); in readYourOwnWrites()
43 db.put(k2, v2); in readYourOwnWrites()
61 wbwi.put(k3, v3); in readYourOwnWrites()
117 wbwi.put(k1, v1); in writeBatchWithIndex()
118 wbwi.put(k2, v2); in writeBatchWithIndex()
479 wbwi.put(k1, v1); in getFromBatch()
480 wbwi.put(k2, v2); in getFromBatch()
481 wbwi.put(k3, v3); in getFromBatch()
510 db.put(k1, v1); in getFromBatchAndDB()
511 db.put(k2, v2); in getFromBatchAndDB()
[all …]
DWriteBatchTest.java62 batch.put(foo, bar); in multipleBatchOperations()
64 batch.put(baz, boo); in multipleBatchOperations()
93 key.put("foo".getBytes("US-ASCII")).flip(); in multipleBatchOperationsDirect()
94 value.put("bar".getBytes("US-ASCII")).flip(); in multipleBatchOperationsDirect()
95 batch.put(key, value); in multipleBatchOperationsDirect()
102 key.put("box".getBytes("US-ASCII")).flip(); in multipleBatchOperationsDirect()
227 db.put("key4".getBytes(), "xyz".getBytes()); in deleteRange()
247 batch.put("k1".getBytes(), "v1".getBytes()); in restorePoints()
248 batch.put("k2".getBytes(), "v2".getBytes()); in restorePoints()
290 batch.put("k1".getBytes(), "v1".getBytes()); in popSavePoint()
[all …]
DRocksDBTest.java206 db.put(opt, key, value); in put()
255 rawKey.put((byte)0); in sliceSegment()
256 rawKey.put((byte)0); in sliceSegment()
257 rawKey.put(key.getBytes()); in sliceSegment()
388 db.put(key, valueSplit); in getOutOfArrayMaxSizeValue()
1182 db.put(key1, key1); in getApproximateSizes()
1183 db.put(key2, key2); in getApproximateSizes()
1184 db.put(key3, key3); in getApproximateSizes()
1209 db.put(key1, key1); in getApproximateMemTableStats()
1210 db.put(key2, key2); in getApproximateMemTableStats()
[all …]
DAbstractTransactionTest.java114 txn.put(k1, v1); in commit()
131 txn.put(k1, v1); in rollback()
154 txn.put(k1, v1); in savePoint()
160 txn.put(k2, v2); in savePoint()
202 txn.put(k1, v1); in getPut()
273 txn.put(k1, v1); in getForUpdate()
332 txn.put(k1, v1); in getIterator()
413 txn.put(k1, v1); in delete()
589 txn.put(k1, v1); in deleteUntracked()
674 txn.put(k1, v1); in numKeys()
[all …]
DColumnFamilyTest.java83 db.put(cfh, key, value); in defaultColumnFamily()
147 db.put("dfkey1".getBytes(), "dfvalue".getBytes()); in openWithColumnFamilies()
190 db.put("key2".getBytes(), "12345678".getBytes()); in getWithOutValueAndCf()
304 writeBatch.put("key".getBytes(), "value".getBytes()); in writeBatch()
305 writeBatch.put(db.getDefaultColumnFamily(), in writeBatch()
359 refMap.put("newcfkey", "value"); in iteratorOnColumnFamily()
360 refMap.put("newcfkey2", "value2"); in iteratorOnColumnFamily()
526 defRefMap.put("dfkey1", "dfvalue"); in iterators()
527 defRefMap.put("key", "value"); in iterators()
535 cfRefMap.put("newcfkey", "value"); in iterators()
[all …]
DOptimisticTransactionTest.java30 txn.put(testCf, k1, v1); in getForUpdate_cf_conflict()
40 txn2.put(testCf, k1, v12); in getForUpdate_cf_conflict()
67 txn.put(k1, v1); in getForUpdate_conflict()
77 txn2.put(k1, v12); in getForUpdate_conflict()
155 txn.put(keys[0], values[0]); in multiGetForUpdate_conflict()
156 txn.put(keys[1], values[1]); in multiGetForUpdate_conflict()
167 txn2.put(keys[0], otherValue); in multiGetForUpdate_conflict()
196 txn.put(testCf, k1, v1); in undoGetForUpdate_cf_conflict()
209 txn2.put(testCf, k1, v12); in undoGetForUpdate_cf_conflict()
230 txn.put(k1, v1); in undoGetForUpdate_conflict()
[all …]
DBackupEngineTest.java124 db.put("key1".getBytes(), "valueV2".getBytes()); in restoreLatestBackup()
125 db.put("key2".getBytes(), "valueV2".getBytes()); in restoreLatestBackup()
128 db.put("key1".getBytes(), "valueV3".getBytes()); in restoreLatestBackup()
129 db.put("key2".getBytes(), "valueV3".getBytes()); in restoreLatestBackup()
174 db.put("key1".getBytes(), "valueV2".getBytes()); in restoreFromBackup()
175 db.put("key2".getBytes(), "valueV2".getBytes()); in restoreFromBackup()
178 db.put("key1".getBytes(), "valueV3".getBytes()); in restoreFromBackup()
179 db.put("key2".getBytes(), "valueV3".getBytes()); in restoreFromBackup()
258 db.put("key1".getBytes(), "valueV1".getBytes()); in prepareDatabase()
259 db.put("key2".getBytes(), "valueV1".getBytes()); in prepareDatabase()
DTransactionTest.java30 txn.put(testCf, k1, v1); in getForUpdate_cf_conflict()
41 txn2.put(testCf, k1, v12); // should cause an exception! in getForUpdate_cf_conflict()
63 txn.put(k1, v1); in getForUpdate_conflict()
74 txn2.put(k1, v12); // should cause an exception! in getForUpdate_conflict()
103 txn.put(testCf, keys[0], values[0]); in multiGetForUpdate_cf_conflict()
104 txn.put(testCf, keys[1], values[1]); in multiGetForUpdate_cf_conflict()
116 txn2.put(testCf, keys[0], otherValue); // should cause an exception! in multiGetForUpdate_cf_conflict()
142 txn.put(keys[0], values[0]); in multiGetForUpdate_conflict()
143 txn.put(keys[1], values[1]); in multiGetForUpdate_conflict()
155 txn2.put(keys[0], otherValue); // should cause an exception! in multiGetForUpdate_conflict()
DMergeTest.java38 db.put("key".getBytes(), "aa".getBytes()); in stringOption()
56 buf.put(a); in longFromByteArray()
70 db.put("key".getBytes(), longToByteArray(100)); in uint64AddOption()
103 db.put(columnFamilyHandleList.get(1), in cFStringOption()
145 db.put(columnFamilyHandleList.get(1), in cFUInt64AddOption()
174 db.put("key".getBytes(), "aa".getBytes()); in operatorOption()
196 db.put("key".getBytes(), longToByteArray(100)); in uint64AddOperatorOption()
231 db.put(columnFamilyHandleList.get(1), in cFOperatorOption()
250 db.put(cfHandle, "cfkey2".getBytes(), "xx".getBytes()); in cFOperatorOption()
293 db.put(columnFamilyHandleList.get(1), in cFUInt64AddOperatorOption()
[all …]
DTableFilterTest.java48 db.put(columnFamilyHandles.get(0), in readOptions()
50 db.put(columnFamilyHandles.get(0), in readOptions()
52 db.put(columnFamilyHandles.get(0), in readOptions()
54 db.put(columnFamilyHandles.get(1), in readOptions()
56 db.put(columnFamilyHandles.get(1), in readOptions()
58 db.put(columnFamilyHandles.get(1), in readOptions()
DSnapshotTest.java28 db.put("key".getBytes(), "value".getBytes()); in snapshots()
45 db.put("newkey".getBytes(), "newvalue".getBytes()); in snapshots()
61 db.put("key".getBytes(), "newvalue".getBytes()); in snapshots()
88 db.put("key".getBytes(), "value".getBytes()); in iteratorWithSnapshot()
95 db.put("key2".getBytes(), "value2".getBytes()); in iteratorWithSnapshot()
132 db.put("key".getBytes(), "value".getBytes()); in iteratorWithSnapshotOnColumnFamily()
139 db.put("key2".getBytes(), "value2".getBytes()); in iteratorWithSnapshotOnColumnFamily()
DTransactionLogIteratorTest.java42 db.put(String.valueOf(i).getBytes(), in getBatch()
56 db.put(cfHandle, String.valueOf(i).getBytes(), in getBatch()
89 db.put("key1".getBytes(), "value1".getBytes()); in transactionLogIteratorStallAtLastRecord()
98 db.put("key2".getBytes(), "value2".getBytes()); in transactionLogIteratorStallAtLastRecord()
117 db.put("key1".getBytes(), "value1".getBytes()); in transactionLogIteratorCheckAfterRestart()
118 db.put("key2".getBytes(), "value2".getBytes()); in transactionLogIteratorCheckAfterRestart()
DBuiltinComparatorTest.java33 rocksDb.put("abc1".getBytes(), "abc1".getBytes()); in builtinForwardComparator()
34 rocksDb.put("abc2".getBytes(), "abc2".getBytes()); in builtinForwardComparator()
35 rocksDb.put("abc3".getBytes(), "abc3".getBytes()); in builtinForwardComparator()
87 rocksDb.put("abc1".getBytes(), "abc1".getBytes()); in builtinReverseComparator()
88 rocksDb.put("abc2".getBytes(), "abc2".getBytes()); in builtinReverseComparator()
89 rocksDb.put("abc3".getBytes(), "abc3".getBytes()); in builtinReverseComparator()
DRocksIteratorTest.java31 db.put("key1".getBytes(), "value1".getBytes()); in rocksIterator()
32 db.put("key2".getBytes(), "value2".getBytes()); in rocksIterator()
91 key.put("key1".getBytes()); in rocksIterator()
100 key.put("key2".getBytes()); in rocksIterator()
160 db.put("key".getBytes(), "value".getBytes()); in rocksIteratorReleaseAfterCfClose()
176 db.put(cfHandle1, "key1".getBytes(), "value1".getBytes()); in rocksIteratorReleaseAfterCfClose()
190 db.put(cfHandle2, "key2".getBytes(), "value2".getBytes()); in rocksIteratorReleaseAfterCfClose()
DFlushTest.java37 db.put(wOpt, "key1".getBytes(), "value1".getBytes()); in flush()
38 db.put(wOpt, "key2".getBytes(), "value2".getBytes()); in flush()
39 db.put(wOpt, "key3".getBytes(), "value3".getBytes()); in flush()
40 db.put(wOpt, "key4".getBytes(), "value4".getBytes()); in flush()
DTtlDBTest.java33 ttlDB.put("key".getBytes(), "value".getBytes()); in ttlDBOpen()
44 ttlDB.put("key".getBytes(), "value".getBytes()); in ttlDBOpenWithTtl()
70 ttlDB.put("key".getBytes(), "value".getBytes()); in ttlDbOpenWithColumnFamilies()
73 ttlDB.put(columnFamilyHandleList.get(1), "key".getBytes(), in ttlDbOpenWithColumnFamilies()
103 ttlDB.put(columnFamilyHandle, "key".getBytes(), in createTtlColumnFamily()
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DSstFileWriter.java76 put(nativeHandle_, key.getNativeHandle(), value.getNativeHandle()); in add()
93 put(nativeHandle_, key.getNativeHandle(), value.getNativeHandle()); in add()
105 public void put(final Slice key, final Slice value) throws RocksDBException { in put() method in SstFileWriter
106 put(nativeHandle_, key.getNativeHandle(), value.getNativeHandle()); in put()
118 public void put(final DirectSlice key, final DirectSlice value) in put() method in SstFileWriter
120 put(nativeHandle_, key.getNativeHandle(), value.getNativeHandle()); in put()
132 public void put(final ByteBuffer key, final ByteBuffer value) throws RocksDBException { in put() method in SstFileWriter
149 public void put(final byte[] key, final byte[] value) throws RocksDBException { in put() method in SstFileWriter
150 put(nativeHandle_, key, value); in put()
264 private native void put(final long handle, final long keyHandle, in put() method in SstFileWriter
[all …]
DTransaction.java670 public void put(final ColumnFamilyHandle columnFamilyHandle, final byte[] key, in put() method in Transaction
673 put(nativeHandle_, key, key.length, value, value.length, in put()
705 put(nativeHandle_, key, key.length, value, value.length, in put()
731 public void put(final byte[] key, final byte[] value) in put() method in Transaction
734 put(nativeHandle_, key, key.length, value, value.length); in put()
755 public void put(final ColumnFamilyHandle columnFamilyHandle, in put() method in Transaction
777 public void put(final ColumnFamilyHandle columnFamilyHandle, in put() method in Transaction
797 public void put(final byte[][] keyParts, final byte[][] valueParts) in put() method in Transaction
800 put(nativeHandle_, keyParts, keyParts.length, valueParts, in put()
1926 private native void put(final long handle, final byte[] key, in put() method in Transaction
[all …]
DAbstractWriteBatch.java23 public void put(byte[] key, byte[] value) throws RocksDBException { in put() method in AbstractWriteBatch
24 put(nativeHandle_, key, key.length, value, value.length); in put()
28 public void put(ColumnFamilyHandle columnFamilyHandle, byte[] key, in put() method in AbstractWriteBatch
30 put(nativeHandle_, key, key.length, value, value.length, in put()
59 public void put(ByteBuffer key, ByteBuffer value) throws RocksDBException { in put() method in AbstractWriteBatch
68 public void put(ColumnFamilyHandle columnFamilyHandle, ByteBuffer key, ByteBuffer value) in put() method in AbstractWriteBatch
163 abstract void put(final long handle, final byte[] key, final int keyLen, in put() method in AbstractWriteBatch
166 abstract void put(final long handle, final byte[] key, final int keyLen, in put() method in AbstractWriteBatch
DWriteBatchInterface.java30 void put(byte[] key, byte[] value) throws RocksDBException; in put() method
42 void put(ColumnFamilyHandle columnFamilyHandle, in put() method
55 void put(ByteBuffer key, ByteBuffer value) throws RocksDBException; in put() method
69 void put(ColumnFamilyHandle columnFamilyHandle, ByteBuffer key, ByteBuffer value) in put() method
DAbstractMutableOptions.java102 options.put(key, MutableOptionValue.fromDouble(value)); in setDouble()
121 options.put(key, MutableOptionValue.fromLong(value)); in setLong()
140 options.put(key, MutableOptionValue.fromInt(value)); in setInt()
159 options.put(key, MutableOptionValue.fromBoolean(value)); in setBoolean()
178 options.put(key, MutableOptionValue.fromIntArray(value)); in setIntArray()
197 options.put(key, MutableOptionValue.fromEnum(value)); in setEnum()
/rocksdb-6.9/java/samples/src/main/java/
DOptimisticTransactionSample.java74 txn.put(key1, value1); in readCommitted()
83 txnDb.put(writeOptions, key2, value2); in readCommitted()
109 txnDb.put(writeOptions, key1, value1); in repeatableRead()
159 txn.put(valueX, valueX); in readCommitted_monotonicAtomicViews()
162 txnDb.put(writeOptions, keyY, valueY); in readCommitted_monotonicAtomicViews()
173 txn.put(keyY, valueY); in readCommitted_monotonicAtomicViews()
DTransactionSample.java75 txn.put(key1, value1); in readCommitted()
84 txnDb.put(writeOptions, key2, value2); in readCommitted()
110 txnDb.put(writeOptions, key1, value1); in repeatableRead()
156 txn.put(valueX, valueX); in readCommitted_monotonicAtomicViews()
159 txnDb.put(writeOptions, keyY, valueY); in readCommitted_monotonicAtomicViews()
171 txn.put(keyY, valueY); in readCommitted_monotonicAtomicViews()

1234