org.voovan.tools.collection

Class RocksMap<K,V>

java.lang.Object

org.voovan.tools.collection.RocksMap<K,V>

All Implemented Interfaces:

Closeable, AutoCloseable, Map<K,V>, SortedMap<K,V>

public class RocksMap<K,V>
extends Object
implements SortedMap<K,V>, Closeable

RocksDB 的 Map 封装

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	RocksMap.RocksMapEntry<K,V>
class	RocksMap.RocksMapIterator<K,V>
static class	RocksMap.RocksWalReader 按批次读取Wal, wal 读取器
static class	RocksMap.RocksWalRecord

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Field Summary

Fields

Modifier and Type	Field and Description
org.rocksdb.ColumnFamilyOptions	columnFamilyOptions
org.rocksdb.DBOptions	dbOptions
static String	DEFAULT_COLUMN_FAMILY_NAME
org.rocksdb.ReadOptions	readOptions
static ThreadLocal<org.rocksdb.WriteBatch>	THREAD_LOCAL_WRITE_BATCH
org.rocksdb.WriteOptions	writeOptions

Constructor Summary

Constructors

Constructor and Description
RocksMap() 构造方法
RocksMap(boolean readOnly) 构造方法
RocksMap(String columnFamilyName) 构造方法
RocksMap(String columnFamilyName, boolean readOnly) 构造方法
RocksMap(String dbname, String columnFamilyName) 构造方法
RocksMap(String dbname, String columnFamilyName, boolean readOnly) 构造方法
RocksMap(String dbname, String columnFamilyName, org.rocksdb.ColumnFamilyOptions columnFamilyOptions, org.rocksdb.DBOptions dbOptions, org.rocksdb.ReadOptions readOptions, org.rocksdb.WriteOptions writeOptions, Boolean readOnly) 构造方法

Method Summary

