Package | Description |
---|---|
org.voovan.tools.collection |
Modifier and Type | Method and Description |
---|---|
RocksMap<K,V> |
RocksMap.choseColumnFamily(String cfName)
在多个 Columnt 之间切换
|
RocksMap<K,V> |
RocksMap.duplicate(String cfName)
复制出一个列族不同,但事务共享的 RocksMap
|
RocksMap<K,V> |
RocksMap.duplicate(String cfName,
boolean shareTransaction)
复制出一个列族不同的 RocksMAp
|
RocksMap<K,V> |
RocksMap.RocksMapEntry.getRocksMap() |
Modifier and Type | Method and Description |
---|---|
static org.rocksdb.BackupableDBOptions |
RocksMap.createBackupableOption(RocksMap rocksMap) |
Modifier and Type | Method and Description |
---|---|
<T> T |
RocksMap.withTransaction(Function<RocksMap<K,V>,T> transFunction)
开启式事务模式 (立即失败, 死锁检测,无快照)
同一个线程共线给一个事务
使用内置公共事务通过 savepoint 来失败回滚, 但统一提交, 性能会好很多, 但是由于很多层嵌套的 savepont 在高并发时使用这种方式时回导致提交会慢很多
|
<T> T |
RocksMap.withTransaction(long expire,
boolean deadlockDetect,
boolean withSnapShot,
Function<RocksMap<K,V>,T> transFunction)
开启式事务模式
同一个线程共线给一个事务
使用内置公共事务通过 savepoint 来失败回滚, 但统一提交, 性能会好很多, 但是由于很多层嵌套的 savepont 在高并发时使用这种方式时回导致提交会慢很多
|
Constructor and Description |
---|
RocksMapEntry(RocksMap<K,V> rocksMap,
byte[] keyBytes,
byte[] valueBytes) |
RocksMapIterator(RocksMap rocksMap,
K fromKey,
K toKey,
int skipSize,
int size) |
RocksWalReader(Object mark,
RocksMap rocksMap,
int batchSeqsize) |
Copyright © 2020 Voovan. All rights reserved.