public class ClusterStore extends RemoteScanStore
RemoteScanStore.CleanUpCursor
LocalStoreImpl.RecentCacheStats
Modifier and Type | Field and Description |
---|---|
protected ClusterNodes |
clusterNodes |
protected static org.apache.commons.logging.Log |
logger |
cursorMap, seqno
blockValue, DELAY_TIMEOUT, deleteTrigger, deleteTriggerName, delta, embeddedSerializer, getTrigger, getTriggerName, putTrigger, putTriggerName, threadLoader
blockSize, delay, filename, getFreq, getTimes, isSorted, logPath, logQueue, mode, needLogThread, needPstThread, path, pstQueue, putFreq, putTimes, recentCacheStats, removeFreq, removeTimes, replicaClientList, serializer, statList, store
Constructor and Description |
---|
ClusterStore(String filename,
Serializer serializer,
boolean delay,
int mode,
ClusterNodes clusterNodes) |
ClusterStore(String filename,
Serializer serializer,
int mode,
ClusterNodes clusterNodes) |
ClusterStore(String filename,
Serializer serializer,
String path,
boolean delay,
voldemort.store.cachestore.BlockSize blockSize,
int mode,
boolean isSorted,
ClusterNodes clusterNodes) |
ClusterStore(String filename,
Serializer serializer,
String path,
boolean delay,
voldemort.store.cachestore.BlockSize blockSize,
int mode,
ClusterNodes clusterNodes) |
Modifier and Type | Method and Description |
---|---|
ClusterNodes |
getClusterNodes() |
List<String> |
getReplicaCluster(ClusterNodes clusterNodes,
String url) |
void |
startReplica(String logPath,
String localUrl) |
void |
startWriteThread(int no) |
getIterator, getSortedStore, init, isSorted, nextBatch, nextBatchQuery, nextCursor, scan, scan
close, decodeRecord, decodeVersion, encodeRV, get, getDeleteTrigger, getDelta, getGetTrigger, getPutTrigger, insert, multiGets, multiPuts, multiRemove, put, put, reloadTrigger, remove, setBlockValue, setDeleteTrigger, setDelta, setGetTrigger, setGetTrigger, setPutTrigger, setupTrigger2Cache, startPstReplica, startReplica
backup, containsKey, createPath, dumpLinkQueue, getBackupDuration, getBackupEndTime, getBackupStartTime, getBlockOverflow, getCache, getCacheHitPercentage, getCacheHits, getCacheMisses, getDelayQueueCapacity, getFileSize, getGetFreq, getGetMetric, getGetTimes, getKeyIterator, getPackDuration, getPackEndTime, getPackStartTime, getPuregeDuration, getPurgeEndTime, getPurgeStartTime, getPurgeTrigger, getPutFreq, getPutMetric, getPutTimes, getRecentCacheHitPercentage, getRecentCacheHits, getRecentCacheMisses, getRecentCount, getRecentEmpty, getRecentSkips, getRemote, getRemoveFreq, getRemoveMetric, getRemoveTimes, getReplicaClientInfo, getReplicaClientList, getSerializer, getStore, getStoreInfo, getStoreName, getStoreStat, getTotalActiveRecords, getTotalActiveRecordsPercentage, getTotalDeletedRecords, getTotalRecords, getWriteBackThread, init, pack, purge, putInMap, resetIndex, restartReplicaClients, setPurge, setReplicaBatcSize, shutdownClient, size, startPstLogThread, startWriteLogThread, stopReplicaClients, validateLink
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
multiGets, multiPuts
get, insert, put
backup, close, getKeyIterator, pack, put, remove, size
protected static final org.apache.commons.logging.Log logger
protected ClusterNodes clusterNodes
public ClusterStore(String filename, Serializer serializer, int mode, ClusterNodes clusterNodes)
public ClusterStore(String filename, Serializer serializer, String path, boolean delay, voldemort.store.cachestore.BlockSize blockSize, int mode, ClusterNodes clusterNodes)
public ClusterStore(String filename, Serializer serializer, String path, boolean delay, voldemort.store.cachestore.BlockSize blockSize, int mode, boolean isSorted, ClusterNodes clusterNodes)
public ClusterStore(String filename, Serializer serializer, boolean delay, int mode, ClusterNodes clusterNodes)
public List<String> getReplicaCluster(ClusterNodes clusterNodes, String url)
public ClusterNodes getClusterNodes()
public void startReplica(String logPath, String localUrl)
logPath
- - path for WAGpublic void startWriteThread(int no)
startWriteThread
in class LocalStoreImpl
Copyright © 2016. All rights reserved.