com.srotya.minuteman.rocksdb

Class RocksDBWALClient

java.lang.Object

com.srotya.minuteman.wal.WALClient

com.srotya.minuteman.wal.LocalWALClient

com.srotya.minuteman.rocksdb.RocksDBWALClient

All Implemented Interfaces:

Runnable

public class RocksDBWALClient
extends LocalWALClient

Field Summary

Fields inherited from class com.srotya.minuteman.wal.LocalWALClient

COMMITTED, UNCOMMITTED, WAL_LOCAL_READ_MODE

Fields inherited from class com.srotya.minuteman.wal.WALClient

DEFAULT_MAX_FETCH_BYTES, DEFAULT_WAL_CLIENT_EMPTY_WAIT, DEFAULT_WAL_CLIENT_ERROR_WAIT, errorRetryWait, MAX_FETCH_BYTES, maxFetchBytes, nodeId, offset, retryWait, wal, WAL_CLIENT_EMPTY_WAIT, WAL_CLIENT_ERROR_WAIT

Constructor Summary

Constructors

Constructor and Description
RocksDBWALClient()

Method Summary

Modifier and Type	Method and Description
LocalWALClient	configure(Map<String,String> conf, String nodeId, WAL localWAL, Object storageObject)
void	processData(List<byte[]> list)

Methods inherited from class com.srotya.minuteman.wal.LocalWALClient

getPos, getWal, iterate

Methods inherited from class com.srotya.minuteman.wal.WALClient

configure, getCtrl, run, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

RocksDBWALClient

public RocksDBWALClient()

Method Detail

configure

public LocalWALClient configure(Map<String,String> conf,
                                String nodeId,
                                WAL localWAL,
                                Object storageObject)
                         throws IOException

Overrides:

configure in class LocalWALClient

Throws:

IOException

processData

public void processData(List<byte[]> list)

Overrides:

processData in class LocalWALClient