Modifier and Type	Method and Description
void	beginTransaction() 开启事务 同一个线程共线给一个事务 默认: 锁提交等待时间-1, 死锁检测:true, 是否启用快照事务: false
void	beginTransaction(long expire, boolean deadlockDetect, boolean withSnapShot) 开启事务 同一个线程共线给一个事务 事务都是读事务，无论操作的记录间是否有交集，都不会锁定。 事务包含读、写事务： 所有的读事务不会锁定，读到的数据取决于snapshot设置。 写事务之间如果不存在记录交集，不会锁定。 写事务之间如果存在记录交集，此时如果未设置snapshot，则交集部分的记录是可以串行提交的。如果设置了snapshot，则第一个写事务(写锁队列的head)会成功，其他写事务会失败(之前的事务修改了该记录的情况下)。
RocksMap<K,V>	choseColumnFamily(String cfName) 在多个 Columnt 之间切换
void	clear()
void	close()
void	commit() 事务提交
void	compact()
void	compactRange(K start, K end)
Comparator<? super K>	comparator()
boolean	containsKey(Object key)
boolean	containsValue(Object value)
String	createBackup()
String	createBackup(org.rocksdb.BackupableDBOptions backupableDBOptions)
String	createBackup(org.rocksdb.BackupableDBOptions backupableDBOptions, boolean beforeFlush) 创建一个备份
static org.rocksdb.BackupableDBOptions	createBackupableOption(RocksMap rocksMap)
static org.rocksdb.BackupableDBOptions	createBackupableOption(String dbName)
static org.rocksdb.BackupableDBOptions	createBackupableOption(String dbName, String backupPath) 创建一个备份选项
void	drop() 删除这个列族
RocksMap<K,V>	duplicate(String cfName) 复制出一个列族不同,但事务共享的 RocksMap
RocksMap<K,V>	duplicate(String cfName, boolean shareTransaction) 复制出一个列族不同的 RocksMAp
void	empty(Object key)
Set<Map.Entry<K,V>>	entrySet() 数据拷贝到内存中, 所以对这个 Set 的修改不会在 Rocksdb 中生效
K	firstKey()
void	flush() 刷新数据到文件
void	flush(boolean sync) 刷新数据到文件
void	flush(boolean sync, boolean allowStall) 刷新数据到文件
void	flushWal()
void	flushWal(boolean sync) 刷新WAL数据到文件
V	get(Object key)
List<V>	getAll(Collection<K> keys)
List<org.rocksdb.BackupInfo>	getBackupInfo()
List<org.rocksdb.BackupInfo>	getBackupInfo(org.rocksdb.BackupableDBOptions backupableDBOptions) 获取备份信息
int	getColumnFamilyId()
int	getColumnFamilyId(String columnFamilyName)
String	getColumnFamilyName()
String	getDataPath()
String	getDbname()
static String	getDefaultDbPath() 获取默认数据存储路径
static String	getDefaultWalPath() 默认WAL数存储据路径
Long	getLastSequence() 获取最后的序号
String	getProperty(String name)
String	getProperty(String columnFamilyName, String name)
Boolean	getReadOnly()
org.rocksdb.RocksDB	getRocksDB()
org.rocksdb.Transaction	getTransaction()
int	getTransactionLockTimeout() 获取事务锁超时时间
List<RocksMap.RocksWalRecord>	getWalBetween(Long startSequence, Long endSequence, BiFunction<Integer,Integer,Boolean> filter, boolean withSerial) 获取某个序号以后的更新操作记录
String	getWalPath()
List<RocksMap.RocksWalRecord>	getWalSince(Long startSequence, BiFunction<Integer,Integer,Boolean> filter, boolean withSerial) 获取某个序号以后的更新操作记录
List<RocksMap.RocksWalRecord>	getWalSince(Long sequenceNumber, boolean withSerial) 获取某个序号以后的更新操作记录
List<RocksMap.RocksWalRecord>	getWalSince(Long startSequence, Long endSequence, boolean withSerial) 获取某个序号以后的更新操作记录
SortedMap<K,V>	headMap(K toKey)
boolean	isEmpty()
RocksMap.RocksMapIterator<K,V>	iterator() 构造一个迭代器
RocksMap.RocksMapIterator<K,V>	iterator(int size) 构造一个有范围的迭代器
RocksMap.RocksMapIterator<K,V>	iterator(int skipSize, int size) 构造一个有范围的迭代器
RocksMap.RocksMapIterator<K,V>	iterator(K fromKey, K toKey) 构造一个有范围的迭代器
RocksMap.RocksMapIterator<K,V>	iterator(K fromKey, K toKey, int skipSize, int size) 构造一个有范围的迭代器
boolean	keyMayExists(K key) 判断 key 是否不存在
Set	keySet() 数据拷贝到内存中, 所以对这个 Set 的修改不会在 Rocksdb 中生效
K	lastKey()
V	lock(Object key) 获取并锁定, 默认独占模式
V	lock(Object key, boolean exclusive) 获取并加锁
Object	put(Object key, Object value)
Object	put(Object key, Object value, boolean isRetVal)
void	putAll(Map m)
V	putIfAbsent(K key, V value)
V	remove(Object key)
V	remove(Object key, boolean isRetVal) 删除某个 key
void	removeAll(Collection<K> keys)
void	removeRange(K fromKey, K toKey) Removes the database entries in the range ["beginKey", "endKey"), i.e., including "beginKey" and excluding "endKey".
void	removeRange(K fromKey, K toKey, boolean useTransaction) Removes the database entries in the range ["beginKey", "endKey"), i.e., including "beginKey" and excluding "endKey".
boolean	replace(K key, V oldValue, V newValue)
static void	restore(int backupId)
static void	restore(int backupId, String dbName, org.rocksdb.BackupableDBOptions backupableDBOptions, Boolean keepLogfile) 从指定备份恢复数据
static void	restoreFromLatestBackup()
static void	restoreFromLatestBackup(String dbName, org.rocksdb.BackupableDBOptions backupableDBOptions, Boolean keepLogfile) 从最后一次备份恢复数据
void	rollback() 事务回滚
void	rollback(boolean all) 事务回滚
void	rollbackSavePoint()
void	savePoint()
int	savePointCount()
void	scan(Function<RocksMap.RocksMapEntry<K,V>,Boolean> checker) 数据清理执行器
void	scan(Function<RocksMap.RocksMapEntry<K,V>,Boolean> checker, boolean disableWal) 数据清理执行器
void	scan(K fromKey, K toKey, Function<RocksMap.RocksMapEntry<K,V>,Boolean> checker) 数据清理执行器
void	scan(K fromKey, K toKey, Function<RocksMap.RocksMapEntry<K,V>,Boolean> checker, boolean disableWal) 数据清理执行器
static byte[]	serialize(Object obj)
static void	setDefaultDbPath(String defaultDbPath) 设置默认数存储据路径
static void	setDefaultWalPath(String defaultWalPath) 设置WAL数存储据路径
void	setTransactionLockTimeout(int transactionLockTimeout) 设置事务锁超时时间
int	size()
Map<K,V>	startWith(K key) 按前缀查找关联的 key
Map<K,V>	startWith(K key, int skipSize, int size) 按前缀查找关联的 key
SortedMap<K,V>	subMap(K fromKey, K toKey)
SortedMap<K,V>	tailMap(K fromKey)
void	unlock(Object key) 释放锁
static Object	unserialize(byte[] obj)
Collection	values()
<T> T	withTransaction(Function<RocksMap<K,V>,T> transFunction) 开启式事务模式 (立即失败, 死锁检测,无快照) 同一个线程共线给一个事务 使用内置公共事务通过 savepoint 来失败回滚, 但统一提交, 性能会好很多, 但是由于很多层嵌套的 savepont 在高并发时使用这种方式时回导致提交会慢很多
<T> T	withTransaction(long expire, boolean deadlockDetect, boolean withSnapShot, Function<RocksMap<K,V>,T> transFunction) 开启式事务模式 同一个线程共线给一个事务 使用内置公共事务通过 savepoint 来失败回滚, 但统一提交, 性能会好很多, 但是由于很多层嵌套的 savepont 在高并发时使用这种方式时回导致提交会慢很多

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Map

