public class RocksDBWALClient extends LocalWALClient
COMMITTED, UNCOMMITTED, WAL_LOCAL_READ_MODEDEFAULT_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 and Description |
|---|
RocksDBWALClient() |
| Modifier and Type | Method and Description |
|---|---|
LocalWALClient |
configure(Map<String,String> conf,
String nodeId,
WAL localWAL,
Object storageObject) |
void |
processData(List<byte[]> list) |
getPos, getWal, iteratepublic LocalWALClient configure(Map<String,String> conf, String nodeId, WAL localWAL, Object storageObject) throws IOException
configure in class LocalWALClientIOExceptionpublic void processData(List<byte[]> list)
processData in class LocalWALClientCopyright © 2018. All rights reserved.