A B C D E F G H I J K L M N P Q R S T V W 

A

addRemoteStore(String, String, int) - Method in class com.sm.store.server.RemoteStoreServer
 
addRemoteStore(RemoteStore) - Method in class com.sm.store.server.RemoteStoreServer
 
addStore(String, String, int) - Method in class com.sm.store.server.StoreCallBack
 
addStore(RemoteStore) - Method in class com.sm.store.server.StoreCallBack
 
AdminClusterStore - Class in com.sm.store.server
 
AdminClusterStore(String, Serializer, String, boolean, BlockSize, int, ClusterNodes) - Constructor for class com.sm.store.server.AdminClusterStore
 
AdminStore - Class in com.sm.store.server
 
AdminStore(List<ClusterNodes>, List<StoreConfig>) - Constructor for class com.sm.store.server.AdminStore
 

B

backup(String, int) - Method in class com.sm.localstore.impl.LocalStoreImpl
 
BLOCK_SIZE - Variable in class com.sm.connector.server.ServerStore
 
blockSize - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
blockValue - Variable in class com.sm.store.server.RemoteStore
 
BUF_SIZE - Static variable in class com.sm.connector.server.MRStore
 
buildMap(Map<String, RemoteStore>) - Method in class com.sm.store.server.ClusterStoreServer
 

C

callBack - Variable in class com.sm.store.server.ClusterStoreServer
 
callback - Variable in class com.sm.store.server.grizzly.StoreServerFilter
 
callBack - Variable in class com.sm.store.server.RemoteStoreServer
 
callback - Variable in class com.sm.store.server.StoreServerHandler
 
checkIndexBuf() - Method in class com.sm.connector.server.MRStore
check index buffer has enough data, if not read next buffer
checkValue(StoreParas) - Method in class com.sm.store.server.StoreCallBack
 
close() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
close() - Method in class com.sm.store.server.RemoteStore
close remote server, replica client and server if it existed
clusterNo - Variable in class com.sm.store.server.ClusterStoreServer
 
clusterNodes - Variable in class com.sm.store.server.ClusterStore
 
clusterNodes - Variable in class com.sm.store.server.ClusterStoreCallBack
 
ClusterServer - Class in com.sm.store.server
 
ClusterServer() - Constructor for class com.sm.store.server.ClusterServer
 
ClusterServerHandler - Class in com.sm.store.server
 
ClusterServerHandler(TCPCallBack, int, int, Serializer) - Constructor for class com.sm.store.server.ClusterServerHandler
 
ClusterStore - Class in com.sm.store.server
 
ClusterStore(String, Serializer, int, ClusterNodes) - Constructor for class com.sm.store.server.ClusterStore
 
ClusterStore(String, Serializer, String, boolean, BlockSize, int, ClusterNodes) - Constructor for class com.sm.store.server.ClusterStore
 
ClusterStore(String, Serializer, String, boolean, BlockSize, int, boolean, ClusterNodes) - Constructor for class com.sm.store.server.ClusterStore
 
ClusterStore(String, Serializer, boolean, int, ClusterNodes) - Constructor for class com.sm.store.server.ClusterStore
 
ClusterStoreCallBack - Class in com.sm.store.server
 
ClusterStoreCallBack(ConcurrentMap<String, RemoteStore>, Serializer, ClusterNodes) - Constructor for class com.sm.store.server.ClusterStoreCallBack
 
ClusterStoreFilter - Class in com.sm.store.server.grizzly
 
ClusterStoreFilter(TCPCallBack, int) - Constructor for class com.sm.store.server.grizzly.ClusterStoreFilter
 
ClusterStoreServer - Class in com.sm.store.server
 
ClusterStoreServer(ClusterServerConfig, Serializer) - Constructor for class com.sm.store.server.ClusterStoreServer
 
colSerialize - Variable in class com.sm.connector.server.ExecMapReduce
 
COLUMN - Static variable in class com.sm.connector.server.ExecMapReduce
 
com.sm - package com.sm
 
com.sm.connector.server - package com.sm.connector.server
 
com.sm.localstore.impl - package com.sm.localstore.impl
 
com.sm.store - package com.sm.store
 
com.sm.store.server - package com.sm.store.server
 
com.sm.store.server.grizzly - package com.sm.store.server.grizzly
 
com.sm.store.server.netty - package com.sm.store.server.netty
 
Config - Static variable in class com.sm.connector.server.MapReduceUtils
 
containsKey(Key) - Method in class com.sm.localstore.impl.LocalStoreImpl
 
createPath(String) - Method in class com.sm.localstore.impl.LocalStoreImpl
make sure the path is exist, otherwise create it
createStoreMap(String) - Method in class com.sm.connector.server.MapReduceUtils
 
cursorMap - Variable in class com.sm.store.server.RemoteScanStore
 

D

dataBuf - Variable in class com.sm.connector.server.MRStore
 
dataOffset - Variable in class com.sm.connector.server.ServerStore
 
dataPos - Variable in class com.sm.connector.server.MRStore
 
decodeRecord(long) - Static method in class com.sm.store.server.RemoteStore
 
decodeVersion(long) - Static method in class com.sm.store.server.RemoteStore
 
delay - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
delay - Variable in class com.sm.store.server.RemoteStoreServer
 
delay - Variable in class com.sm.store.server.StoreCallBack
 
DELAY_TIMEOUT - Static variable in class com.sm.store.server.RemoteStore
 
deleteTrigger - Variable in class com.sm.store.server.RemoteStore
 