compute, computeIfAbsent, computeIfPresent, equals, forEach, getOrDefault, hashCode, merge, remove, replace, replaceAll

Field Detail

DEFAULT_COLUMN_FAMILY_NAME

public static final String DEFAULT_COLUMN_FAMILY_NAME

See Also:

Constant Field Values

dbOptions

public transient org.rocksdb.DBOptions dbOptions

readOptions

public transient org.rocksdb.ReadOptions readOptions

writeOptions

public transient org.rocksdb.WriteOptions writeOptions

columnFamilyOptions

public transient org.rocksdb.ColumnFamilyOptions columnFamilyOptions

THREAD_LOCAL_WRITE_BATCH

public static ThreadLocal<org.rocksdb.WriteBatch> THREAD_LOCAL_WRITE_BATCH

Constructor Detail

RocksMap

public RocksMap()

构造方法

RocksMap

public RocksMap(String columnFamilyName)

构造方法

Parameters:

columnFamilyName - 列族名称

RocksMap

public RocksMap(String dbname,
                String columnFamilyName)

构造方法

Parameters:

dbname - 数据库的名称, 基于数据保存目录的相对路径

columnFamilyName - 列族名称

RocksMap

public RocksMap(boolean readOnly)

构造方法

Parameters:

readOnly - 是否以只读模式打开

RocksMap

public RocksMap(String columnFamilyName,
                boolean readOnly)

构造方法

Parameters:

columnFamilyName - 列族名称

readOnly - 是否以只读模式打开

RocksMap

public RocksMap(String dbname,
                String columnFamilyName,
                boolean readOnly)

构造方法

Parameters:

dbname - 数据库的名称, 基于数据保存目录的相对路径

columnFamilyName - 列族名称

readOnly - 是否以只读模式打开

RocksMap

public RocksMap(String dbname,
                String columnFamilyName,
                org.rocksdb.ColumnFamilyOptions columnFamilyOptions,
                org.rocksdb.DBOptions dbOptions,
                org.rocksdb.ReadOptions readOptions,
                org.rocksdb.WriteOptions writeOptions,
                Boolean readOnly)

构造方法

Parameters:

dbname - 数据库的名称, 基于数据保存目录的相对路径

columnFamilyName - 列族名称

dbOptions - DBOptions 配置对象

readOptions - ReadOptions 配置对象

writeOptions - WriteOptions 配置对象

columnFamilyOptions - 列族配置对象

readOnly - 是否以只读模式打开

Method Detail

getDefaultDbPath

public static String getDefaultDbPath()

