A B C D E F G H I L M N O P Q R S T U V 

A

addKey(Key) - Method in class com.sm.store.client.ClusterClient.KeyCluster
 

B

backup(String, int) - Method in class com.sm.store.client.ClusterClient
 
backup(String, int) - Method in class com.sm.store.client.ClusterClientImpl
 
backup(String, int) - Method in class com.sm.store.client.LocalClusterClientImpl
 
backup(String, int) - Method in class com.sm.store.client.RemoteClientImpl
 
buf - Variable in class com.sm.connector.client.MD5Reader
 
BUF_SIZE - Static variable in class com.sm.connector.client.MD5Reader
 
bufIndex - Variable in class com.sm.connector.client.MD5Reader
 
bufLen - Variable in class com.sm.connector.client.MD5Reader
 
buildClusterConnection(List<ClusterNodes>, TCPClientFactory.ClientType) - Static method in class com.sm.store.client.Utils
 
buildConnections(String[], TCPClientFactory.ClientType) - Static method in class com.sm.store.client.Utils
 

C

call() - Method in class com.sm.connector.client.PartitionClient.RunThread
 
channelConnected(ChannelHandlerContext, ChannelStateEvent) - Method in class com.sm.store.client.netty.StoreClientHandler
 
channelInterestChanged(ChannelHandlerContext, ChannelStateEvent) - Method in class com.sm.store.client.netty.StoreClientHandler
 
client - Variable in class com.sm.store.client.RemoteClientImpl
 
ClientConnections - Class in com.sm.store.client
 
ClientConnections(List<ClusterNodes>, Serializer) - Constructor for class com.sm.store.client.ClientConnections
 
ClientConnections(List<ClusterNodes>, Serializer, TCPClientFactory.ClientType) - Constructor for class com.sm.store.client.ClientConnections
 
clientConnections - Variable in class com.sm.store.client.ClusterClient
 
clientType - Variable in class com.sm.store.client.ClientConnections
 
clientType - Variable in class com.sm.store.client.ClusterClient
 
clientType - Variable in class com.sm.store.cluster.Connection
 
close() - Method in class com.sm.connector.client.MD5Reader
 
close() - Method in class com.sm.store.client.ClusterClient
 
close() - Method in class com.sm.store.client.ClusterClient.ClusterCursor
 
close() - Method in class com.sm.store.client.ClusterClientFactory
 
close() - Method in class com.sm.store.client.ClusterClientImpl
 
close() - Method in class com.sm.store.client.LocalClusterClientImpl
 
close() - Method in class com.sm.store.client.RemoteClientImpl
 
close() - Method in class com.sm.store.client.ScanIterator
 
close() - Method in class com.sm.store.cluster.Connection
 
closeCursor(CursorPara) - Method in class com.sm.store.client.netty.ScanClientImpl
close cursor on server side
ClusterClient - Class in com.sm.store.client
 
ClusterClient(List<ClusterNodes>, String, Serializer, TCPClientFactory.ClientType) - Constructor for class com.sm.store.client.ClusterClient
 
ClusterClient.ClusterCursor - Class in com.sm.store.client
 
ClusterClient.ClusterCursor(CursorPara) - Constructor for class com.sm.store.client.ClusterClient.ClusterCursor
 
ClusterClient.KeyCluster - Class in com.sm.store.client
 
ClusterClient.KeyCluster(short, Key, int) - Constructor for class com.sm.store.client.ClusterClient.KeyCluster
 
ClusterClient.KeyCluster(short, Key) - Constructor for class com.sm.store.client.ClusterClient.KeyCluster
 
ClusterClient.RunThread - Class in com.sm.store.client
 
ClusterClient.RunThread(Request, short, CountDownLatch, Key) - Constructor for class com.sm.store.client.ClusterClient.RunThread
 
ClusterClient.RunThread(Request, short, CountDownLatch, Key, OpType) - Constructor for class com.sm.store.client.ClusterClient.RunThread
 
ClusterClient.RunThread(Request, ClusterClient.KeyCluster, CountDownLatch, OpType) - Constructor for class com.sm.store.client.ClusterClient.RunThread
 
ClusterClientFactory - Class in com.sm.store.client
 
ClusterClientFilter - Class in com.sm.store.client.grizzly
 
ClusterClientFilter(long) - Constructor for class com.sm.store.client.grizzly.ClusterClientFilter
 
ClusterClientFilter(long, Serializer) - Constructor for class com.sm.store.client.grizzly.ClusterClientFilter
 
ClusterClientHandler - Class in com.sm.store.client.netty
 
ClusterClientHandler(long, Serializer) - Constructor for class com.sm.store.client.netty.ClusterClientHandler
 