deleteTriggerName - Variable in class com.sm.store.server.RemoteStore
 
delta - Variable in class com.sm.store.server.RemoteStore
 
dumpLinkQueue() - Method in class com.sm.localstore.impl.LocalStoreImpl
 

E

embeddedSerializer - Variable in class com.sm.store.server.RemoteStore
 
embeddedSerializer - Variable in class com.sm.store.server.StoreCallBack
 
encodeRV(long, int) - Static method in class com.sm.store.server.RemoteStore
 
error - Variable in class com.sm.store.server.ClusterServerHandler
 
exceptionCaught(ChannelHandlerContext, ExceptionEvent) - Method in class com.sm.store.server.StoreServerHandler
 
ExecMapReduce<T> - Class in com.sm.connector.server
Created by mhsieh on 12/16/15.
ExecMapReduce(Map<String, RemoteStore>, Class<T>, MapReduce<T>) - Constructor for class com.sm.connector.server.ExecMapReduce
 
ExecMapReduce(Map<String, RemoteStore>, Class<T>, MapReduce<T>, Serializer) - Constructor for class com.sm.connector.server.ExecMapReduce
 
ExecMapReduce(Map<String, RemoteStore>, Class<T>, MapReduce<T>, Serializer, String, Filter.Impl) - Constructor for class com.sm.connector.server.ExecMapReduce
 
ExecMapReduce.RunThread - Class in com.sm.connector.server
use StoreConfig.IsUrl to determine which (MRStore or ServerStore) tp create MRStore assume that all records are physical consective
ExecMapReduce.RunThread(CountDownLatch, int, int, T, int, String) - Constructor for class com.sm.connector.server.ExecMapReduce.RunThread
 
execute(String, int, String) - Method in class com.sm.connector.server.ExecMapReduce
 
execute(String, int) - Method in class com.sm.connector.server.ExecMapReduce
 
execute(String, int, int, int) - Method in class com.sm.connector.server.ExecMapReduce
each thread will process 3 of record (end -begin) /noOfThread

F

filename - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
findPath(String) - Method in class com.sm.store.server.ClusterStoreServer
 
findTotal2BatchSize() - Method in class com.sm.connector.server.ServerStore
 
findTotalBlock() - Method in class com.sm.connector.server.ServerStore
 
freq - Variable in class com.sm.store.server.grizzly.StoreServerFilter
 
freq - Variable in class com.sm.store.server.StoreServerHandler
 

G

get(Key) - Method in class com.sm.localstore.impl.LocalStoreImpl
 
get(Key) - Method in class com.sm.store.server.AdminStore
 
get(Key) - Method in class com.sm.store.server.RemoteStore
 
getAllStoreNames() - Method in class com.sm.store.server.ClusterStoreServer
 
getAllStoreNames() - Method in class com.sm.store.server.RemoteStoreServer
 
getBackupDuration() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getBackupEndTime() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getBackupStartTime() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getBlockOverflow() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getCache() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getCacheHitPercentage() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getCacheHits() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getCacheMisses() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getCacheStore() - Method in class com.sm.store.server.AdminStore
 
getCallBack() - Method in class com.sm.store.server.ClusterStoreServer
 
getCluster() - Method in class com.sm.store.server.AdminClusterStore
 
getClusterNo() - Method in class com.sm.store.server.ClusterStoreServer
 
getClusterNodes() - Method in class com.sm.store.server.ClusterStore
 
getClusterNodesList() - Method in class com.sm.store.server.AdminClusterStore
 
getClusterNodesList() - Method in class com.sm.store.server.AdminStore
 
getColumnMap(String) - Method in class com.sm.connector.server.MapReduceUtils
 
getDelayQueueCapacity() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getDeleteTrigger() - Method in class com.sm.store.server.RemoteStore
 
getDelta() - Method in class com.sm.store.server.RemoteStore
 
getEmbeddedSerializer() - Method in class com.sm.store.server.StoreCallBack
 
getFilename() - Method in class com.sm.connector.server.ServerStore
 
getFileSize() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getFreq - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
getFreq() - Method in class com.sm.store.server.grizzly.StoreServerFilter
 
getFreq() - Method in class com.sm.store.server.StoreServerHandler
 
getGetFreq() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getGetMetric() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getGetTimes() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getGetTrigger() - Method in class com.sm.store.server.RemoteStore
 
getGZHandler() - Method in class com.sm.store.server.grizzly.GZClusterStoreServer
 
getGZHandler() - Method in class com.sm.store.server.grizzly.GZRemoteStoreServer
 
getGZServer() - Method in class com.sm.store.server.grizzly.GZClusterStoreServer
 
getGZServer() - Method in class com.sm.store.server.grizzly.GZRemoteStoreServer
 
getHandler() - Method in class com.sm.store.server.ClusterStoreServer
 
getInstance() - Static method in class com.sm.connector.server.MapReduceUtils
 
getIterator() - Method in class com.sm.store.server.QueryIterator
 
getIterator(CursorPara) - Method in class com.sm.store.server.RemoteScanStore
 
getKeyIterator() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getKeyType() - Method in class com.sm.store.server.QueryIterator
 
getLoader() - Method in class com.sm.store.ServerWSHandler
 
getObject(Key) - Method in class com.sm.store.server.AdminClusterStore
 
getObject(Key) - Method in class com.sm.store.server.AdminStore
 
getPackDuration() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getPackEndTime() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getPackStartTime() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getPredicateStack() - Method in class com.sm.store.server.QueryIterator
 