获取默认数据存储路径

Returns:

默认数存储据路径

setDefaultDbPath

public static void setDefaultDbPath(String defaultDbPath)

设置默认数存储据路径

Parameters:

defaultDbPath - 默认数存储据路径

getDefaultWalPath

public static String getDefaultWalPath()

默认WAL数存储据路径

Returns:

WAL数存储据路径

setDefaultWalPath

public static void setDefaultWalPath(String defaultWalPath)

设置WAL数存储据路径

Parameters:

defaultWalPath - WAL数存储据路径

serialize

public static byte[] serialize(Object obj)

unserialize

public static Object unserialize(byte[] obj)

duplicate

public RocksMap<K,V> duplicate(String cfName)

复制出一个列族不同,但事务共享的 RocksMap

Parameters:

cfName - 列族名称

Returns:

事务共享的 RocksMap

duplicate

public RocksMap<K,V> duplicate(String cfName,
                               boolean shareTransaction)

复制出一个列族不同的 RocksMAp

Parameters:

cfName - 列族名称

shareTransaction - true: 共享事务, false: 不共享事务

Returns:

事务共享的 RocksMap

getDbname

public String getDbname()

getDataPath

public String getDataPath()

getWalPath

public String getWalPath()

getColumnFamilyName

public String getColumnFamilyName()

getReadOnly

public Boolean getReadOnly()

savePointCount

public int savePointCount()

getRocksDB

public org.rocksdb.RocksDB getRocksDB()

createBackupableOption

public static org.rocksdb.BackupableDBOptions createBackupableOption(String dbName,
                                                                     String backupPath)

创建一个备份选项

Parameters:

dbName - db 名称

backupPath - 备份路径, null 使用默认路径

Returns:

BackupableDBOptions 对象

createBackupableOption

public static org.rocksdb.BackupableDBOptions createBackupableOption(String dbName)

createBackupableOption

public static org.rocksdb.BackupableDBOptions createBackupableOption(RocksMap rocksMap)

createBackup

public String createBackup(org.rocksdb.BackupableDBOptions backupableDBOptions,
                           boolean beforeFlush)
                    throws org.rocksdb.RocksDBException

创建一个备份

Parameters:

backupableDBOptions - 备份选项

beforeFlush - 是否在备份前执行 flush

Returns:

备份路径

Throws:

org.rocksdb.RocksDBException - 异常

createBackup

public String createBackup(org.rocksdb.BackupableDBOptions backupableDBOptions)
                    throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

createBackup

public String createBackup()
                    throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

getBackupInfo

public List<org.rocksdb.BackupInfo> getBackupInfo(org.rocksdb.BackupableDBOptions backupableDBOptions)
                                           throws org.rocksdb.RocksDBException

获取备份信息

Parameters:

backupableDBOptions - 备份选线

Returns:

备份信息清单

Throws:

org.rocksdb.RocksDBException - 异常

getBackupInfo

public List<org.rocksdb.BackupInfo> getBackupInfo()
                                           throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

restoreFromLatestBackup

public static void restoreFromLatestBackup(String dbName,
                                           org.rocksdb.BackupableDBOptions backupableDBOptions,
                                           Boolean keepLogfile)
                                    throws org.rocksdb.RocksDBException

从最后一次备份恢复数据

Parameters:

dbName - 数据库名, 用以确定恢复路径

backupableDBOptions - 备份选项

keepLogfile - 是否覆盖原有 wal 日志

Throws:

org.rocksdb.RocksDBException - 异常

restoreFromLatestBackup

public static void restoreFromLatestBackup()
                                    throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

restore

public static void restore(int backupId,
                           String dbName,
                           org.rocksdb.BackupableDBOptions backupableDBOptions,
                           Boolean keepLogfile)
                    throws org.rocksdb.RocksDBException

从指定备份恢复数据

Parameters:

backupId - 备份 id 标识

dbName - 数据库名, 用以确定恢复路径

backupableDBOptions - 备份选项

keepLogfile - 是否覆盖原有 wal 日志

Throws:

org.rocksdb.RocksDBException - 异常

restore

public static void restore(int backupId)
                    throws org.rocksdb.RocksDBException

Throws:

org.rocksdb.RocksDBException

