org.voovan.tools.collection

Class RocksMap.RocksWalReader

java.lang.Object

org.voovan.tools.collection.RocksMap.RocksWalReader

Enclosing class:

RocksMap<K,V>

public static class RocksMap.RocksWalReader
extends Object

按批次读取Wal, wal 读取器

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	RocksMap.RocksWalReader.RocksWalProcessor 日志处理器

Constructor Summary

Constructors

Constructor and Description
RocksWalReader(Object mark, RocksMap rocksMap, int batchSeqsize)

Method Summary

Modifier and Type	Method and Description
int	getBatchSeqsize()
List<Integer>	getColumnFamily()
long	getLastSequence()
List<Integer>	getWalTypes()
void	processing(RocksMap.RocksWalReader.RocksWalProcessor rocksWalProcessor)
void	setColumnFamily(List<Integer> columnFamilys)
void	setWalTypes(List<Integer> walTypes)

Methods inherited from class java.lang.Object

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

Constructor Detail

RocksWalReader

public RocksWalReader(Object mark,
                      RocksMap rocksMap,
                      int batchSeqsize)

Method Detail

getLastSequence

public long getLastSequence()

getColumnFamily

public List<Integer> getColumnFamily()

setColumnFamily

public void setColumnFamily(List<Integer> columnFamilys)

getBatchSeqsize

public int getBatchSeqsize()

getWalTypes

public List<Integer> getWalTypes()

setWalTypes

public void setWalTypes(List<Integer> walTypes)

processing

public void processing(RocksMap.RocksWalReader.RocksWalProcessor rocksWalProcessor)