getPuregeDuration() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getPurgeEndTime() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getPurgeStartTime() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getPurgeTrigger() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getPutFreq() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getPutMetric() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getPutTimes() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getPutTrigger() - Method in class com.sm.store.server.RemoteStore
 
getRecentCacheHitPercentage() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getRecentCacheHits() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getRecentCacheHits() - Method in class com.sm.localstore.impl.LocalStoreImpl.RecentCacheStats
 
getRecentCacheMisses() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getRecentCacheMisses() - Method in class com.sm.localstore.impl.LocalStoreImpl.RecentCacheStats
 
getRecentCount() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getRecentCount() - Method in class com.sm.localstore.impl.LocalStoreImpl.RecentCacheStats
 
getRecentEmpty() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getRecentEmpty() - Method in class com.sm.localstore.impl.LocalStoreImpl.RecentCacheStats
 
getRecentSkips() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getRecentSkips() - Method in class com.sm.localstore.impl.LocalStoreImpl.RecentCacheStats
 
getRemote(Key) - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getRemoteStore() - Method in class com.sm.store.server.QueryIterator
 
getRemoteStore(String) - Method in class com.sm.store.server.RemoteStoreServer
 
getRemoteStore(String) - Method in class com.sm.store.server.StoreCallBack
 
getRemoveFreq() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getRemoveMetric() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getRemoveTimes() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getReplicaClientInfo() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getReplicaClientList() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getReplicaCluster(ClusterNodes, String) - Method in class com.sm.store.server.ClusterStore
 
getReplicaServer() - Method in class com.sm.store.server.ClusterStoreServer
 
getSerializer() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getSerializer() - Method in class com.sm.store.server.StoreCallBack
 
getServer() - Method in class com.sm.store.server.ClusterStoreServer
 
getServerConfig() - Method in class com.sm.store.server.AdminClusterStore
 
getServerConfig() - Method in class com.sm.store.server.ClusterStoreServer
 
getSortedStore() - Method in class com.sm.store.server.LocalSortedCacheStore
 
getSortedStore() - Method in class com.sm.store.server.RemoteScanStore
 
getState(int) - Static method in enum com.sm.Service.State
 
getState() - Method in class com.sm.store.server.ClusterStoreServer
 
getStatus() - Method in interface com.sm.Service
 
getStatus() - Method in class com.sm.store.server.ClusterStoreServer
 
getStatus() - Method in class com.sm.store.server.grizzly.GZClusterStoreServer
 
getStore() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getStore(String) - Method in class com.sm.store.server.ClusterStoreServer
 
getStoreConfig() - Method in class com.sm.store.server.AdminClusterStore
 
getStoreConfigList() - Method in class com.sm.store.server.AdminClusterStore
 
getStoreConfigList() - Method in class com.sm.store.server.AdminStore
 
getStoreInfo() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getStoreMaps() - Method in class com.sm.store.server.ClusterStoreServer
 
getStoreMaps() - Method in class com.sm.store.server.StoreCallBack
 
getStoreMaps() - Method in class com.sm.store.ServerWSHandler
 
getStoreName() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getStoreStat() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getTCPHandler() - Method in class com.sm.store.server.RemoteStoreServer
 
getTCPServer() - Method in class com.sm.store.server.RemoteStoreServer
 
getTimes - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
getTotalActiveRecords() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getTotalActiveRecordsPercentage() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getTotalDeletedRecords() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getTotalRecords() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getTrigger - Variable in class com.sm.store.server.RemoteStore
 
getTriggerName - Variable in class com.sm.store.server.RemoteStore
 
getWriteBackThread() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
getWSHandler() - Method in class com.sm.store.server.StoreCallBack
 
GZClusterServer - Class in com.sm.store.server.grizzly
 
GZClusterServer() - Constructor for class com.sm.store.server.grizzly.GZClusterServer
 
GZClusterStoreServer - Class in com.sm.store.server.grizzly
 
GZClusterStoreServer(ClusterServerConfig, Serializer) - Constructor for class com.sm.store.server.grizzly.GZClusterStoreServer
 
GZRemoteStoreServer - Class in com.sm.store.server.grizzly
 
GZRemoteStoreServer() - Constructor for class com.sm.store.server.grizzly.GZRemoteStoreServer
 
GZRemoteStoreServer(int, List<TupleThree<String, String, Integer>>, boolean) - Constructor for class com.sm.store.server.grizzly.GZRemoteStoreServer
 
GZRemoteStoreServer(int, List<TupleThree<String, String, Integer>>, Serializer, boolean) - Constructor for class com.sm.store.server.grizzly.GZRemoteStoreServer
 
GZRemoteStoreServer(RemoteConfig) - Constructor for class com.sm.store.server.grizzly.GZRemoteStoreServer
 
GZScan4RemoteServer - Class in com.sm.store.server.grizzly
 
GZScan4RemoteServer(RemoteConfig) - Constructor for class com.sm.store.server.grizzly.GZScan4RemoteServer
 

H

handleRead(FilterChainContext) - Method in class com.sm.store.server.grizzly.StoreServerFilter
 
handleUpstream(ChannelHandlerContext, ChannelEvent) - Method in class com.sm.store.server.InvokerServerHandler
 
handleUpstream(ChannelHandlerContext, ChannelEvent) - Method in class com.sm.store.server.StoreServerHandler
 
hasNext() - Method in class com.sm.store.server.QueryIterator
 
hookShutdown() - Method in class com.sm.store.server.ClusterStoreServer
 
hookShutdown() - Method in class com.sm.store.server.RemoteStoreServer
 

I