getColumnFamilyId

public int getColumnFamilyId()

compact

public void compact()

compactRange

public void compactRange(K start,
                         K end)

getProperty

public String getProperty(String columnFamilyName,
                          String name)

getProperty

public String getProperty(String name)

getLastSequence

public Long getLastSequence()

获取最后的序号

Returns:

返回最后的日志序号

getWalSince

public List<RocksMap.RocksWalRecord> getWalSince(Long sequenceNumber,
                                                 boolean withSerial)

获取某个序号以后的更新操作记录

Parameters:

sequenceNumber - 序号

withSerial - 是否进行序列化行为

Returns:

日志记录集合

getWalSince

public List<RocksMap.RocksWalRecord> getWalSince(Long startSequence,
                                                 BiFunction<Integer,Integer,Boolean> filter,
                                                 boolean withSerial)

获取某个序号以后的更新操作记录

Parameters:

startSequence - 起始序号

filter - 过滤器,用来过滤可用的操作类型和列族

withSerial - 是否进行反序列化

Returns:

日志记录集合

getWalSince

public List<RocksMap.RocksWalRecord> getWalSince(Long startSequence,
                                                 Long endSequence,
                                                 boolean withSerial)

获取某个序号以后的更新操作记录

Parameters:

startSequence - 起始序号

endSequence - 结束序号

withSerial - 是否进行反序列化

Returns:

日志记录集合

getWalBetween

public List<RocksMap.RocksWalRecord> getWalBetween(Long startSequence,
                                                   Long endSequence,
                                                   BiFunction<Integer,Integer,Boolean> filter,
                                                   boolean withSerial)

获取某个序号以后的更新操作记录

Parameters:

startSequence - 起始序号

endSequence - 结束序号

filter - 过滤器,用来过滤可用的操作类型和列族

withSerial - 是否进行反序列化

Returns:

日志记录集合

getColumnFamilyId

public int getColumnFamilyId(String columnFamilyName)

choseColumnFamily

public RocksMap<K,V> choseColumnFamily(String cfName)

在多个 Columnt 之间切换

Parameters:

cfName - columnFamily 的名称

Returns:

RocksMap 对象

getTransactionLockTimeout

public int getTransactionLockTimeout()

获取事务锁超时时间

Returns:

事务锁超时时间

setTransactionLockTimeout

public void setTransactionLockTimeout(int transactionLockTimeout)

设置事务锁超时时间

Parameters:

transactionLockTimeout - 事务锁超时时间

withTransaction

public <T> T withTransaction(Function<RocksMap<K,V>,T> transFunction)

开启式事务模式 (立即失败, 死锁检测,无快照) 同一个线程共线给一个事务 使用内置公共事务通过 savepoint 来失败回滚, 但统一提交, 性能会好很多, 但是由于很多层嵌套的 savepont 在高并发时使用这种方式时回导致提交会慢很多

Type Parameters:

T - 范型

Parameters:

transFunction - 事务执行器, 返回 Null 则事务回滚, 其他则事务提交

Returns:

非 null: 事务成功, null: 事务失败

withTransaction

public <T> T withTransaction(long expire,
                             boolean deadlockDetect,
                             boolean withSnapShot,
                             Function<RocksMap<K,V>,T> transFunction)

开启式事务模式 同一个线程共线给一个事务 使用内置公共事务通过 savepoint 来失败回滚, 但统一提交, 性能会好很多, 但是由于很多层嵌套的 savepont 在高并发时使用这种方式时回导致提交会慢很多

Type Parameters:

T - 范型

Parameters:

expire - 提交时锁超时时间

deadlockDetect - 死锁检测是否打开

withSnapShot - 是否启用快照事务

transFunction - 事务执行器, 返回 Null 则事务回滚, 其他则事务提交

Returns:

非 null: 事务成功, null: 事务失败

beginTransaction

public void beginTransaction()

开启事务 同一个线程共线给一个事务 默认: 锁提交等待时间-1, 死锁检测:true, 是否启用快照事务: false

beginTransaction

public void beginTransaction(long expire,
                             boolean deadlockDetect,
                             boolean withSnapShot)

