Home
last modified time | relevance | path

Searched refs:columnFamilyHandle (Results 1 – 16 of 16) sorted by relevance

/rocksdb-6.9/java/src/main/java/org/rocksdb/
DTransaction.java277 columnFamilyHandle.nativeHandle_); in get()
706 columnFamilyHandle.nativeHandle_, false); in put()
782 columnFamilyHandle.nativeHandle_, false); in put()
869 columnFamilyHandle.nativeHandle_, false); in merge()
1033 columnFamilyHandle.nativeHandle_, false); in delete()
1116 columnFamilyHandle.nativeHandle_, false); in singleDelete()
1190 columnFamilyHandle.nativeHandle_, false); in singleDelete()
1234 columnFamilyHandle.nativeHandle_); in putUntracked()
1325 columnFamilyHandle.nativeHandle_); in mergeUntracked()
1376 columnFamilyHandle.nativeHandle_); in deleteUntracked()
[all …]
DRocksDB.java2796 columnFamilyHandle == null ? 0 : columnFamilyHandle.nativeHandle_, in getProperty()
2857 columnFamilyHandle == null ? 0 : columnFamilyHandle.nativeHandle_, in getMapProperty()
2915 columnFamilyHandle == null ? 0 : columnFamilyHandle.nativeHandle_, in getLongProperty()
2989 columnFamilyHandle == null ? 0 : columnFamilyHandle.nativeHandle_, in getApproximateSizes()
3041 columnFamilyHandle == null ? 0 : columnFamilyHandle.nativeHandle_, in getApproximateMemTableStats()
3111 columnFamilyHandle == null ? 0 : columnFamilyHandle.nativeHandle_); in compactRange()
3251 columnFamilyHandle == null ? 0 : columnFamilyHandle.nativeHandle_); in compactRange()
3338 columnFamilyHandle == null ? 0 : columnFamilyHandle.nativeHandle_); in compactRange()
3475 columnFamilyHandle == null ? 0 : columnFamilyHandle.nativeHandle_, in compactFiles()
4038 columnFamilyHandle == null ? 0 : columnFamilyHandle.nativeHandle_, in getPropertiesOfTablesInRange()
[all …]
DAbstractWriteBatch.java28 public void put(ColumnFamilyHandle columnFamilyHandle, byte[] key, in put() argument
31 columnFamilyHandle.nativeHandle_); in put()
40 public void merge(ColumnFamilyHandle columnFamilyHandle, byte[] key, in merge() argument
43 columnFamilyHandle.nativeHandle_); in merge()
54 public void remove(ColumnFamilyHandle columnFamilyHandle, byte[] key) in remove() argument
56 delete(nativeHandle_, key, key.length, columnFamilyHandle.nativeHandle_); in remove()
72 value.remaining(), columnFamilyHandle.nativeHandle_); in put()
83 public void delete(ColumnFamilyHandle columnFamilyHandle, byte[] key) in delete() argument
107 public void deleteRange(ColumnFamilyHandle columnFamilyHandle, in deleteRange() argument
110 columnFamilyHandle.nativeHandle_); in deleteRange()
[all …]
DWriteBatchInterface.java42 void put(ColumnFamilyHandle columnFamilyHandle, in put() argument
69 void put(ColumnFamilyHandle columnFamilyHandle, ByteBuffer key, ByteBuffer value) in put() argument
93 void merge(ColumnFamilyHandle columnFamilyHandle, in merge() argument
117 void remove(ColumnFamilyHandle columnFamilyHandle, byte[] key) in remove() argument
135 void delete(ColumnFamilyHandle columnFamilyHandle, byte[] key) in delete() argument
185 void singleDelete(final ColumnFamilyHandle columnFamilyHandle, in singleDelete() argument
205 void remove(ColumnFamilyHandle columnFamilyHandle, ByteBuffer key) throws RocksDBException; in remove() argument
240 void deleteRange(ColumnFamilyHandle columnFamilyHandle, byte[] beginKey, in deleteRange() argument
DWriteBatchWithIndex.java95 final ColumnFamilyHandle columnFamilyHandle) { in newIterator() argument
97 columnFamilyHandle.nativeHandle_)); in newIterator()
132 final ColumnFamilyHandle columnFamilyHandle, in newIteratorWithBase() argument
136 nativeHandle_, columnFamilyHandle.nativeHandle_, baseIterator.nativeHandle_)); in newIteratorWithBase()
171 public byte[] getFromBatch(final ColumnFamilyHandle columnFamilyHandle, in getFromBatch() argument
174 key, key.length, columnFamilyHandle.nativeHandle_); in getFromBatch()
218 public byte[] getFromBatchAndDB(final RocksDB db, final ColumnFamilyHandle columnFamilyHandle, in getFromBatchAndDB() argument
222 columnFamilyHandle.nativeHandle_); in getFromBatchAndDB()
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DColumnFamilyTest.java122 columnFamilyHandle.close(); in createColumnFamily()
168 columnFamilyHandle.close(); in openWithColumnFamilies()
208 columnFamilyHandle.close(); in getWithOutValueAndCf()
239 columnFamilyHandle.close(); in createWriteDropColumnFamily()
279 columnFamilyHandle.close(); in createWriteDropColumnFamilies()
373 columnFamilyHandle.close(); in iteratorOnColumnFamily()
417 columnFamilyHandle.close(); in multiGet()
461 columnFamilyHandle.close(); in multiGetAsList()
500 columnFamilyHandle.close(); in properties()
552 columnFamilyHandle.close(); in iterators()
[all …]
DReadOnlyTest.java92 columnFamilyHandle.close(); in readOnlyOpen()
99 columnFamilyHandle.close(); in readOnlyOpen()
104 for (final ColumnFamilyHandle columnFamilyHandle : in readOnlyOpen()
106 columnFamilyHandle.close(); in readOnlyOpen()
138 for (final ColumnFamilyHandle columnFamilyHandle : in failToWriteInReadOnly()
140 columnFamilyHandle.close(); in failToWriteInReadOnly()
170 columnFamilyHandle.close(); in failToCFWriteInReadOnly()
201 columnFamilyHandle.close(); in failToRemoveInReadOnly()
232 columnFamilyHandle.close(); in failToCFRemoveInReadOnly()
265 columnFamilyHandle.close(); in failToWriteBatchReadOnly()
[all …]
DTtlDBTest.java86 for (final ColumnFamilyHandle columnFamilyHandle : in ttlDbOpenWithColumnFamilies()
88 columnFamilyHandle.close(); in ttlDbOpenWithColumnFamilies()
100 final ColumnFamilyHandle columnFamilyHandle = in createTtlColumnFamily() argument
103 ttlDB.put(columnFamilyHandle, "key".getBytes(), in createTtlColumnFamily()
105 assertThat(ttlDB.get(columnFamilyHandle, "key".getBytes())). in createTtlColumnFamily()
108 ttlDB.compactRange(columnFamilyHandle); in createTtlColumnFamily()
109 assertThat(ttlDB.get(columnFamilyHandle, "key".getBytes())).isNull(); in createTtlColumnFamily()
DMergeTest.java261 for (final ColumnFamilyHandle columnFamilyHandle : in cFOperatorOption()
263 columnFamilyHandle.close(); in cFOperatorOption()
323 for (final ColumnFamilyHandle columnFamilyHandle : in cFUInt64AddOperatorOption()
325 columnFamilyHandle.close(); in cFUInt64AddOperatorOption()
DTableFilterTest.java89 for (final ColumnFamilyHandle columnFamilyHandle : columnFamilyHandles) { in readOptions()
90 columnFamilyHandle.close(); in readOptions()
DOptionsUtilTest.java72 try (final ColumnFamilyHandle columnFamilyHandle = in verifyOptions() argument
74 assert(columnFamilyHandle != null); in verifyOptions()
DLoggerTest.java145 for (final ColumnFamilyHandle columnFamilyHandle : cfHandles) { in dbOptionsLogger()
146 columnFamilyHandle.close(); in dbOptionsLogger()
DKeyMayExistTest.java158 for (final ColumnFamilyHandle columnFamilyHandle : in keyMayExist()
160 columnFamilyHandle.close(); in keyMayExist()
DTransactionTest.java299 for(final ColumnFamilyHandle columnFamilyHandle : columnFamilyHandles) { in close()
300 columnFamilyHandle.close(); in close()
DOptimisticTransactionTest.java343 for(final ColumnFamilyHandle columnFamilyHandle : columnFamilyHandles) { in close()
344 columnFamilyHandle.close(); in close()
/rocksdb-6.9/java/samples/src/main/java/
DRocksDBColumnFamilySample.java32 try(final ColumnFamilyHandle columnFamilyHandle = db.createColumnFamily( in main() argument
35 assert (columnFamilyHandle != null); in main()