INDEX_SIZE - Static variable in class com.sm.connector.server.MRStore
 
indexBuf - Variable in class com.sm.connector.server.MRStore
 
indexPos - Variable in class com.sm.connector.server.MRStore
 
init(CacheStore) - Method in class com.sm.localstore.impl.LocalStoreImpl
 
init() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
init() - Method in class com.sm.store.server.ClusterStoreCallBack
 
init() - Method in class com.sm.store.server.ClusterStoreServer
 
init() - Method in class com.sm.store.server.grizzly.GZClusterStoreServer
 
init(boolean) - Method in class com.sm.store.server.grizzly.GZRemoteStoreServer
 
init(boolean) - Method in class com.sm.store.server.grizzly.GZScan4RemoteServer
 
init() - Method in class com.sm.store.server.LocalSortedCacheStore
 
init(boolean) - Method in class com.sm.store.server.netty.Scan4RemoteServer
 
init() - Method in class com.sm.store.server.RemoteScanStore
 
init(boolean) - Method in class com.sm.store.server.RemoteStoreServer
 
init() - Method in class com.sm.store.server.Scan4CallBack
sorted == true, create RemoteScanStore, otherwise RemoteStore
initConfig(RemoteConfig) - Method in class com.sm.store.server.RemoteStoreServer
 
initPut() - Method in class com.sm.store.server.AdminClusterStore
 
insert(Key, Value) - Method in class com.sm.store.server.RemoteStore
insert will perform get to make sure key did not exist
invoke(Invoker) - Method in class com.sm.store.ServerWSHandler
look up service nameMap and invoke the corresponding method
InvokerServerHandler - Class in com.sm.store.server
 
InvokerServerHandler(List<String>) - Constructor for class com.sm.store.server.InvokerServerHandler
 
InvokerServerHandler(Serializer, List<String>) - Constructor for class com.sm.store.server.InvokerServerHandler
 
isEnd(int) - Method in class com.sm.connector.server.ServerStore
 
isEnd() - Method in class com.sm.store.server.QueryIterator
 
isSorted - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
isSorted() - Method in class com.sm.store.server.QueryIterator
 
isSorted() - Method in class com.sm.store.server.RemoteScanStore
 
isTableScan() - Method in class com.sm.store.server.QueryIterator
 

J

joinMap(Pair<Key, Object>, T, Map<String, Object>, List<String>, Filter) - Method in interface com.sm.connector.server.JoinMapReduce
 
JoinMapReduce<T> - Interface in com.sm.connector.server
Created by mhsieh on 4/29/16.

K

keyBuf - Variable in class com.sm.connector.server.MRStore
 
keyOffset - Variable in class com.sm.connector.server.ServerStore
 
keyPos - Variable in class com.sm.connector.server.MRStore
 

L

loader - Variable in class com.sm.store.ServerWSHandler
 
LocalSortedCacheStore - Class in com.sm.store.server
 
LocalSortedCacheStore(String, Serializer, String, boolean, BlockSize, int) - Constructor for class com.sm.store.server.LocalSortedCacheStore
 
LocalSortedCacheStore(String, Serializer, boolean, int) - Constructor for class com.sm.store.server.LocalSortedCacheStore
 
LocalSortedCacheStore(String, Serializer, int) - Constructor for class com.sm.store.server.LocalSortedCacheStore
 
LocalStoreImpl<T> - Class in com.sm.localstore.impl
 
LocalStoreImpl() - Constructor for class com.sm.localstore.impl.LocalStoreImpl
 
LocalStoreImpl(String, Serializer, String, boolean, BlockSize, int, boolean) - Constructor for class com.sm.localstore.impl.LocalStoreImpl
 
LocalStoreImpl(String, Serializer, String, boolean, BlockSize, int) - Constructor for class com.sm.localstore.impl.LocalStoreImpl
 
LocalStoreImpl(String, Serializer, boolean, int) - Constructor for class com.sm.localstore.impl.LocalStoreImpl
 
LocalStoreImpl(String, Serializer, int) - Constructor for class com.sm.localstore.impl.LocalStoreImpl
 
LocalStoreImpl(CacheStore, boolean, int) - Constructor for class com.sm.localstore.impl.LocalStoreImpl
 
LocalStoreImpl.RecentCacheStats - Class in com.sm.localstore.impl
 
LocalStoreImpl.RecentCacheStats(CacheStore) - Constructor for class com.sm.localstore.impl.LocalStoreImpl.RecentCacheStats
 
lock - Variable in class com.sm.connector.server.ServerStore
 
logger - Static variable in class com.sm.localstore.impl.LocalStoreImpl
 
logger - Static variable in class com.sm.store.server.ClusterServerHandler
 
logger - Static variable in class com.sm.store.server.ClusterStore
 
logger - Static variable in class com.sm.store.server.ClusterStoreCallBack
 
logger - Static variable in class com.sm.store.server.ClusterStoreServer
 
logger - Static variable in class com.sm.store.server.LocalSortedCacheStore
 
logger - Static variable in class com.sm.store.server.RemoteScanStore
 
logger - Static variable in class com.sm.store.server.RemoteStoreServer
 
logger - Static variable in class com.sm.store.server.Scan4CallBack
 
logger - Static variable in class com.sm.store.server.StoreCallBack
 
logPath - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
logQueue - Variable in class com.sm.localstore.impl.LocalStoreImpl
 

M

main(String[]) - Static method in class com.sm.store.server.ClusterServer
 
main(String[]) - Static method in class com.sm.store.server.grizzly.GZClusterServer
 
