public class RemoteScanStore extends RemoteStore implements ScanPersistence
Modifier and Type | Class and Description |
---|---|
class |
RemoteScanStore.CleanUpCursor |
LocalStoreImpl.RecentCacheStats
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<Long,Cursor> |
cursorMap |
protected static org.apache.commons.logging.Log |
logger |
protected AtomicLong |
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 |
---|
RemoteScanStore(String filename,
Serializer serializer,
boolean delay,
int mode) |
RemoteScanStore(String filename,
Serializer serializer,
boolean delay,
int mode,
boolean isSorted) |
RemoteScanStore(String filename,
Serializer serializer,
int mode) |
RemoteScanStore(String filename,
Serializer serializer,
String path,
boolean delay,
voldemort.store.cachestore.BlockSize blockSize,
int mode) |
RemoteScanStore(String filename,
Serializer serializer,
String path,
boolean delay,
voldemort.store.cachestore.BlockSize blockSize,
int mode,
boolean isSorted) |
Modifier and Type | Method and Description |
---|---|
protected Iterator |
getIterator(CursorPara cursorPara) |
voldemort.store.cachestore.impl.SortedCacheStore |
getSortedStore() |
protected void |
init() |
boolean |
isSorted() |
protected List<voldemort.store.cachestore.voldeimpl.KeyValue> |
nextBatch(Cursor cursor,
CursorPara cursorPara) |
protected List<voldemort.store.cachestore.voldeimpl.KeyValue> |
nextBatchQuery(Cursor cursor,
CursorPara cursorPara) |
void |
nextCursor(CursorPara cursorPara) |
List<voldemort.store.cachestore.voldeimpl.KeyValue> |
scan(voldemort.store.cachestore.Key from) |
List<voldemort.store.cachestore.voldeimpl.KeyValue> |
scan(voldemort.store.cachestore.Key from,
voldemort.store.cachestore.Key to) |
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, startWriteThread, 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 AtomicLong seqno
protected ConcurrentMap<Long,Cursor> cursorMap
public RemoteScanStore(String filename, Serializer serializer, int mode)
public RemoteScanStore(String filename, Serializer serializer, String path, boolean delay, voldemort.store.cachestore.BlockSize blockSize, int mode)
public RemoteScanStore(String filename, Serializer serializer, String path, boolean delay, voldemort.store.cachestore.BlockSize blockSize, int mode, boolean isSorted)
public RemoteScanStore(String filename, Serializer serializer, boolean delay, int mode)
public RemoteScanStore(String filename, Serializer serializer, boolean delay, int mode, boolean isSorted)
protected void init()
init
in class LocalStoreImpl
public boolean isSorted()
public List<voldemort.store.cachestore.voldeimpl.KeyValue> scan(voldemort.store.cachestore.Key from, voldemort.store.cachestore.Key to)
scan
in interface ScanPersistence
public List<voldemort.store.cachestore.voldeimpl.KeyValue> scan(voldemort.store.cachestore.Key from)
scan
in interface ScanPersistence
public voldemort.store.cachestore.impl.SortedCacheStore getSortedStore()
public void nextCursor(CursorPara cursorPara)
protected Iterator getIterator(CursorPara cursorPara)
protected List<voldemort.store.cachestore.voldeimpl.KeyValue> nextBatchQuery(Cursor cursor, CursorPara cursorPara)
protected List<voldemort.store.cachestore.voldeimpl.KeyValue> nextBatch(Cursor cursor, CursorPara cursorPara)
Copyright © 2016. All rights reserved.