开启事务 同一个线程共线给一个事务 事务都是读事务，无论操作的记录间是否有交集，都不会锁定。 事务包含读、写事务： 所有的读事务不会锁定，读到的数据取决于snapshot设置。 写事务之间如果不存在记录交集，不会锁定。 写事务之间如果存在记录交集，此时如果未设置snapshot，则交集部分的记录是可以串行提交的。如果设置了snapshot，则第一个写事务(写锁队列的head)会成功，其他写事务会失败(之前的事务修改了该记录的情况下)。

Parameters:

expire - 提交时锁超时时间

deadlockDetect - 死锁检测是否打开

withSnapShot - 是否启用快照事务

getTransaction

public org.rocksdb.Transaction getTransaction()

savePoint

public void savePoint()

rollbackSavePoint

public void rollbackSavePoint()

commit

public void commit()

事务提交

rollback

public void rollback()

事务回滚

rollback

public void rollback(boolean all)

事务回滚

Parameters:

all - true: 直接彻底回滚当前事务, false: 回滚到上一个 savepoint

comparator

public Comparator<? super K> comparator()

Specified by:

comparator in interface SortedMap<K,V>

subMap

public SortedMap<K,V> subMap(K fromKey,
                             K toKey)

Specified by:

subMap in interface SortedMap<K,V>

tailMap

public SortedMap<K,V> tailMap(K fromKey)

Specified by:

tailMap in interface SortedMap<K,V>

headMap

public SortedMap<K,V> headMap(K toKey)

Specified by:

headMap in interface SortedMap<K,V>

firstKey

public K firstKey()

Specified by:

firstKey in interface SortedMap<K,V>

lastKey

public K lastKey()

Specified by:

lastKey in interface SortedMap<K,V>

size

public int size()

Specified by:

size in interface Map<K,V>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface Map<K,V>

containsKey

public boolean containsKey(Object key)

Specified by:

containsKey in interface Map<K,V>

containsValue

public boolean containsValue(Object value)

Specified by:

containsValue in interface Map<K,V>

lock

public V lock(Object key)

获取并锁定, 默认独占模式

Parameters:

key - 将被加锁的 key

Returns:

key 对应的 value

unlock

public void unlock(Object key)

释放锁

Parameters:

key - 将被释放锁的 key

lock

public V lock(Object key,
              boolean exclusive)

获取并加锁

Parameters:

key - 将被加锁的 key

exclusive - 是否独占模式

Returns:

key 对应的 value

get

public V get(Object key)

Specified by:

get in interface Map<K,V>

getAll

public List<V> getAll(Collection<K> keys)

empty

public void empty(Object key)

put

public Object put(Object key,
                  Object value,
                  boolean isRetVal)

put

public Object put(Object key,
                  Object value)

Specified by:

put in interface Map<K,V>

putIfAbsent

public V putIfAbsent(K key,
                     V value)

Specified by:

putIfAbsent in interface Map<K,V>

keyMayExists

public boolean keyMayExists(K key)

判断 key 是否不存在

Parameters:

key - key对象

Returns:

当返回 false 的时候 key 一定不存在, 当返回 true 的时候, key 有可能不存在, 参考 boomfilter

replace

public boolean replace(K key,
                       V oldValue,
                       V newValue)

Specified by:

replace in interface Map<K,V>

remove

public V remove(Object key,
                boolean isRetVal)

删除某个 key

Parameters:

key - key 对象

isRetVal - 是否返回被移除的 value

Returns:

返回值, 在 isRetVal=false 时, 总是为 null

remove

public V remove(Object key)

Specified by:

remove in interface Map<K,V>

removeAll

public void removeAll(Collection<K> keys)

removeRange

public void removeRange(K fromKey,
                        K toKey)

Removes the database entries in the range ["beginKey", "endKey"), i.e., including "beginKey" and excluding "endKey". a non-OK status on error. It is not an error if no keys exist in the range ["beginKey", "endKey").

Parameters:

fromKey - 其实 key

toKey - 结束 key

removeRange

public void removeRange(K fromKey,
                        K toKey,
                        boolean useTransaction)

Removes the database entries in the range ["beginKey", "endKey"), i.e., including "beginKey" and excluding "endKey". a non-OK status on error. It is not an error if no keys exist in the range ["beginKey", "endKey").

Parameters:

fromKey - 其实 key