main(String[]) - Static method in class com.sm.store.server.grizzly.RemoteScan4ReplicaServer
 
main(String[]) - Static method in class com.sm.store.server.netty.RemoteScan4ReplicaServer
 
main(String[]) - Static method in class com.sm.store.server.RemoteReplicaServer
 
mapper - Variable in class com.sm.store.server.StoreCallBack
 
MapReduceUtils - Class in com.sm.connector.server
Created by mhsieh on 3/18/16.
MAX_SIZE - Static variable in class com.sm.store.server.StoreCallBack
 
maxQueue - Variable in class com.sm.store.server.grizzly.StoreServerFilter
 
maxQueue - Variable in class com.sm.store.server.RemoteStoreServer
 
maxQueue - Variable in class com.sm.store.server.StoreServerHandler
 
maxThread - Variable in class com.sm.store.server.RemoteStoreServer
 
maxThreads - Variable in class com.sm.store.server.grizzly.StoreServerFilter
 
maxThreads - Variable in class com.sm.store.server.StoreServerHandler
 
messageReceived(ChannelHandlerContext, MessageEvent) - Method in class com.sm.store.server.InvokerServerHandler
 
messageReceived(ChannelHandlerContext, MessageEvent) - Method in class com.sm.store.server.StoreServerHandler
 
mode - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
MRStore - Class in com.sm.connector.server
Created by mhsieh on 2/13/16.
MRStore(String) - Constructor for class com.sm.connector.server.MRStore
 
MRStore(String, boolean) - Constructor for class com.sm.connector.server.MRStore
 
multiGets(List<Key>) - Method in class com.sm.store.server.RemoteStore
 
multiPuts(List<KeyValue>) - Method in class com.sm.store.server.RemoteStore
 
multiRemove(List<Key>) - Method in class com.sm.store.server.RemoteStore
 

N

needLogThread - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
needPstThread - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
next() - Method in class com.sm.connector.server.MRStore
 
next(int, ByteBuffer) - Method in class com.sm.connector.server.ServerStore
 
next() - Method in class com.sm.store.server.QueryIterator
 
nextBatch(Cursor, CursorPara) - Method in class com.sm.store.server.RemoteScanStore
 
nextBatchQuery(Cursor, CursorPara) - Method in class com.sm.store.server.RemoteScanStore
 
nextBlock(int, int) - Method in class com.sm.connector.server.ServerStore
 
nextCursor(CursorPara) - Method in class com.sm.store.server.RemoteScanStore
 

P

pack(int) - Method in class com.sm.localstore.impl.LocalStoreImpl
 
path - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
populate(byte[], Value<byte[]>) - Method in class com.sm.connector.server.ServerStore
 
port - Variable in class com.sm.store.server.RemoteStoreServer
 
processFullQuery(QueryIterator, String, RemoteStore) - Method in class com.sm.store.server.StoreCallBack
 
processGet(RemoteStore, Key) - Method in class com.sm.store.server.StoreCallBack
 
processGetNoBlock(RemoteStore, StoreParas) - Method in class com.sm.store.server.StoreCallBack
 
processGetNoBlockInt(RemoteStore, StoreParas) - Method in class com.sm.store.server.StoreCallBack
 
processGetSeqNo(RemoteStore, Key) - Method in class com.sm.store.server.StoreCallBack
 
processGetSeqNoInt(RemoteStore, Key) - Method in class com.sm.store.server.StoreCallBack
 
processInsert(RemoteStore, Key, Value) - Method in class com.sm.store.server.StoreCallBack
 
processKeyIterator(Request) - Method in class com.sm.store.server.StoreCallBack
 
processParas(StoreParas, RemoteStore) - Method in class com.sm.store.server.StoreCallBack
 
processPut(RemoteStore, Key, Value) - Method in class com.sm.store.server.StoreCallBack
 
processQueryPut(KeyValueParas, RemoteStore) - Method in class com.sm.store.server.StoreCallBack
will deprecate MultiSelectQuery.
processQueryStr(RemoteStore, List<KeyValue>, String) - Method in class com.sm.store.server.StoreCallBack
 
processQueryStr(RemoteStore, List<KeyValue>, String, OpType) - Method in class com.sm.store.server.StoreCallBack
 
processRemove(RemoteStore, Key) - Method in class com.sm.store.server.StoreCallBack
 
processRequest(Request) - Method in class com.sm.store.server.ClusterStoreCallBack
 
processRequest(Request, FilterChainContext) - Method in class com.sm.store.server.grizzly.StoreServerFilter
 
processRequest(Request) - Method in class com.sm.store.server.Scan4CallBack
try to reuse StoreServerHandler which assume response payload had been serialized unlike ScanStore which assume response payload is a object
processRequest(Request) - Method in class com.sm.store.server.StoreCallBack
 
processScan(Request) - Method in class com.sm.store.server.Scan4CallBack
process scan request type that includes scan range, cursor, KeyParas, KeySet
processScan(Request) - Method in class com.sm.store.server.StoreCallBack
 
processSelectQuery(RemoteStore, Key, Value) - Method in class com.sm.store.server.StoreCallBack
 
processStoreParas(Request) - Method in class com.sm.store.server.ClusterStoreCallBack
 
processStoreParas(Request) - Method in class com.sm.store.server.StoreCallBack
 
processUpdateQuery(RemoteStore, Key, Value) - Method in class com.sm.store.server.StoreCallBack
 
pstQueue - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
purge() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
put(Key, Value) - Method in class com.sm.localstore.impl.LocalStoreImpl
 
