andreacavalli/CavalliumDBEngine
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Update rocksdb

Browse Source
This commit is contained in:
Andrea Cavalli 2022-09-26 21:56:56 +02:00
parent 5360a7dd7c
commit b33bafec21
2 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pom.xml
View File

@ -237,7 +237,7 @@
<dependency> <dependency>
<groupId>org.rocksdb</groupId> <groupId>org.rocksdb</groupId>
<artifactId>rocksdbjni</artifactId> <artifactId>rocksdbjni</artifactId>
<version>7.5.3</version> <version>7.6.0</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.apache.lucene</groupId> <groupId>org.apache.lucene</groupId>

6
src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java
View File

@ -82,6 +82,7 @@ import org.rocksdb.LogFile;
import org.rocksdb.MutableDBOptions; import org.rocksdb.MutableDBOptions;
import org.rocksdb.OptimisticTransactionDB; import org.rocksdb.OptimisticTransactionDB;
import org.rocksdb.PersistentCache; import org.rocksdb.PersistentCache;
import org.rocksdb.PrepopulateBlobCache;
import org.rocksdb.RocksDB; import org.rocksdb.RocksDB;
import org.rocksdb.RocksDBException; import org.rocksdb.RocksDBException;
import org.rocksdb.Snapshot; import org.rocksdb.Snapshot;
@ -230,6 +231,11 @@ public class LLLocalKeyValueDatabase extends Backuppable implements LLKeyValueDa
} }
var blobFiles = columnOptions.blobFiles(); var blobFiles = columnOptions.blobFiles();
columnFamilyOptions.setEnableBlobFiles(blobFiles); columnFamilyOptions.setEnableBlobFiles(blobFiles);
try {
columnFamilyOptions.setPrepopulateBlobCache(PrepopulateBlobCache.PREPOPULATE_BLOB_FLUSH_ONLY);
} catch (Throwable ex) {
logger.error("Failed to set prepopulate blob cache", ex);
}
if (blobFiles) { if (blobFiles) {
if (columnOptions.blobFileSize().isPresent()) { if (columnOptions.blobFileSize().isPresent()) {
columnFamilyOptions.setBlobFileSize(columnOptions.blobFileSize().get()); columnFamilyOptions.setBlobFileSize(columnOptions.blobFileSize().get());