Home
last modified time | relevance | path

Searched refs:nativeHandle_ (Results 1 – 25 of 61) sorted by relevance

123

/rocksdb-6.9/java/src/main/java/org/rocksdb/
DOptions.java104 setEnv(nativeHandle_, env.nativeHandle_); in setEnv()
198 setComparatorHandle(nativeHandle_, comparator.nativeHandle_, in setComparator()
217 setMergeOperator(nativeHandle_, mergeOperator.nativeHandle_); in setMergeOperator()
225 setCompactionFilterHandle(nativeHandle_, compactionFilter.nativeHandle_); in setCompactionFilter()
441 setStatistics(nativeHandle_, statistics.nativeHandle_); in setStatistics()
797 setWriteBufferManager(nativeHandle_, writeBufferManager.nativeHandle_); in setWriteBufferManager()
1069 setRowCache(nativeHandle_, rowCache.nativeHandle_); in setRowCache()
1083 setWalFilter(nativeHandle_, walFilter.nativeHandle_); in setWalFilter()
1214 setRateLimiter(nativeHandle_, rateLimiter.nativeHandle_); in setRateLimiter()
1221 setSstFileManager(nativeHandle_, sstFileManager.nativeHandle_); in setSstFileManager()
[all …]
DDBOptions.java175 setEnv(nativeHandle_, env.nativeHandle_); in setEnv()
189 setRateLimiter(nativeHandle_, rateLimiter.nativeHandle_); in setRateLimiter()
196 setSstFileManager(nativeHandle_, sstFileManager.nativeHandle_); in setSstFileManager()
203 setLogger(nativeHandle_, logger.nativeHandle_); in setLogger()
266 setStatistics(nativeHandle_, statistics.nativeHandle_); in setStatistics()
292 return useFsync(nativeHandle_); in useFsync()
343 return dbLogDir(nativeHandle_); in dbLogDir()
357 return walDir(nativeHandle_); in walDir()
719 setWriteBufferManager(nativeHandle_, writeBufferManager.nativeHandle_); in setWriteBufferManager()
1023 setRowCache(nativeHandle_, rowCache.nativeHandle_); in setRowCache()
[all …]
DColumnFamilyOptions.java121 optimizeForSmallDb(nativeHandle_); in optimizeForSmallDb()
128 optimizeForPointLookup(nativeHandle_, in optimizeForPointLookup()
175 setComparatorHandle(nativeHandle_, comparator.nativeHandle_, in setComparator()
195 setMergeOperator(nativeHandle_, mergeOperator.nativeHandle_); in setMergeOperator()
203 setCompactionFilterHandle(nativeHandle_, compactionFilter.nativeHandle_); in setCompactionFilter()
217 setCompactionFilterFactoryHandle(nativeHandle_, compactionFilterFactory.nativeHandle_); in setCompactionFilterFactory()
348 setCompressionOptions(nativeHandle_, compressionOptions.nativeHandle_); in setCompressionOptions()
366 return numLevels(nativeHandle_); in numLevels()
373 nativeHandle_, numFiles); in setLevelZeroFileNumCompactionTrigger()
780 setTtl(nativeHandle_, ttl); in setTtl()
[all …]
DTransaction.java135 setSnapshotOnNextOperation(nativeHandle_, transactionNotifier.nativeHandle_); in setSnapshotOnNextOperation()
276 return get(nativeHandle_, readOptions.nativeHandle_, key, key.length, in get()
308 return get(nativeHandle_, readOptions.nativeHandle_, key, key.length); in get()
357 return multiGet(nativeHandle_, readOptions.nativeHandle_, in multiGet()
393 return multiGet(nativeHandle_, readOptions.nativeHandle_, in multiGet()
561 return multiGetForUpdate(nativeHandle_, readOptions.nativeHandle_, in multiGetForUpdate()
639 readOptions.nativeHandle_, columnFamilyHandle.nativeHandle_)); in getIterator()
930 delete(nativeHandle_, key, key.length, columnFamilyHandle.nativeHandle_, in delete()
961 delete(nativeHandle_, key, key.length, columnFamilyHandle.nativeHandle_, in delete()
1582 setWriteOptions(nativeHandle_, writeOptions.nativeHandle_); in setWriteOptions()
[all …]
DRocksDB.java705 put(nativeHandle_, writeOpts.nativeHandle_, in put()
734 put(nativeHandle_, writeOpts.nativeHandle_, in put()
1448 merge(nativeHandle_, writeOpts.nativeHandle_, in merge()
1478 merge(nativeHandle_, writeOpts.nativeHandle_, in merge()
1537 merge(nativeHandle_, writeOpts.nativeHandle_, in merge()
1570 merge(nativeHandle_, writeOpts.nativeHandle_, in merge()
1586 write0(nativeHandle_, writeOpts.nativeHandle_, updates.nativeHandle_); in write()
1600 write1(nativeHandle_, writeOpts.nativeHandle_, updates.nativeHandle_); in write()
1734 return get(nativeHandle_, opt.nativeHandle_, in get()
1767 return get(nativeHandle_, opt.nativeHandle_, in get()
[all …]
DReadOptions.java51 return verifyChecksums(nativeHandle_); in verifyChecksums()
81 return fillCache(nativeHandle_); in fillCache()
127 setSnapshot(nativeHandle_, snapshot.nativeHandle_); in setSnapshot()
129 setSnapshot(nativeHandle_, 0l); in setSnapshot()
171 return tailing(nativeHandle_); in tailing()
187 setTailing(nativeHandle_, tailing); in setTailing()
202 return managed(nativeHandle_); in managed()
218 setManaged(nativeHandle_, managed); in setManaged()
282 return pinData(nativeHandle_); in pinData()
297 setPinData(nativeHandle_, pinData); in setPinData()
[all …]
DCompactionJobStats.java25 reset(nativeHandle_); in reset()
34 add(nativeHandle_, compactionJobStats.nativeHandle_); in add()
43 return elapsedMicros(nativeHandle_); in elapsedMicros()
52 return numInputRecords(nativeHandle_); in numInputRecords()
61 return numInputFiles(nativeHandle_); in numInputFiles()
79 return numOutputRecords(nativeHandle_); in numOutputRecords()
88 return numOutputFiles(nativeHandle_); in numOutputFiles()
106 return totalInputBytes(nativeHandle_); in totalInputBytes()
180 return numCorruptKeys(nativeHandle_); in numCorruptKeys()
191 return fileWriteNanos(nativeHandle_); in fileWriteNanos()
[all …]
DEnvOptions.java29 super(newEnvOptions(dbOptions.nativeHandle_)); in EnvOptions()
42 setUseMmapReads(nativeHandle_, useMmapReads); in setUseMmapReads()
53 return useMmapReads(nativeHandle_); in useMmapReads()
66 setUseMmapWrites(nativeHandle_, useMmapWrites); in setUseMmapWrites()
77 return useMmapWrites(nativeHandle_); in useMmapWrites()
101 return useDirectReads(nativeHandle_); in useDirectReads()
125 return useDirectWrites(nativeHandle_); in useDirectWrites()
151 return allowFallocate(nativeHandle_); in allowFallocate()
177 return setFdCloexec(nativeHandle_); in setFdCloexec()
203 return bytesPerSync(nativeHandle_); in bytesPerSync()
[all …]
DBackupableDBOptions.java54 return backupDir(nativeHandle_); in backupDir()
71 setBackupEnv(nativeHandle_, env.nativeHandle_); in setBackupEnv()
118 return shareTableFiles(nativeHandle_); in shareTableFiles()
129 setInfoLog(nativeHandle_, logger.nativeHandle_); in setInfoLog()
159 setSync(nativeHandle_, sync); in setSync()
170 return sync(nativeHandle_); in sync()
196 return destroyOldData(nativeHandle_); in destroyOldData()
223 return backupLogFiles(nativeHandle_); in backupLogFiles()
252 return backupRateLimit(nativeHandle_); in backupRateLimit()
266 setBackupRateLimiter(nativeHandle_, backupRateLimiter.nativeHandle_); in setBackupRateLimiter()
[all …]
DAbstractWriteBatch.java19 return count0(nativeHandle_); in count()
31 columnFamilyHandle.nativeHandle_); in put()
43 columnFamilyHandle.nativeHandle_); in merge()
56 delete(nativeHandle_, key, key.length, columnFamilyHandle.nativeHandle_); in remove()
85 delete(nativeHandle_, key, key.length, columnFamilyHandle.nativeHandle_); in delete()
97 singleDelete(nativeHandle_, key, key.length, columnFamilyHandle.nativeHandle_); in singleDelete()
122 nativeHandle_, key, key.position(), key.remaining(), columnFamilyHandle.nativeHandle_); in remove()
133 clear0(nativeHandle_); in clear()
138 setSavePoint0(nativeHandle_); in setSavePoint()
143 rollbackToSavePoint0(nativeHandle_); in rollbackToSavePoint()
[all …]
DTransactionDB.java47 transactionDbOptions.nativeHandle_, path)); in open()
90 final long[] handles = open(dbOptions.nativeHandle_, in open()
123 closeDatabase(nativeHandle_); in closeE()
145 closeDatabase(nativeHandle_); in close()
157 writeOptions.nativeHandle_)); in beginTransaction()
164 writeOptions.nativeHandle_, transactionOptions.nativeHandle_)); in beginTransaction()
177 writeOptions.nativeHandle_, oldTransaction.nativeHandle_); in beginTransaction()
192 writeOptions.nativeHandle_, transactionOptions.nativeHandle_, in beginTransaction()
193 oldTransaction.nativeHandle_); in beginTransaction()
278 return getLockStatusData(nativeHandle_); in getLockStatusData()
[all …]
DOptimisticTransactionDB.java41 options.nativeHandle_, path)); in open()
114 closeDatabase(nativeHandle_); in closeE()
136 closeDatabase(nativeHandle_); in close()
148 writeOptions.nativeHandle_)); in beginTransaction()
155 writeOptions.nativeHandle_, in beginTransaction()
156 optimisticTransactionOptions.nativeHandle_)); in beginTransaction()
169 writeOptions.nativeHandle_, oldTransaction.nativeHandle_); in beginTransaction()
174 assert(jtxn_handle == oldTransaction.nativeHandle_); in beginTransaction()
184 writeOptions.nativeHandle_, optimisticTransactionOptions.nativeHandle_, in beginTransaction()
185 oldTransaction.nativeHandle_); in beginTransaction()
[all …]
DSstFileWriter.java35 envOptions.nativeHandle_, options.nativeHandle_, comparator.nativeHandle_, in SstFileWriter()
47 envOptions.nativeHandle_, options.nativeHandle_)); in SstFileWriter()
59 open(nativeHandle_, filePath); in open()
76 put(nativeHandle_, key.getNativeHandle(), value.getNativeHandle()); in add()
150 put(nativeHandle_, key, value); in put()
180 merge(nativeHandle_, key, value); in merge()
207 delete(nativeHandle_, key.getNativeHandle()); in delete()
219 delete(nativeHandle_, key.getNativeHandle()); in delete()
231 delete(nativeHandle_, key); in delete()
241 finish(nativeHandle_); in finish()
[all …]
DWriteBatchWithIndex.java96 return new WBWIRocksIterator(this, iterator1(nativeHandle_, in newIterator()
97 columnFamilyHandle.nativeHandle_)); in newIterator()
136 nativeHandle_, columnFamilyHandle.nativeHandle_, baseIterator.nativeHandle_)); in newIteratorWithBase()
173 return getFromBatch(nativeHandle_, options.nativeHandle_, in getFromBatch()
174 key, key.length, columnFamilyHandle.nativeHandle_); in getFromBatch()
192 return getFromBatch(nativeHandle_, options.nativeHandle_, key, key.length); in getFromBatch()
220 return getFromBatchAndDB(nativeHandle_, db.nativeHandle_, in getFromBatchAndDB()
221 options.nativeHandle_, key, key.length, in getFromBatchAndDB()
222 columnFamilyHandle.nativeHandle_); in getFromBatchAndDB()
249 return getFromBatchAndDB(nativeHandle_, db.nativeHandle_, in getFromBatchAndDB()
[all …]
DCompactionOptionsUniversal.java29 setSizeRatio(nativeHandle_, sizeRatio); in setSizeRatio()
43 return sizeRatio(nativeHandle_); in sizeRatio()
56 setMinMergeWidth(nativeHandle_, minMergeWidth); in setMinMergeWidth()
68 return minMergeWidth(nativeHandle_); in minMergeWidth()
81 setMaxMergeWidth(nativeHandle_, maxMergeWidth); in setMaxMergeWidth()
93 return maxMergeWidth(nativeHandle_); in maxMergeWidth()
137 return maxSizeAmplificationPercent(nativeHandle_); in maxSizeAmplificationPercent()
193 return compressionSizePercent(nativeHandle_); in compressionSizePercent()
207 setStopStyle(nativeHandle_, compactionStopStyle.getValue()); in setStopStyle()
234 setAllowTrivialMove(nativeHandle_, allowTrivialMove); in setAllowTrivialMove()
[all …]
DBackupEngine.java37 return new BackupEngine(open(env.nativeHandle_, options.nativeHandle_)); in open()
84 createNewBackup(nativeHandle_, db.nativeHandle_, flushBeforeBackup); in createNewBackup()
116 createNewBackupWithMetadata(nativeHandle_, db.nativeHandle_, metadata, flushBeforeBackup); in createNewBackupWithMetadata()
127 return getBackupInfo(nativeHandle_); in getBackupInfo()
139 return getCorruptedBackups(nativeHandle_); in getCorruptedBackups()
152 garbageCollect(nativeHandle_); in garbageCollect()
165 purgeOldBackups(nativeHandle_, numBackupsToKeep); in purgeOldBackups()
177 deleteBackup(nativeHandle_, backupId); in deleteBackup()
207 restoreOptions.nativeHandle_); in restoreDbFromBackup()
225 restoreDbFromLatestBackup(nativeHandle_, dbDir, walDir, in restoreDbFromLatestBackup()
[all …]
DCompactRangeOptions.java77 return exclusiveManualCompaction(nativeHandle_); in exclusiveManualCompaction()
97 return changeLevel(nativeHandle_); in changeLevel()
108 setChangeLevel(nativeHandle_, changeLevel); in setChangeLevel()
117 return targetLevel(nativeHandle_); in targetLevel()
128 setTargetLevel(nativeHandle_, targetLevel); in setTargetLevel()
138 return targetPathId(nativeHandle_); in targetPathId()
149 setTargetPathId(nativeHandle_, targetPathId); in setTargetPathId()
178 return allowWriteStall(nativeHandle_); in allowWriteStall()
190 setAllowWriteStall(nativeHandle_, allowWriteStall); in setAllowWriteStall()
199 return maxSubcompactions(nativeHandle_); in maxSubcompactions()
[all …]
DCompressionOptions.java18 setWindowBits(nativeHandle_, windowBits); in setWindowBits()
23 return windowBits(nativeHandle_); in windowBits()
27 setLevel(nativeHandle_, level); in setLevel()
32 return level(nativeHandle_); in level()
36 setStrategy(nativeHandle_, strategy); in setStrategy()
41 return strategy(nativeHandle_); in strategy()
61 setMaxDictBytes(nativeHandle_, maxDictBytes); in setMaxDictBytes()
71 return maxDictBytes(nativeHandle_); in maxDictBytes()
99 return zstdMaxTrainBytes(nativeHandle_); in zstdMaxTrainBytes()
119 setEnabled(nativeHandle_, enabled); in setEnabled()
[all …]
DTransactionOptions.java18 return isSetSnapshot(nativeHandle_); in isSetSnapshot()
24 setSetSnapshot(nativeHandle_, setSnapshot); in setSetSnapshot()
37 return isDeadlockDetect(nativeHandle_); in isDeadlockDetect()
51 setDeadlockDetect(nativeHandle_, deadlockDetect); in setDeadlockDetect()
66 return getLockTimeout(nativeHandle_); in getLockTimeout()
85 setLockTimeout(nativeHandle_, lockTimeout); in setLockTimeout()
101 return getExpiration(nativeHandle_); in getExpiration()
120 setExpiration(nativeHandle_, expiration); in setExpiration()
131 return getDeadlockDetectDepth(nativeHandle_); in getDeadlockDetectDepth()
156 return getMaxWriteBatchSize(nativeHandle_); in getMaxWriteBatchSize()
[all …]
DCompactionJobInfo.java31 return columnFamilyName(nativeHandle_); in columnFamilyName()
40 return status(nativeHandle_); in status()
49 return threadId(nativeHandle_); in threadId()
58 return jobId(nativeHandle_); in jobId()
67 return baseInputLevel(nativeHandle_); in baseInputLevel()
76 return outputLevel(nativeHandle_); in outputLevel()
85 return Arrays.asList(inputFiles(nativeHandle_)); in inputFiles()
94 return Arrays.asList(outputFiles(nativeHandle_)); in outputFiles()
106 return tableProperties(nativeHandle_); in tableProperties()
115 return CompactionReason.fromValue(compactionReason(nativeHandle_)); in compactionReason()
[all …]
DIngestExternalFileOptions.java38 return moveFiles(nativeHandle_); in moveFiles()
49 setMoveFiles(nativeHandle_, moveFiles); in setMoveFiles()
60 return snapshotConsistency(nativeHandle_); in snapshotConsistency()
84 return allowGlobalSeqNo(nativeHandle_); in allowGlobalSeqNo()
97 setAllowGlobalSeqNo(nativeHandle_, allowGlobalSeqNo); in setAllowGlobalSeqNo()
108 return allowBlockingFlush(nativeHandle_); in allowBlockingFlush()
121 setAllowBlockingFlush(nativeHandle_, allowBlockingFlush); in setAllowBlockingFlush()
133 return ingestBehind(nativeHandle_); in ingestBehind()
156 setIngestBehind(nativeHandle_, ingestBehind); in setIngestBehind()
170 return writeGlobalSeqno(nativeHandle_); in writeGlobalSeqno()
[all …]
DWriteOptions.java38 super(copyWriteOptions(other.nativeHandle_)); in WriteOptions()
65 setSync(nativeHandle_, flag); in setSync()
88 return sync(nativeHandle_); in sync()
103 setDisableWAL(nativeHandle_, flag); in setDisableWAL()
117 return disableWAL(nativeHandle_); in disableWAL()
133 setIgnoreMissingColumnFamilies(nativeHandle_, ignoreMissingColumnFamilies); in setIgnoreMissingColumnFamilies()
147 return ignoreMissingColumnFamilies(nativeHandle_); in ignoreMissingColumnFamilies()
158 setNoSlowdown(nativeHandle_, noSlowdown); in setNoSlowdown()
169 return noSlowdown(nativeHandle_); in noSlowdown()
187 setLowPri(nativeHandle_, lowPri); in setLowPri()
[all …]
DSstFileManager.java121 super(newSstFileManager(env.nativeHandle_, in SstFileManager()
122 logger != null ? logger.nativeHandle_ : 0, in SstFileManager()
139 setMaxAllowedSpaceUsage(nativeHandle_, maxAllowedSpace); in setMaxAllowedSpaceUsage()
152 setCompactionBufferSize(nativeHandle_, compactionBufferSize); in setCompactionBufferSize()
162 return isMaxAllowedSpaceReached(nativeHandle_); in isMaxAllowedSpaceReached()
182 return getTotalSize(nativeHandle_); in getTotalSize()
191 return getTrackedFiles(nativeHandle_); in getTrackedFiles()
200 return getDeleteRateBytesPerSecond(nativeHandle_); in getDeleteRateBytesPerSecond()
211 setDeleteRateBytesPerSecond(nativeHandle_, deleteRate); in setDeleteRateBytesPerSecond()
220 return getMaxTrashDBRatio(nativeHandle_); in getMaxTrashDBRatio()
[all …]
DWriteBatch.java63 iterate(nativeHandle_, handler.nativeHandle_); in iterate()
75 return data(nativeHandle_); in data()
84 return getDataSize(nativeHandle_); in getDataSize()
93 return hasPut(nativeHandle_); in hasPut()
102 return hasDelete(nativeHandle_); in hasDelete()
111 return hasSingleDelete(nativeHandle_); in hasSingleDelete()
120 return hasDeleteRange(nativeHandle_); in hasDeleteRange()
129 return hasMerge(nativeHandle_); in hasMerge()
147 return hasEndPrepare(nativeHandle_); in hasEndPrepare()
156 return hasCommit(nativeHandle_); in hasCommit()
[all …]
DTransactionDBOptions.java25 return getMaxNumLocks(nativeHandle_); in getMaxNumLocks()
42 setMaxNumLocks(nativeHandle_, maxNumLocks); in setMaxNumLocks()
53 return getNumStripes(nativeHandle_); in getNumStripes()
69 setNumStripes(nativeHandle_, numStripes); in setNumStripes()
85 return getTransactionLockTimeout(nativeHandle_); in getTransactionLockTimeout()
107 setTransactionLockTimeout(nativeHandle_, transactionLockTimeout); in setTransactionLockTimeout()
126 return getDefaultLockTimeout(nativeHandle_); in getDefaultLockTimeout()
154 setDefaultLockTimeout(nativeHandle_, defaultLockTimeout); in setDefaultLockTimeout()
182 return TxnDBWritePolicy.getTxnDBWritePolicy(getWritePolicy(nativeHandle_)); in getWritePolicy()
198 setWritePolicy(nativeHandle_, writePolicy.getValue()); in setWritePolicy()

123