put(Key, T) - Method in class com.sm.localstore.impl.LocalStoreImpl
 
put(Key, Value) - Method in class com.sm.store.server.AdminStore
 
put(Key, Value) - Method in class com.sm.store.server.RemoteStore
 
put(Key, Object) - Method in class com.sm.store.server.RemoteStore
we don't support this for remote client
putClusterNodesList(List<ClusterNodes>) - Method in class com.sm.store.server.AdminStore
 
putFreq - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
putInMap(Key, T) - Method in class com.sm.localstore.impl.LocalStoreImpl
 
putObject(Key, Object) - Method in class com.sm.store.server.AdminClusterStore
 
putObject(Key, Object) - Method in class com.sm.store.server.AdminStore
 
putStoreConfigList(List<StoreConfig>) - Method in class com.sm.store.server.AdminStore
 
putTimes - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
putTrigger - Variable in class com.sm.store.server.RemoteStore
 
putTriggerName - Variable in class com.sm.store.server.RemoteStore
 

Q

QueryIterator - Class in com.sm.store.server
 
QueryIterator(Stack<Predicate>, boolean, RemoteStore) - Constructor for class com.sm.store.server.QueryIterator
 

R

r2 - Variable in class com.sm.connector.server.MRStore
 
readDataBuf() - Method in class com.sm.connector.server.MRStore
read next data buffer, update dataPos
readDataBufAry(byte[]) - Method in class com.sm.connector.server.MRStore
when data block size > BUF_SIZE, pass the large byte array to be read but not into data buffer which is 8192 bytes
readDataChannel(long, long, long) - Method in class com.sm.connector.server.MRStore
read destinate data len from data buffer and advance the gap (blocksize -d datalen) also handle if block size > BUF_SIZE
readKeyBuf() - Method in class com.sm.connector.server.MRStore
read next key buffer and update keyPos
readKeyChannel(int) - Method in class com.sm.connector.server.MRStore
read next key bytes from key buffer
recentCacheStats - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
reloadTrigger() - Method in class com.sm.store.server.RemoteStore
 
remoteConfig - Variable in class com.sm.store.server.Scan4CallBack
 
RemoteReplicaServer - Class in com.sm.store.server
 
RemoteReplicaServer() - Constructor for class com.sm.store.server.RemoteReplicaServer
 
RemoteScan4ReplicaServer - Class in com.sm.store.server.grizzly
 
RemoteScan4ReplicaServer() - Constructor for class com.sm.store.server.grizzly.RemoteScan4ReplicaServer
 
RemoteScan4ReplicaServer - Class in com.sm.store.server.netty
 
RemoteScan4ReplicaServer() - Constructor for class com.sm.store.server.netty.RemoteScan4ReplicaServer
 
RemoteScanStore - Class in com.sm.store.server
 
RemoteScanStore(String, Serializer, int) - Constructor for class com.sm.store.server.RemoteScanStore
 
RemoteScanStore(String, Serializer, String, boolean, BlockSize, int) - Constructor for class com.sm.store.server.RemoteScanStore
 
RemoteScanStore(String, Serializer, String, boolean, BlockSize, int, boolean) - Constructor for class com.sm.store.server.RemoteScanStore
 
RemoteScanStore(String, Serializer, boolean, int) - Constructor for class com.sm.store.server.RemoteScanStore
 
RemoteScanStore(String, Serializer, boolean, int, boolean) - Constructor for class com.sm.store.server.RemoteScanStore
 
RemoteScanStore.CleanUpCursor - Class in com.sm.store.server
 
RemoteScanStore.CleanUpCursor(long) - Constructor for class com.sm.store.server.RemoteScanStore.CleanUpCursor
 
RemoteStore - Class in com.sm.store.server
An Remote store is primary for remote Client, value.getData() is a serialized byte[] which imply an CacheValue
RemoteStore() - Constructor for class com.sm.store.server.RemoteStore
 
RemoteStore(String, Serializer, int) - Constructor for class com.sm.store.server.RemoteStore
 
RemoteStore(String, Serializer, String, boolean, BlockSize, int) - Constructor for class com.sm.store.server.RemoteStore
 
RemoteStore(String, Serializer, boolean, int) - Constructor for class com.sm.store.server.RemoteStore
 
RemoteStore(CacheStore, boolean, int) - Constructor for class com.sm.store.server.RemoteStore
 
RemoteStoreServer - Class in com.sm.store.server
 
RemoteStoreServer() - Constructor for class com.sm.store.server.RemoteStoreServer
 
RemoteStoreServer(int, List<TupleThree<String, String, Integer>>) - Constructor for class com.sm.store.server.RemoteStoreServer
 
RemoteStoreServer(int, List<TupleThree<String, String, Integer>>, boolean) - Constructor for class com.sm.store.server.RemoteStoreServer
 
RemoteStoreServer(int, List<TupleThree<String, String, Integer>>, Serializer, boolean) - Constructor for class com.sm.store.server.RemoteStoreServer
 
RemoteStoreServer(RemoteConfig) - Constructor for class com.sm.store.server.RemoteStoreServer
 
RemoteStoreServer(int, List<TupleThree<String, String, Integer>>, Serializer, int, int, boolean) - Constructor for class com.sm.store.server.RemoteStoreServer
 
remove(Key) - Method in class com.sm.localstore.impl.LocalStoreImpl
 
remove() - Method in class com.sm.store.server.QueryIterator
 
remove(Key) - Method in class com.sm.store.server.RemoteStore
 