ClusterClientHandler() - Constructor for class com.sm.store.client.netty.ClusterClientHandler
 
ClusterClientImpl - Class in com.sm.store.client
 
ClusterClientImpl(List<String>, String) - Constructor for class com.sm.store.client.ClusterClientImpl
 
ClusterClientImpl(List<String>, String, Serializer) - Constructor for class com.sm.store.client.ClusterClientImpl
\
ClusterClientImpl(List<String>, String, Serializer, ConcurrentMap<String, RemoteStore>) - Constructor for class com.sm.store.client.ClusterClientImpl
 
clusterStoreProc(Invoker, List<Key>) - Method in class com.sm.store.client.ClusterClient
 
clusterStoreProc(Invoker, List<Key>, String) - Method in class com.sm.store.client.ClusterClient
 
clusterStoreProcFuture(Invoker, List<Key>) - Method in class com.sm.store.client.ClusterClient
 
com.sm.connector.client - package com.sm.connector.client
 
com.sm.store.client - package com.sm.store.client
 
com.sm.store.client.grizzly - package com.sm.store.client.grizzly
 
com.sm.store.client.netty - package com.sm.store.client.netty
 
com.sm.store.cluster - package com.sm.store.cluster
 
connect(String, String) - Static method in class com.sm.store.client.ClusterClientFactory
 
connect(String, String, Serializer) - Static method in class com.sm.store.client.ClusterClientFactory
 
connect(String, String, TCPClientFactory.ClientType) - Static method in class com.sm.store.client.ClusterClientFactory
 
connect(String, String, Serializer, TCPClientFactory.ClientType) - Static method in class com.sm.store.client.ClusterClientFactory
 
connect(long) - Method in class com.sm.store.cluster.Connection
 
connectAll() - Method in class com.sm.store.client.ClientConnections
 
Connection - Class in com.sm.store.cluster
 
Connection(String, int) - Constructor for class com.sm.store.cluster.Connection
 
Connection(String, int, TCPClientFactory.ClientType) - Constructor for class com.sm.store.cluster.Connection
 
create4GetPutRequest(List, OpType, String) - Method in class com.sm.store.client.ClusterClient
 
createClient(TCPClientFactory.ClientType, String, long) - Static method in class com.sm.store.client.TCPClientFactory
 
createClient(TCPClientFactory.ClientType, Connection, long) - Static method in class com.sm.store.client.TCPClientFactory
 
createCursorRequest(CursorPara) - Method in class com.sm.store.client.ClusterClient
 
createRequest(byte[], String) - Method in class com.sm.store.client.ClientConnections
 
createRequest(byte[], String, Request.RequestType) - Method in class com.sm.store.client.ClientConnections
 
createRequest(byte[], Request.RequestType) - Method in class com.sm.store.client.RemoteClientImpl
 
createScanRequest(ScanParaList) - Method in class com.sm.store.client.ClusterClient
 
createStoreProcRequest(Invoker) - Method in class com.sm.store.client.ClusterClient
 

D

dataChannel - Variable in class com.sm.connector.client.MD5Reader
 

E

embeddedSerializer - Variable in class com.sm.store.client.ClusterClient
 
embeddedSerializer - Variable in class com.sm.store.client.grizzly.StoreClientFilter
 
embeddedSerializer - Variable in class com.sm.store.client.netty.StoreClientHandler
 
embeddedSerializer - Variable in class com.sm.store.client.RemoteClientImpl
 
EmbeddedSerializer - Static variable in class com.sm.store.client.TCPClientFactory
 
EOF - Variable in class com.sm.connector.client.MD5Reader
 
equals(Object) - Method in class com.sm.store.cluster.Connection
 
error - Variable in class com.sm.store.client.netty.ClusterClientHandler
 
exceptionCaught(ChannelHandlerContext, ExceptionEvent) - Method in class com.sm.store.client.netty.ClusterClientHandler
 
exceptionCaught(ChannelHandlerContext, ExceptionEvent) - Method in class com.sm.store.client.netty.StoreClientHandler
 
execute(List<RemoteClientImpl>, int) - Method in class com.sm.connector.client.PartitionClient
 
executeStoreProc(Invoker, List<ClusterClient.KeyCluster>, boolean) - Method in class com.sm.store.client.ClusterClient
 
executeStoreProc(Invoker, List<ClusterClient.KeyCluster>, boolean, String) - Method in class com.sm.store.client.ClusterClient
 

F

filename - Variable in class com.sm.connector.client.MD5Reader
 
findAll() - Method in class com.sm.store.client.ClusterClient
 
