Package | Description |
---|---|
com.sm.connector.server | |
com.sm.store | |
com.sm.store.server |
Constructor and Description |
---|
ExecMapReduce(Map<String,RemoteStore> remoteStoreMap,
Class<T> tClass,
MapReduce<T> mapReduce) |
ExecMapReduce(Map<String,RemoteStore> remoteStoreMap,
Class<T> tClass,
MapReduce<T> mapReduce,
Serializer serializer) |
ExecMapReduce(Map<String,RemoteStore> remoteStoreMap,
Class<T> tClass,
MapReduce<T> mapReduce,
Serializer serializer,
String predicateQuery,
Filter.Impl impl) |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<String,RemoteStore> |
ServerWSHandler.storeMaps |
Modifier and Type | Method and Description |
---|---|
ConcurrentMap<String,RemoteStore> |
ServerWSHandler.getStoreMaps() |
Modifier and Type | Method and Description |
---|---|
void |
StoreMap.setStoreMap(ConcurrentMap<String,RemoteStore> storeMaps) |
Constructor and Description |
---|
ServerWSHandler(ConcurrentMap<String,RemoteStore> storeMaps) |
ServerWSHandler(ConcurrentMap<String,RemoteStore> storeMaps,
Loader loader) |
Modifier and Type | Class and Description |
---|---|
class |
AdminClusterStore |
class |
ClusterStore |
class |
RemoteScanStore |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<String,RemoteStore> |
StoreCallBack.storeMaps |
protected ConcurrentMap<String,RemoteStore> |
ClusterStoreServer.storeMaps |
Modifier and Type | Method and Description |
---|---|
RemoteStore |
QueryIterator.getRemoteStore() |
RemoteStore |
StoreCallBack.getRemoteStore(String store) |
RemoteStore |
RemoteStoreServer.getRemoteStore(String store) |
Modifier and Type | Method and Description |
---|---|
ConcurrentMap<String,RemoteStore> |
StoreCallBack.getStoreMaps() |
ConcurrentMap<String,RemoteStore> |
ClusterStoreServer.getStoreMaps() |
Modifier and Type | Method and Description |
---|---|
boolean |
RemoteStoreServer.addRemoteStore(RemoteStore remoteStore) |
boolean |
StoreCallBack.addStore(RemoteStore remoteStore) |
protected List<voldemort.store.cachestore.voldeimpl.KeyValue> |
StoreCallBack.processFullQuery(QueryIterator queryIterator,
String queryStr,
RemoteStore store) |
protected voldemort.store.cachestore.Value |
StoreCallBack.processGet(RemoteStore store,
voldemort.store.cachestore.Key key) |
protected voldemort.store.cachestore.Value |
StoreCallBack.processGetNoBlock(RemoteStore store,
StoreParas paras) |
protected voldemort.store.cachestore.Value |
StoreCallBack.processGetNoBlockInt(RemoteStore store,
StoreParas paras) |
protected voldemort.store.cachestore.Value |
StoreCallBack.processGetSeqNo(RemoteStore store,
voldemort.store.cachestore.Key key) |
protected voldemort.store.cachestore.Value |
StoreCallBack.processGetSeqNoInt(RemoteStore store,
voldemort.store.cachestore.Key key) |
protected void |
StoreCallBack.processInsert(RemoteStore store,
voldemort.store.cachestore.Key key,
voldemort.store.cachestore.Value value) |
protected void |
StoreCallBack.processParas(StoreParas paras,
RemoteStore store) |
protected void |
StoreCallBack.processPut(RemoteStore store,
voldemort.store.cachestore.Key key,
voldemort.store.cachestore.Value value) |
protected Response |
StoreCallBack.processQueryPut(KeyValueParas keyValueParas,
RemoteStore store)
will deprecate MultiSelectQuery.
|
protected KeyValueParas |
StoreCallBack.processQueryStr(RemoteStore store,
List<voldemort.store.cachestore.voldeimpl.KeyValue> list,
String queryStr) |
protected KeyValueParas |
StoreCallBack.processQueryStr(RemoteStore store,
List<voldemort.store.cachestore.voldeimpl.KeyValue> list,
String queryStr,
OpType opType) |
protected boolean |
StoreCallBack.processRemove(RemoteStore store,
voldemort.store.cachestore.Key key) |
protected voldemort.store.cachestore.Value |
StoreCallBack.processSelectQuery(RemoteStore store,
voldemort.store.cachestore.Key key,
voldemort.store.cachestore.Value value) |
protected void |
StoreCallBack.processUpdateQuery(RemoteStore store,
voldemort.store.cachestore.Key key,
voldemort.store.cachestore.Value value) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,voldemort.store.cachestore.impl.CacheStore> |
ClusterStoreServer.buildMap(Map<String,RemoteStore> storeMap) |
Constructor and Description |
---|
QueryIterator(Stack<Predicate> predicateStack,
boolean tableScan,
RemoteStore remoteStore) |
Constructor and Description |
---|
ClusterStoreCallBack(ConcurrentMap<String,RemoteStore> storeMaps,
Serializer serializer,
ClusterNodes clusterNodes) |
Copyright © 2016. All rights reserved.