removeFreq - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
removeTimes - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
replicaClientList - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
replicaServer - Variable in class com.sm.store.server.ClusterStoreServer
 
replicaServer - Variable in class com.sm.store.server.RemoteStoreServer
 
resetIndex(int, String, int) - Method in class com.sm.localstore.impl.LocalStoreImpl
 
resetLoader() - Method in class com.sm.store.ServerWSHandler
 
restartReplicaClients() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
run() - Method in class com.sm.connector.server.ExecMapReduce.RunThread
 

S

SCAN - Static variable in class com.sm.connector.server.ExecMapReduce
 
scan(Key, Key) - Method in class com.sm.store.server.RemoteScanStore
 
scan(Key) - Method in class com.sm.store.server.RemoteScanStore
 
Scan4CallBack - Class in com.sm.store.server
 
Scan4CallBack() - Constructor for class com.sm.store.server.Scan4CallBack
 
Scan4CallBack(RemoteConfig) - Constructor for class com.sm.store.server.Scan4CallBack
 
Scan4RemoteServer - Class in com.sm.store.server.netty
 
Scan4RemoteServer(RemoteConfig) - Constructor for class com.sm.store.server.netty.Scan4RemoteServer
 
seqno - Variable in class com.sm.store.server.RemoteScanStore
 
serializer - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
serializer - Variable in class com.sm.store.server.ClusterServerHandler
 
serializer - Variable in class com.sm.store.server.ClusterStoreServer
 
serializer - Variable in class com.sm.store.server.RemoteStoreServer
 
serializer - Variable in class com.sm.store.server.StoreCallBack
 
serializerResponse(Header, Response) - Method in class com.sm.store.server.StoreCallBack
check type of header SerializableType
Server - Interface in com.sm.store.server
 
serverConfig - Variable in class com.sm.store.server.ClusterStoreServer
 
serverState - Variable in class com.sm.store.server.RemoteStoreServer
 
serverState - Variable in class com.sm.store.server.StoreCallBack
 
ServerStore - Class in com.sm.connector.server
Created by mhsieh on 8/6/14.
ServerStore(String) - Constructor for class com.sm.connector.server.ServerStore
 
ServerStore(String, boolean) - Constructor for class com.sm.connector.server.ServerStore
 
ServerWSHandler - Class in com.sm.store
 
ServerWSHandler(ConcurrentMap<String, RemoteStore>) - Constructor for class com.sm.store.ServerWSHandler
 
ServerWSHandler(ConcurrentMap<String, RemoteStore>, Loader) - Constructor for class com.sm.store.ServerWSHandler
 
Service - Interface in com.sm
 
Service.State - Enum in com.sm
 
serviceMap - Variable in class com.sm.store.ServerWSHandler
 
setBlockValue(boolean) - Method in class com.sm.store.server.RemoteStore
 
setCluster(Key) - Method in class com.sm.store.server.AdminClusterStore
 
seTCPtServer(TCPServer) - Method in class com.sm.store.server.RemoteStoreServer
 
setCurrent(int) - Method in class com.sm.connector.server.MRStore
 
setCurrent(int) - Method in class com.sm.connector.server.ServerStore
curRecord is 0 base, so set it by current -1 if you use 1 base
setDeleteTrigger(String) - Method in class com.sm.store.server.RemoteStore
 
setDelta(Delta) - Method in class com.sm.store.server.RemoteStore
 
setFreq(int) - Method in class com.sm.store.server.grizzly.StoreServerFilter
 
setFreq(int) - Method in class com.sm.store.server.StoreServerHandler
 
setGetTrigger(String) - Method in class com.sm.store.server.RemoteStore
 
setGetTrigger(String, StoreConfig) - Method in class com.sm.store.server.RemoteStore
 
setGZHandler(StoreServerFilter) - Method in class com.sm.store.server.grizzly.GZClusterStoreServer
 
setGZHandler(StoreServerFilter) - Method in class com.sm.store.server.grizzly.GZRemoteStoreServer
 
setGZServer(TCPServer) - Method in class com.sm.store.server.grizzly.GZClusterStoreServer
 
setGZServer(TCPServer) - Method in class com.sm.store.server.grizzly.GZRemoteStoreServer
 
setList(List<ClusterNodes>, List<StoreConfig>) - Method in class com.sm.store.server.AdminClusterStore
 
setPurge(Purge) - Method in class com.sm.localstore.impl.LocalStoreImpl
 
setPutTrigger(String) - Method in class com.sm.store.server.RemoteStore
 
setReplicaBatcSize(int) - Method in class com.sm.localstore.impl.LocalStoreImpl
 
setServerConfig(ClusterServerConfig) - Method in class com.sm.store.server.AdminClusterStore
 
setStoreConfig(Key) - Method in class com.sm.store.server.AdminClusterStore
 
setStoreMap(ConcurrentMap<String, RemoteStore>) - Method in interface com.sm.store.StoreMap
 
setTCPHandler(StoreServerHandler) - Method in class com.sm.store.server.RemoteStoreServer
 
setTimeout(long) - Method in class com.sm.connector.server.ExecMapReduce
 
setupTrigger2Cache(StoreConfig) - Method in class com.sm.store.server.RemoteStore
look up storeConfig to determine if trigger had been defined or not if it is, load each interface implementation use Class.forName also if useMaxCache set to true, it use FIFO queue and getMaxCacheMemory to configure the cache by number of objects, not the capacity of memory bytes useLRU flag to determine LRU algorithm had been used or not all implementations ars located at Scan4CallBack handler when request message wree processed
setWSHandler(ServerWSHandler) - Method in class com.sm.store.server.StoreCallBack
provide an way to overwrite ServerWSHandler to handle dynamic class loader
shutdown() - Method in class com.sm.store.server.ClusterStoreServer
 