findConnection(int, List<Connection>) - Method in class com.sm.store.client.ClientConnections
 
findKeyCluster(Key, List<ClusterClient.KeyCluster>) - Method in class com.sm.store.client.ClusterClient
 
findKeyGroups(List<Key>) - Method in class com.sm.store.client.ClusterClient
 
findList(List<Key>, List<KeyValue>) - Method in class com.sm.store.client.ClusterClient
 
FNV_BASIS - Static variable in class com.sm.store.client.FnvHash
 
FNV_PRIME - Static variable in class com.sm.store.client.FnvHash
 
FnvHash - Class in com.sm.store.client
 
FnvHash() - Constructor for class com.sm.store.client.FnvHash
 
freq - Variable in class com.sm.store.client.netty.ClusterClientHandler
 

G

get(Key) - Method in class com.sm.store.client.ClusterClient
 
get(Key) - Method in class com.sm.store.client.ClusterClientImpl
 
get(Key) - Method in class com.sm.store.client.LocalClientImpl
 
get(Key) - Method in class com.sm.store.client.LocalClusterClientImpl
 
get(Key) - Method in class com.sm.store.client.RemoteClientImpl
 
get4Php(Key) - Method in class com.sm.store.client.RemoteClientImpl
return the value and bypass the serializer
getAdminClient() - Method in class com.sm.store.client.ClusterClientFactory
 
getClient() - Method in class com.sm.store.client.RemoteClientImpl
 
getClientType() - Method in class com.sm.store.client.ClientConnections
 
getClientType(byte) - Static method in enum com.sm.store.client.TCPClientFactory.ClientType
 
getCluster() - Method in class com.sm.store.client.ClusterClient.KeyCluster
 
getClusterConnections() - Method in class com.sm.store.client.ClientConnections
 
getClusterNodesList() - Method in class com.sm.store.client.ClusterClientFactory
 
getClusterNodeStr() - Method in class com.sm.store.client.ClientConnections
 
getConnection(Key) - Method in class com.sm.store.client.ClientConnections
add hash interface if there is customize hash function if not set, return key.hashCode()
getConnection(short, int) - Method in class com.sm.store.client.ClientConnections
 
getConnectionList() - Method in class com.sm.store.client.ClientConnections
 
getConnectionListStr(Map<Short, List<Connection>>) - Static method in class com.sm.store.client.Utils
 
getCurrentStore() - Method in class com.sm.store.client.ClusterClientFactory
 
getCursorParaList() - Method in class com.sm.store.client.ClusterClient.ClusterCursor
 
getDefaultStore(long) - Method in class com.sm.store.client.ClusterClientFactory
 
getDefaultStore(long, boolean) - Method in class com.sm.store.client.ClusterClientFactory
 
getDefaultStore() - Method in class com.sm.store.client.ClusterClientFactory
 
getFailCount() - Method in class com.sm.store.cluster.Connection
 
getFreq() - Method in class com.sm.store.client.netty.ClusterClientHandler
 
getHost() - Method in class com.sm.store.cluster.Connection
 
getIndex() - Method in class com.sm.store.client.ClusterClient.KeyCluster
 
getKeyClusterList() - Method in class com.sm.store.client.ClusterClient.ClusterCursor
 
getKeyIterator() - Method in class com.sm.store.client.ClusterClient
 
getKeyIterator() - Method in class com.sm.store.client.ClusterClientImpl
 
getKeyIterator() - Method in class com.sm.store.client.LocalClusterClientImpl
 
getKeyIterator() - Method in class com.sm.store.client.RemoteClientImpl
 
getKeyList(List<KeyValue>) - Method in class com.sm.store.client.ClusterClient
 
getKeyList() - Method in class com.sm.store.client.ClusterClient.KeyCluster
 
getKeyList() - Method in class com.sm.store.client.RemoteClientImpl
 
getKeyValueList() - Method in class com.sm.store.client.ClusterClient.RunThread
 
getLastConnected() - Method in class com.sm.store.cluster.Connection
 
getLastTry() - Method in class com.sm.store.cluster.Connection
 
getLength() - Method in class com.sm.connector.client.MD5Reader
 
getMapClientFromAll() - Method in class com.sm.store.client.ClientConnections
 
getOneFromAllCluster() - Method in class com.sm.store.client.ClientConnections
for those function which did not have keySet reference It will random select one node from cluster
getPartition(Key) - Method in class com.sm.store.client.ClientConnections
 
getPartitionIndex(Key) - Method in class com.sm.store.client.ClientConnections
 
getPartitionMap() - Method in class com.sm.store.client.ClientConnections
 
