org.voovan.tools.collection

Class RocksMap.RocksWalRecord

java.lang.Object

org.voovan.tools.collection.RocksMap.RocksWalRecord

Enclosing class:

RocksMap<K,V>

public static class RocksMap.RocksWalRecord
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static int	TYPE_BEGIN_PERSISTED_PREPARE_XID
static int	TYPE_BEGIN_PREPARE_XID
static int	TYPE_BEGIN_UNPREPARE_XID
static int	TYPE_BLOB_INDEX
static int	TYPE_COLUMNFAMILY_BLOB_INDEX
static int	TYPE_COLUMNFAMILY_DELETION
static int	TYPE_COLUMNFAMILY_MERGE
static int	TYPE_COLUMNFAMILY_RANGE_DELETION
static int	TYPE_COLUMNFAMILY_SINGLE_DELETION
static int	TYPE_COLUMNFAMILY_VALUE
static int	TYPE_COMMIT_XID
static int	TYPE_DELETION
static int[]	TYPE_ELEMENT_COUNT
static int	TYPE_END_PREPARE_XID
static int	TYPE_LOGDATA
static int	TYPE_MERGE
static int	TYPE_NOOP
static int	TYPE_RANGE_DELETION
static int	TYPE_ROLLBACK_XID
static int	TYPE_SINGLE_DELETION
static int	TYPE_VALUE

Method Summary

Modifier and Type	Method and Description
ArrayList<Object>	getChunks()
int	getColumnFamilyId()
long	getSequence()
int	getType()
static List<RocksMap.RocksWalRecord>	parse(ByteBuffer byteBuffer, BiFunction<Integer,Integer,Boolean> filter, boolean withSerial) 解析某个序号以后的更新操作记录
static List<RocksMap.RocksWalRecord>	parse(ByteBuffer byteBuffer, boolean withSerial) 解析某个序号以后的更新操作记录
static RocksMap.RocksWalRecord	parseOperation(ByteBuffer byteBuffer, long sequence, BiFunction<Integer,Integer,Boolean> filter, boolean withSerial) 解析某个序号的操作记录
static RocksMap.RocksWalRecord	parseOperation(ByteBuffer byteBuffer, long sequence, boolean withSerial) 解析某个序号的操作记录

Methods inherited from class java.lang.Object

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

Field Detail

TYPE_DELETION

public static int TYPE_DELETION

TYPE_VALUE

public static int TYPE_VALUE

TYPE_MERGE

public static int TYPE_MERGE

TYPE_LOGDATA

public static int TYPE_LOGDATA

TYPE_COLUMNFAMILY_DELETION

public static int TYPE_COLUMNFAMILY_DELETION

TYPE_COLUMNFAMILY_VALUE

public static int TYPE_COLUMNFAMILY_VALUE

TYPE_COLUMNFAMILY_MERGE

public static int TYPE_COLUMNFAMILY_MERGE

TYPE_SINGLE_DELETION

public static int TYPE_SINGLE_DELETION

TYPE_COLUMNFAMILY_SINGLE_DELETION

public static int TYPE_COLUMNFAMILY_SINGLE_DELETION

TYPE_BEGIN_PREPARE_XID

public static int TYPE_BEGIN_PREPARE_XID

TYPE_END_PREPARE_XID

public static int TYPE_END_PREPARE_XID

TYPE_COMMIT_XID

public static int TYPE_COMMIT_XID

TYPE_ROLLBACK_XID

public static int TYPE_ROLLBACK_XID

TYPE_NOOP

public static int TYPE_NOOP

TYPE_COLUMNFAMILY_RANGE_DELETION

public static int TYPE_COLUMNFAMILY_RANGE_DELETION

TYPE_RANGE_DELETION

public static int TYPE_RANGE_DELETION

TYPE_COLUMNFAMILY_BLOB_INDEX

public static int TYPE_COLUMNFAMILY_BLOB_INDEX

TYPE_BLOB_INDEX

public static int TYPE_BLOB_INDEX

TYPE_BEGIN_PERSISTED_PREPARE_XID

public static int TYPE_BEGIN_PERSISTED_PREPARE_XID

TYPE_BEGIN_UNPREPARE_XID

public static int TYPE_BEGIN_UNPREPARE_XID

TYPE_ELEMENT_COUNT

public static int[] TYPE_ELEMENT_COUNT

Method Detail

getSequence

public long getSequence()

getType

public int getType()

getColumnFamilyId

public int getColumnFamilyId()

getChunks

public ArrayList<Object> getChunks()

parse

public static List<RocksMap.RocksWalRecord> parse(ByteBuffer byteBuffer,
                                                  boolean withSerial)

解析某个序号以后的更新操作记录

Parameters:

byteBuffer - 字节缓冲器

withSerial - 是否进行反序列化

Returns:

日志记录集合

parse

public static List<RocksMap.RocksWalRecord> parse(ByteBuffer byteBuffer,
                                                  BiFunction<Integer,Integer,Boolean> filter,
                                                  boolean withSerial)

解析某个序号以后的更新操作记录

Parameters:

byteBuffer - 字节缓冲器

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

withSerial - 是否进行反序列化

Returns:

日志记录集合

parseOperation

public static RocksMap.RocksWalRecord parseOperation(ByteBuffer byteBuffer,
                                                     long sequence,
                                                     boolean withSerial)

解析某个序号的操作记录

Parameters:

byteBuffer - 字节缓冲器

sequence - 序号

withSerial - 是否进行反序列化

Returns:

日志记录集合

parseOperation

public static RocksMap.RocksWalRecord parseOperation(ByteBuffer byteBuffer,
                                                     long sequence,
                                                     BiFunction<Integer,Integer,Boolean> filter,
                                                     boolean withSerial)

解析某个序号的操作记录

Parameters:

byteBuffer - 字节缓冲器

sequence - 序号

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

withSerial - 是否进行反序列化

Returns:

日志记录集合