shutdown() - Method in class com.sm.store.server.grizzly.GZClusterStoreServer
 
shutdown() - Method in class com.sm.store.server.grizzly.GZRemoteStoreServer
 
shutdown() - Method in class com.sm.store.server.RemoteStoreServer
 
shutdown() - Method in interface com.sm.store.server.Server
 
shutdownClient() - Method in class com.sm.localstore.impl.LocalStoreImpl
shutdown replica client
size() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
start() - Method in interface com.sm.Service
 
start() - Method in class com.sm.store.server.ClusterStoreServer
 
start() - Method in class com.sm.store.server.grizzly.GZClusterStoreServer
 
startAdminStore() - Method in class com.sm.store.server.ClusterStoreServer
 
startPstLogThread(String, List<String>) - Method in class com.sm.localstore.impl.LocalStoreImpl
 
startPstReplica(String, List<String>) - Method in class com.sm.store.server.RemoteStore
 
startReplica(String, String) - Method in class com.sm.store.server.ClusterStore
 
startReplica(String, List<String>) - Method in class com.sm.store.server.RemoteStore
 
startReplica(RemoteConfig) - Method in class com.sm.store.server.RemoteStoreServer
 
startReplicaServer() - Method in class com.sm.store.server.ClusterStoreServer
 
startServer() - Method in class com.sm.store.server.ClusterStoreServer
 
startServer() - Method in class com.sm.store.server.grizzly.GZClusterStoreServer
 
startServer() - Method in class com.sm.store.server.grizzly.GZRemoteStoreServer
 
startServer() - Method in class com.sm.store.server.RemoteStoreServer
 
startWriteLogThread(String, List<String>) - Method in class com.sm.localstore.impl.LocalStoreImpl
 
startWriteThread(int) - Method in class com.sm.localstore.impl.LocalStoreImpl
 
startWriteThread(int) - Method in class com.sm.store.server.ClusterStore
 
state - Variable in class com.sm.store.server.ClusterStoreServer
 
statList - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
stop() - Method in interface com.sm.Service
 
stop() - Method in class com.sm.store.server.ClusterStoreServer
 
stop() - Method in class com.sm.store.server.grizzly.GZClusterStoreServer
 
stopReplicaClients() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
stopReplicaServer() - Method in class com.sm.store.server.ClusterStoreServer
 
stopServer() - Method in class com.sm.store.server.ClusterStoreServer
 
stopServer() - Method in class com.sm.store.server.grizzly.GZClusterStoreServer
 
stopServer() - Method in class com.sm.store.server.grizzly.GZRemoteStoreServer
 
stopServer() - Method in class com.sm.store.server.RemoteStoreServer
 
store - Variable in class com.sm.localstore.impl.LocalStoreImpl
 
StoreCallBack - Class in com.sm.store.server
 
StoreCallBack() - Constructor for class com.sm.store.server.StoreCallBack
 
StoreCallBack(List<TupleThree<String, String, Integer>>) - Constructor for class com.sm.store.server.StoreCallBack
 
StoreCallBack(List<TupleThree<String, String, Integer>>, Serializer) - Constructor for class com.sm.store.server.StoreCallBack
 
StoreCallBack(RemoteConfig) - Constructor for class com.sm.store.server.StoreCallBack
 
StoreCallBack(List<TupleThree<String, String, Integer>>, Serializer, boolean) - Constructor for class com.sm.store.server.StoreCallBack
 
storeList - Variable in class com.sm.store.server.RemoteStoreServer
 
storeList - Variable in class com.sm.store.server.StoreCallBack
 
StoreMap - Interface in com.sm.store
 
storeMaps - Variable in class com.sm.store.server.ClusterStoreServer
 
storeMaps - Variable in class com.sm.store.server.StoreCallBack
 
storeMaps - Variable in class com.sm.store.ServerWSHandler
 
StoreServerFilter - Class in com.sm.store.server.grizzly
 
StoreServerFilter(TCPCallBack, int, int) - Constructor for class com.sm.store.server.grizzly.StoreServerFilter
 
StoreServerFilter(TCPCallBack, int) - Constructor for class com.sm.store.server.grizzly.StoreServerFilter
 
StoreServerHandler - Class in com.sm.store.server
 
StoreServerHandler(TCPCallBack, int, int) - Constructor for class com.sm.store.server.StoreServerHandler
 
StoreServerHandler(TCPCallBack, int) - Constructor for class com.sm.store.server.StoreServerHandler
 

T

threadLoader - Variable in class com.sm.store.server.RemoteStore
 
threadPools - Variable in class com.sm.store.server.StoreServerHandler
 

V

validateLink() - Method in class com.sm.localstore.impl.LocalStoreImpl
 
valueOf(String) - Static method in enum com.sm.Service.State
Returns the enum constant of this type with the specified name.
values() - Static method in enum com.sm.Service.State
Returns an array containing the constants of this enum type, in the order they are declared.

W

writeExistBlock(CacheBlock<byte[]>) - Method in class com.sm.connector.server.ServerStore
 
writeRecord(Key, Value<byte[]>, int) - Method in class com.sm.connector.server.ServerStore
 
WSHandler - Variable in class com.sm.store.server.StoreCallBack
 
A B C D E F G H I J K L M N P Q R S T V W 

Copyright © 2016. All rights reserved.