getPartitionNo(Key) - Method in class com.sm.store.client.ClientConnections
 
getPort() - Method in class com.sm.store.cluster.Connection
 
getPos() - Method in class com.sm.connector.client.MD5Reader
 
getResult() - Method in class com.sm.store.client.ClusterClient.ClusterCursor
 
getSeqNo(Key) - Method in class com.sm.store.client.RemoteClientImpl
 
getSeqNoBlock(Key, int) - Method in class com.sm.store.client.RemoteClientImpl
 
getSeqNoBlockInt(Key, int) - Method in class com.sm.store.client.RemoteClientImpl
 
getSeqNoInt(Key) - Method in class com.sm.store.client.RemoteClientImpl
 
getSerializer() - Method in class com.sm.store.client.netty.ClusterClientHandler
 
getSerializer() - Method in class com.sm.store.client.netty.ScanClientHandler
 
getStore() - Method in class com.sm.store.client.ClusterClient
 
getStore() - Method in class com.sm.store.client.ClusterClientFactory
 
getStore() - Method in class com.sm.store.client.RemoteClientImpl
 
getStoreConfigList() - Method in class com.sm.store.client.ClusterClientFactory
 
getStoreProc() - Method in class com.sm.store.client.ClusterClient.RunThread
 
getTCPClient() - Method in class com.sm.store.client.grizzly.GZRemoteClientImpl
 
getTCPClient() - Method in class com.sm.store.client.grizzly.GZScanClientImpl
 
getTCPClient() - Method in class com.sm.store.client.netty.NTRemoteClientImpl
 
getTCPClient() - Method in class com.sm.store.client.netty.ScanClientImpl
 
getTCPClient() - Method in class com.sm.store.client.RemoteClientImpl
 
getTcpClient() - Method in class com.sm.store.cluster.Connection
 
getTimeout() - Method in class com.sm.store.client.ClientConnections
 
getTotalPartition() - Method in class com.sm.store.client.ClientConnections
 
getType() - Method in class com.sm.store.client.ClientConnections
 
getUrl() - Method in class com.sm.store.client.ClusterClientFactory
 
GZRemoteClientImpl - Class in com.sm.store.client.grizzly
 
GZRemoteClientImpl(String, Serializer, String) - Constructor for class com.sm.store.client.grizzly.GZRemoteClientImpl
 
GZRemoteClientImpl(String, Serializer, String, boolean) - Constructor for class com.sm.store.client.grizzly.GZRemoteClientImpl
 
GZRemoteClientImpl(String, Serializer, String, boolean, long) - Constructor for class com.sm.store.client.grizzly.GZRemoteClientImpl
 
GZScanClientImpl - Class in com.sm.store.client.grizzly
 
GZScanClientImpl(String, Serializer, String) - Constructor for class com.sm.store.client.grizzly.GZScanClientImpl
 
GZScanClientImpl(String, Serializer, String, int) - Constructor for class com.sm.store.client.grizzly.GZScanClientImpl
 
GZScanClientImpl(String, Serializer, String, int, boolean) - Constructor for class com.sm.store.client.grizzly.GZScanClientImpl
 
GZScanClientImpl(String, Serializer, String, int, boolean, long) - Constructor for class com.sm.store.client.grizzly.GZScanClientImpl
 

H

handleRead(FilterChainContext) - Method in class com.sm.store.client.grizzly.ClusterClientFilter
 
handleRead(FilterChainContext) - Method in class com.sm.store.client.grizzly.StoreClientFilter
 
handleUpstream(ChannelHandlerContext, ChannelEvent) - Method in class com.sm.store.client.netty.StoreClientHandler
 
hash(Key) - Method in class com.sm.store.client.FnvHash
Use FnvHashFunction to perform hash funtion instead Key.hashCode
hash(byte[]) - Method in class com.sm.store.client.FnvHash
 
hash(int) - Method in class com.sm.store.client.FnvHash
Static function to apply fnv hash function
hash(long) - Static method in class com.sm.store.client.FnvHash
Static function to apply fnv hash function
hashCode() - Method in class com.sm.store.cluster.Connection
 
hasNext() - Method in class com.sm.connector.client.MD5Reader
 
hasNext() - Method in class com.sm.store.client.ScanIterator
 

I

index - Variable in class com.sm.store.client.RemoteClientImpl
 
init() - Method in class com.sm.connector.client.MD5Reader
 
init() - Method in class com.sm.store.client.RemoteClientImpl
 
insert(Key, Value) - Method in class com.sm.store.client.ClusterClient
 
insert(Key, Value) - Method in class com.sm.store.client.ClusterClientImpl
 
