public class ClusterStoreCallBack extends Scan4CallBack
Modifier and Type | Field and Description |
---|---|
protected ClusterNodes |
clusterNodes |
protected static org.apache.commons.logging.Log |
logger |
remoteConfig
delay, embeddedSerializer, mapper, MAX_SIZE, serializer, serverState, storeList, storeMaps, WSHandler
Constructor and Description |
---|
ClusterStoreCallBack(ConcurrentMap<String,RemoteStore> storeMaps,
Serializer serializer,
ClusterNodes clusterNodes) |
Modifier and Type | Method and Description |
---|---|
protected void |
init()
sorted == true, create RemoteScanStore, otherwise RemoteStore
|
Response |
processRequest(Request request)
try to reuse StoreServerHandler which assume response payload had been serialized
unlike ScanStore which assume response payload is a object
|
protected StoreParas |
processStoreParas(Request request) |
processScan
addStore, addStore, checkValue, getEmbeddedSerializer, getRemoteStore, getSerializer, getStoreMaps, getWSHandler, processFullQuery, processGet, processGetNoBlock, processGetNoBlockInt, processGetSeqNo, processGetSeqNoInt, processInsert, processKeyIterator, processParas, processPut, processQueryPut, processQueryStr, processQueryStr, processRemove, processSelectQuery, processUpdateQuery, serializerResponse, setWSHandler
protected static final org.apache.commons.logging.Log logger
protected ClusterNodes clusterNodes
public ClusterStoreCallBack(ConcurrentMap<String,RemoteStore> storeMaps, Serializer serializer, ClusterNodes clusterNodes)
protected void init()
Scan4CallBack
init
in class Scan4CallBack
public Response processRequest(Request request)
Scan4CallBack
processRequest
in interface TCPCallBack
processRequest
in class Scan4CallBack
protected StoreParas processStoreParas(Request request)
processStoreParas
in class StoreCallBack
Copyright © 2016. All rights reserved.