toKey - 结束 key

useTransaction - 是否嵌套至已有事务

putAll

public void putAll(Map m)

Specified by:

putAll in interface Map<K,V>

flush

public void flush(boolean sync,
                  boolean allowStall)

刷新数据到文件

Parameters:

sync - 同步刷新

allowStall - 是否允许写入暂停

flush

public void flush(boolean sync)

刷新数据到文件

Parameters:

sync - 同步刷新

flush

public void flush()

刷新数据到文件

flushWal

public void flushWal(boolean sync)

刷新WAL数据到文件

Parameters:

sync - 同步刷新

flushWal

public void flushWal()

clear

public void clear()

Specified by:

clear in interface Map<K,V>

drop

public void drop()

删除这个列族

keySet

public Set keySet()

数据拷贝到内存中, 所以对这个 Set 的修改不会在 Rocksdb 中生效

Specified by:

keySet in interface Map<K,V>

Specified by:

keySet in interface SortedMap<K,V>

Returns:

保存了 Key 的 set

values

public Collection values()

Specified by:

values in interface Map<K,V>

Specified by:

values in interface SortedMap<K,V>

entrySet

public Set<Map.Entry<K,V>> entrySet()

数据拷贝到内存中, 所以对这个 Set 的修改不会在 Rocksdb 中生效

Specified by:

entrySet in interface Map<K,V>

Specified by:

entrySet in interface SortedMap<K,V>

Returns:

保存了 Entry 的 set

startWith

public Map<K,V> startWith(K key)

按前缀查找关联的 key

Parameters:

key - key 的前缀

Returns:

找到的 Map 数据

startWith

public Map<K,V> startWith(K key,
                          int skipSize,
                          int size)

按前缀查找关联的 key

Parameters:

key - key 的前缀

skipSize - 跳过记录数

size - 返回记录数

Returns:

找到的 Map 数据

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

iterator

public RocksMap.RocksMapIterator<K,V> iterator(K fromKey,
                                               K toKey,
                                               int skipSize,
                                               int size)

构造一个有范围的迭代器

Parameters:

fromKey - 起始 key

toKey - 结束 key

size - 迭代的记录数

skipSize - 跳过记录数

size - 返回记录数

Returns:

迭代器对象

iterator

public RocksMap.RocksMapIterator<K,V> iterator(K fromKey,
                                               K toKey)

构造一个有范围的迭代器

Parameters:

fromKey - 起始 key

toKey - 结束 key

Returns:

迭代器对象

iterator

public RocksMap.RocksMapIterator<K,V> iterator(int skipSize,
                                               int size)

构造一个有范围的迭代器

Parameters:

skipSize - 跳过记录数

size - 返回记录数

Returns:

迭代器对象

iterator

public RocksMap.RocksMapIterator<K,V> iterator(int size)

构造一个有范围的迭代器

Parameters:

size - 迭代的记录数

Returns:

迭代器对象

iterator

public RocksMap.RocksMapIterator<K,V> iterator()

构造一个迭代器

Returns:

迭代器对象

scan

public void scan(Function<RocksMap.RocksMapEntry<K,V>,Boolean> checker)

数据清理执行器

Parameters:

checker - 数据清理逻辑, true: 继续扫描, false: 停止扫描

scan

public void scan(Function<RocksMap.RocksMapEntry<K,V>,Boolean> checker,
                 boolean disableWal)

数据清理执行器

Parameters:

checker - 数据清理逻辑, true: 继续扫描, false: 停止扫描

disableWal - 是否屏蔽 wal

scan

public void scan(K fromKey,
                 K toKey,
                 Function<RocksMap.RocksMapEntry<K,V>,Boolean> checker)

数据清理执行器

Parameters:

fromKey - 起始 key

toKey - 结束 key

checker - 数据清理逻辑, true: 继续扫描, false: 停止扫描

scan

public void scan(K fromKey,
                 K toKey,
                 Function<RocksMap.RocksMapEntry<K,V>,Boolean> checker,
                 boolean disableWal)

数据清理执行器

Parameters:

fromKey - 起始 key

toKey - 结束 key

checker - 数据清理逻辑, true: 继续扫描, false: 停止扫描

disableWal - 是否屏蔽 wal