insert(Key, Value) - Method in class com.sm.store.client.LocalClientImpl
 
insert(Key, Value) - Method in class com.sm.store.client.LocalClusterClientImpl
 
insert(Key, Value) - Method in class com.sm.store.client.RemoteClientImpl
 
invoke(Invoker) - Method in class com.sm.store.client.ClusterClient
invoke store proc across clusters without passing keyList one node per cluster
invoke(Request, Channel) - Method in class com.sm.store.client.netty.StoreClientHandler
 
invoke(Invoker) - Method in class com.sm.store.client.RemoteClientImpl
 
invokeMapReduce(Invoker) - Method in class com.sm.store.client.ClusterClient
invoke MapReduce store proc across the cluster, The goal is to use max number of node so it try to invoke every node in each cluster, instead of one node per cluster data node will be provided partition information through additional parameter add to invoker in the format of (node#, total nodes)
isConnected() - Method in class com.sm.store.cluster.Connection
 
isDown() - Method in class com.sm.store.cluster.Connection
 
isEnd(long) - Method in class com.sm.connector.client.MD5Reader
 
isEnd() - Method in class com.sm.store.client.ClusterClient.ClusterCursor
 
isSameCluster(Pair<Short, Integer>) - Method in class com.sm.store.client.ClusterClient.KeyCluster
 
isStop() - Method in class com.sm.store.client.ClusterClient.ClusterCursor
 

L

length - Variable in class com.sm.connector.client.MD5Reader
 
LocalClientImpl - Class in com.sm.store.client
 
LocalClientImpl(String, Serializer, int) - Constructor for class com.sm.store.client.LocalClientImpl
 
LocalClientImpl(String, Serializer, boolean, int) - Constructor for class com.sm.store.client.LocalClientImpl
 
LocalClientImpl(String, Serializer, String, boolean, BlockSize, int) - Constructor for class com.sm.store.client.LocalClientImpl
 
LocalClusterClientImpl - Class in com.sm.store.client
 
LocalClusterClientImpl(RemoteStore) - Constructor for class com.sm.store.client.LocalClusterClientImpl
 
LocalClusterClientImpl(RemoteStore, Serializer) - Constructor for class com.sm.store.client.LocalClusterClientImpl
 

M

map - Variable in class com.sm.store.client.netty.StoreClientHandler
 
MAX_TRY - Static variable in class com.sm.store.cluster.Connection
 
MD5Reader - Class in com.sm.connector.client
Created by mhsieh on 3/3/16.
MD5Reader(String) - Constructor for class com.sm.connector.client.MD5Reader
 
MD5Reader(String, int) - Constructor for class com.sm.connector.client.MD5Reader
 
mergeCluster(List<Runnable>, ClusterClient.ClusterCursor) - Method in class com.sm.store.client.ClusterClient
 
mergeResponse(List<Runnable>) - Method in class com.sm.store.client.ClusterClient
 
mergeStoreProc(List<Runnable>) - Method in class com.sm.store.client.ClusterClient
 
messageReceived(ChannelHandlerContext, MessageEvent) - Method in class com.sm.store.client.netty.ClusterClientHandler
 
messageReceived(ChannelHandlerContext, MessageEvent) - Method in class com.sm.store.client.netty.StoreClientHandler
based upon request type there are different way to handle request payload Invoker type will just pass through, let client handle the
multiGets(List<Key>, String) - Method in class com.sm.store.client.ClusterClient
 
multiGets(List<Key>) - Method in class com.sm.store.client.ClusterClient
 
multiGets(List<Key>) - Method in class com.sm.store.client.netty.ScanClientImpl
batch get
multiPuts(List<KeyValue>, String) - Method in class com.sm.store.client.ClusterClient
 
multiPuts(List<KeyValue>) - Method in class com.sm.store.client.ClusterClient
 
multiPuts(List<KeyValue>) - Method in class com.sm.store.client.netty.ScanClientImpl
perform batch put
multiRemoves(List<Key>) - Method in class com.sm.store.client.ClusterClient
 
multiRemoves(List<Key>) - Method in class com.sm.store.client.netty.ScanClientImpl
 
multiSelectQuery(List<Key>, String) - Method in class com.sm.store.client.netty.ScanClientImpl
 
multiUpdateQuery(List<Key>, String) - Method in class com.sm.store.client.netty.ScanClientImpl
 
multiValueUpdateQuery(List<KeyValue>, String) - Method in class com.sm.store.client.netty.ScanClientImpl
 

N

next() - Method in class com.sm.connector.client.MD5Reader
 
next() - Method in class com.sm.store.client.ScanIterator
 
nextByte - Variable in class com.sm.connector.client.MD5Reader
 
nextCursor(ClusterClient.ClusterCursor) - Method in class com.sm.store.client.ClusterClient
nextCursor will continue call to each cluster node to iterate through server side cursor isEnd() return true, mean the end of cursor for each cluster
nextCursor(CursorPara) - Method in class com.sm.store.client.netty.ScanClientImpl
Table scan of key set to return List in key set cursorPara.isEnd() is true, means end of cursor to retrieve List by calling cursorPara.getKeyValue()
nio - Variable in class com.sm.store.client.ClientConnections
 
nio - Variable in class com.sm.store.client.ClusterClient
 
nio - Variable in class com.sm.store.client.RemoteClientImpl
 
NTRemoteClientImpl - Class in com.sm.store.client.netty
 
NTRemoteClientImpl(String, Serializer, String) - Constructor for class com.sm.store.client.netty.NTRemoteClientImpl
 
NTRemoteClientImpl(String, Serializer, String, boolean) - Constructor for class com.sm.store.client.netty.NTRemoteClientImpl
 
NTRemoteClientImpl(String, Serializer, String, boolean, long) - Constructor for class com.sm.store.client.netty.NTRemoteClientImpl
 

O

openKeyCursor(short) - Method in class com.sm.store.client.ClusterClient
 
openKeyCursor(short) - Method in class com.sm.store.client.netty.ScanClientImpl
Table scan of key set to return List in key set cursorPara.isEnd() is true, means end of cursor to retrieve List by calling cursorPara.getKeyValue()
openKeyCursor(short, String) - Method in class com.sm.store.client.netty.ScanClientImpl
 
openKeyValueCursor(short) - Method in class com.sm.store.client.ClusterClient
Table scan of key set to return List in key set cursorPara.isEnd() is true, means end of cursor to retrieve List by calling cursorPara.getKeyValue()
openKeyValueCursor(short) - Method in class com.sm.store.client.netty.ScanClientImpl
Table scan of key set to return List in key set cursorPara.isEnd() is true, means end of cursor to retrieve List by calling cursorPara.getKeyValue()
openKeyValueCursor(short, String) - Method in class com.sm.store.client.netty.ScanClientImpl
 
openQueryCursor(short, String) - Method in class com.sm.store.client.netty.ScanClientImpl
 
openScanCursor(short, Key, Key) - Method in class com.sm.store.client.ClusterClient
 
openScanCursor(short, Key, Key) - Method in class com.sm.store.client.netty.ScanClientImpl
Table scan of key set to return List in key set cursorPara.isEnd() is true, means end of cursor to retrieve List by calling cursorPara.getKeyValue()
openScanCursor(short, Key, Key, String) - Method in class com.sm.store.client.netty.ScanClientImpl
 

P

pack(int) - Method in class com.sm.store.client.ClusterClient
 
pack(int) - Method in class com.sm.store.client.ClusterClientImpl
 
pack(int) - Method in class com.sm.store.client.LocalClusterClientImpl
 
pack(int) - Method in class com.sm.store.client.RemoteClientImpl
 
PartitionClient<T> - Class in com.sm.connector.client
Created by mhsieh on 2/25/16.
PartitionClient(Invoker, String, Class<Aggregate<T>>) - Constructor for class com.sm.connector.client.PartitionClient
 
PartitionClient.RunThread - Class in com.sm.connector.client
 
PartitionClient.RunThread(int, RemoteClientImpl, int, int, Aggregate<T>) - Constructor for class com.sm.connector.client.PartitionClient.RunThread
 
pos - Variable in class com.sm.connector.client.MD5Reader
 
put(Key, Object) - Method in class com.sm.store.client.ClusterClient
 
put(Key, Value) - Method in class com.sm.store.client.ClusterClient
 
put(Key, Value) - Method in class com.sm.store.client.ClusterClientImpl
 
put(Key, Object) - Method in class com.sm.store.client.ClusterClientImpl
 
put(Key, Object) - Method in class com.sm.store.client.LocalClientImpl
 
put(Key, Value) - Method in class com.sm.store.client.LocalClusterClientImpl
 
put(Key, Object) - Method in class com.sm.store.client.LocalClusterClientImpl
 
put(Key, Object) - Method in class com.sm.store.client.RemoteClientImpl
 
put(Key, Value) - Method in class com.sm.store.client.RemoteClientImpl
 
put4Php(Key, Value) - Method in class com.sm.store.client.RemoteClientImpl
 
put4Value(Key, Value) - Method in class com.sm.store.client.RemoteClientImpl
put4Value is primary to put Value into KeyStore KeyStore value is encoded different, It bypass the serializer use Utils.putLong and putInt to encode byte[], use RemoteValue to construct value object
putIfAbsent(BlockingQueue<Connection>) - Method in class com.sm.store.cluster.Connection
 

Q

query(String) - Method in class com.sm.store.client.ClusterClient
 
query(String) - Method in class com.sm.store.client.RemoteClientImpl
 
query4Json(String) - Method in class com.sm.store.client.ClusterClient
 
query4Json(String) - Method in class com.sm.store.client.RemoteClientImpl
 

R

rebalance(List<ClusterClient.KeyCluster>) - Method in class com.sm.store.client.ClusterClient
 
reconnect(long) - Method in class com.sm.store.cluster.Connection
 
reconnect() - Method in class com.sm.store.cluster.Connection
 
reloadClusterClient() - Method in class com.sm.store.client.ClusterClientFactory
 
RemoteClientImpl - Class in com.sm.store.client
 
RemoteClientImpl() - Constructor for class com.sm.store.client.RemoteClientImpl
 
remoteFromQueue(BlockingQueue<Connection>) - Method in class com.sm.store.cluster.Connection
 
remove(Key) - Method in class com.sm.store.client.ClusterClient
 
remove(Key) - Method in class com.sm.store.client.ClusterClientImpl
 
remove(Key) - Method in class com.sm.store.client.LocalClusterClientImpl
 
remove(Key) - Method in class com.sm.store.client.RemoteClientImpl
 
resetCursorParaList() - Method in class com.sm.store.client.ClusterClient.ClusterCursor
 
run() - Method in class com.sm.store.client.ClusterClient.RunThread
 

S

scan(Key, Key) - Method in class com.sm.store.client.ClusterClient
 
scan(Key, Key, String) - Method in class com.sm.store.client.ClusterClient
OpType to determine deserialze payload during merge MultiGets means payload is byte[], else payload is serialized object
scan(Key) - Method in class com.sm.store.client.ClusterClient
 
scan(Key, Key) - Method in class com.sm.store.client.netty.ScanClientImpl
 
scan(Key, Key, String) - Method in class com.sm.store.client.netty.ScanClientImpl
 
scan(Key) - Method in class com.sm.store.client.netty.ScanClientImpl
 
ScanClientHandler - Class in com.sm.store.client.netty
 
ScanClientHandler(long, Serializer) - Constructor for class com.sm.store.client.netty.ScanClientHandler
 
ScanClientHandler() - Constructor for class com.sm.store.client.netty.ScanClientHandler
 
ScanClientImpl - Class in com.sm.store.client.netty
 
ScanClientImpl() - Constructor for class com.sm.store.client.netty.ScanClientImpl
 
ScanClientImpl(String, Serializer, String) - Constructor for class com.sm.store.client.netty.ScanClientImpl
 
ScanClientImpl(String, Serializer, String, int) - Constructor for class com.sm.store.client.netty.ScanClientImpl
 
ScanClientImpl(String, Serializer, String, int, boolean) - Constructor for class com.sm.store.client.netty.ScanClientImpl
 
ScanClientImpl(String, Serializer, String, int, boolean, long) - Constructor for class com.sm.store.client.netty.ScanClientImpl
 
ScanIterator - Class in com.sm.store.client
 
ScanIterator(String, String, Key, Key) - Constructor for class com.sm.store.client.ScanIterator
 
ScanIterator(String, String, Key, Key, short) - Constructor for class com.sm.store.client.ScanIterator
 
selectQuery(Key, String) - Method in class com.sm.store.client.ClusterClient
 
selectQuery(Key, String) - Method in class com.sm.store.client.RemoteClientImpl
 
sendMessage(Request, Channel) - Method in class com.sm.store.client.netty.StoreClientHandler
 
sendPayload(byte[]) - Method in class com.sm.store.client.RemoteClientImpl
 
sendRequest(Request, Channel) - Method in class com.sm.store.client.netty.ClusterClientHandler
 
sendRequest(Request, Channel) - Method in class com.sm.store.client.netty.StoreClientHandler
 
sendRequest(Request) - Method in class com.sm.store.client.RemoteClientImpl
 
seqno - Variable in class com.sm.store.client.ClientConnections
 
seqno - Variable in class com.sm.store.client.RemoteClientImpl
 
serializer - Variable in class com.sm.store.client.ClusterClient
 
serializer - Variable in class com.sm.store.client.netty.ClusterClientHandler
 
serializer - Variable in class com.sm.store.client.netty.ScanClientHandler
 
serializer - Variable in class com.sm.store.client.RemoteClientImpl
 
setClient(Client) - Method in class com.sm.store.client.RemoteClientImpl
 
setClientType(TCPClientFactory.ClientType) - Method in class com.sm.store.client.ClientConnections
 
setClientType(TCPClientFactory.ClientType) - Method in class com.sm.store.client.ClusterClient
 
setCurrent(long) - Method in class com.sm.connector.client.MD5Reader
 
setFreq(int) - Method in class com.sm.store.client.netty.ClusterClientHandler
 
setHash(Hash) - Method in class com.sm.store.client.ClientConnections
set cutomer hash function
setHashFunction(Hash) - Method in class com.sm.store.client.ClusterClient
 
setNio(boolean) - Method in class com.sm.store.client.ClientConnections
 
setNio(boolean) - Method in class com.sm.store.client.ClusterClient
 
setSerializeTpe(Header.SerializableType) - Method in class com.sm.store.client.ClusterClient
to support return as json string,using Header.SerializableType.Json
setStore(String) - Method in class com.sm.store.client.ClusterClient
 
setTimeout(long) - Method in class com.sm.store.client.ClientConnections
 
setTimeout(long) - Method in class com.sm.store.client.ClusterClient
set connection timeout
setType(Header.SerializableType) - Method in class com.sm.store.client.ClientConnections
 
setType(Header.SerializableType) - Method in class com.sm.store.client.RemoteClientImpl
 
shutdown() - Method in class com.sm.store.client.ClientConnections
 
shutdown() - Method in class com.sm.store.client.ClusterClient
 
shutdown() - Method in class com.sm.store.cluster.Connection
 
size - Variable in class com.sm.connector.client.MD5Reader
 
SIZE - Static variable in class com.sm.connector.client.MD5Reader
 
size() - Method in class com.sm.store.client.ClusterClient
 
size() - Method in class com.sm.store.client.ClusterClientImpl
 
size() - Method in class com.sm.store.client.LocalClusterClientImpl
 
size() - Method in class com.sm.store.client.RemoteClientImpl
 
stop() - Method in class com.sm.store.client.ClientConnections
 
store - Variable in class com.sm.store.client.ClusterClient
 
store - Variable in class com.sm.store.client.RemoteClientImpl
 
StoreClientFilter - Class in com.sm.store.client.grizzly
 
StoreClientFilter(long) - Constructor for class com.sm.store.client.grizzly.StoreClientFilter
 
StoreClientFilter(long, Serializer) - Constructor for class com.sm.store.client.grizzly.StoreClientFilter
 
StoreClientHandler - Class in com.sm.store.client.netty
 
StoreClientHandler(long) - Constructor for class com.sm.store.client.netty.StoreClientHandler
 
StoreClientHandler() - Constructor for class com.sm.store.client.netty.StoreClientHandler
 
switchStore(String) - Method in class com.sm.store.client.ClusterClientFactory
 

T

tcpClient - Variable in class com.sm.store.cluster.Connection
 
TCPClientFactory - Class in com.sm.store.client
 
TCPClientFactory() - Constructor for class com.sm.store.client.TCPClientFactory
 
TCPClientFactory.ClientType - Enum in com.sm.store.client
 
timeout - Variable in class com.sm.store.client.ClusterClient
 
timeout - Variable in class com.sm.store.client.netty.StoreClientHandler
 
timeout - Variable in class com.sm.store.client.RemoteClientImpl
 
toString() - Method in class com.sm.store.client.ClusterClient.KeyCluster
 
toString() - Method in class com.sm.store.client.RemoteClientImpl
 
toString() - Method in class com.sm.store.cluster.Connection
 
type - Variable in class com.sm.store.client.ClientConnections
 
type - Variable in class com.sm.store.client.RemoteClientImpl
 

U

updateQuery(Key, Value, String) - Method in class com.sm.store.client.ClusterClient
 
updateQuery(Key, Value, String) - Method in class com.sm.store.client.RemoteClientImpl
 
url - Variable in class com.sm.store.client.RemoteClientImpl
 
urlArrays - Variable in class com.sm.store.client.RemoteClientImpl
 
useNext - Variable in class com.sm.connector.client.MD5Reader
 
Utils - Class in com.sm.store.client
 
Utils() - Constructor for class com.sm.store.client.Utils
 

V

valueOf(String) - Static method in enum com.sm.store.client.TCPClientFactory.ClientType
Returns the enum constant of this type with the specified name.
values() - Static method in enum com.sm.store.client.TCPClientFactory.ClientType
Returns an array containing the constants of this enum type, in the order they are declared.
A B C D E F G H I L M N O P Q R S T U V 

Copyright © 2016. All rights reserved.