beehive.util

Class HashTableThriftHandler

java.lang.Object

beehive.util.HashTableThriftHandler

All Implemented Interfaces:

HashtableServer, Remote

public final class HashTableThriftHandler
extends Object
implements HashtableServer

Field Summary

Fields

Modifier and Type	Field and Description
static String	RPC_MECHANISM

Constructor Summary

Constructors

Constructor and Description
HashTableThriftHandler(StorageSystem storagesystem, String host, Config configParams)

Method Summary

Modifier and Type	Method and Description
void	cacheEvictMasterNotify(String cachingServerId, Hashtable<String,Long> evictedNodes)
void	cacheInvalidate(String nodeID)
Vector<ResultObject>	cachePut(Map<Integer,Vector<Node>> nodes, long storageSystemThreadId)
ResultObject	cachePut(String nodeID, Node node, int masterCopySite, long storageSystemThreadId)
void	clearStatContainers()
boolean	contains(String key)
ResultObject	exec(NodeData nd)
Vector<ResultObject>	execBulk(Vector<NodeData> keyList)
ResultObject	get(String key, long storageSystemThreadId)
Vector<String>	getAllKeys()
Vector<Node>	getAllNodes()
Vector<Node>	getCachedObjects(Vector<String> nodeIds)
ClusterMeasures	getClusterMeasures()
Vector<ResultObject>	getLocalNodes(Vector<String> nodeIds, long storageSystemThreadId)
Node	getNodeForCaching(String nodeID, int cachingSite)
Node	getNodeFromCacheTable(String nodeId)
Node	getNodeFromTable(String nodeId)
ResultObject	getNodeProperties(NodeData nodeData)
Vector<Node>	getNodesForCaching(Vector<String> nodeIds, int callingSite)
int	getNumServers()
Vector<ResultObject>	getObjects(Vector<String> keyList)
Vector<ResultObject>	getObjectsProperties(Vector<NodeData> vec)
int	getServerId()
String	getStats()
void	loadNodes(Vector<Node> nodes)
void	locationChange(int nodeId, String serverName)
ResultObject	lock(int nodeId)
Date	ping()
ResultObject	put(String key, Object value)
ResultObject	put(String key, Object value, int callingServerId)
Vector<ResultObject>	putObjects(ConcurrentHashMap<String,Node> objList)
Vector<ResultObject>	putObjects(ConcurrentHashMap<String,Node> objList, int callerServerId)
ResultObject	relocate(int nodeId, String serverName)
void	removeLocationTableEntry(String key)
void	setNumServers(int n)
ResultObject	updateNodeProperties(NodeData nodeData)
Vector<ResultObject>	updateNodePropertiesParallel(Vector<NodeData> vec)
void	writeThroughToCache(String paramString, Object value)
void	writeThroughToCacheBulk(ConcurrentHashMap<String,Node> map)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

RPC_MECHANISM

public static String RPC_MECHANISM

Constructor Detail

HashTableThriftHandler

public HashTableThriftHandler(StorageSystem storagesystem,
                              String host,
                              Config configParams)

Method Detail

updateNodeProperties

public ResultObject updateNodeProperties(NodeData nodeData)
                                  throws RemoteException

Specified by:

updateNodeProperties in interface HashtableServer

Throws:

RemoteException

getNodeProperties

public ResultObject getNodeProperties(NodeData nodeData)
                               throws RemoteException

Specified by:

getNodeProperties in interface HashtableServer

Throws:

RemoteException

updateNodePropertiesParallel

public Vector<ResultObject> updateNodePropertiesParallel(Vector<NodeData> vec)
                                                  throws RemoteException

Specified by:

updateNodePropertiesParallel in interface HashtableServer

Throws:

RemoteException

getObjectsProperties

public Vector<ResultObject> getObjectsProperties(Vector<NodeData> vec)
                                          throws RemoteException

Specified by:

getObjectsProperties in interface HashtableServer

Throws:

RemoteException

ping

public Date ping()
          throws RemoteException

Specified by:

ping in interface HashtableServer

Throws:

RemoteException

put

public ResultObject put(String key,
                        Object value)
                 throws RemoteException

Specified by:

put in interface HashtableServer

Throws:

RemoteException

put

public ResultObject put(String key,
                        Object value,
                        int callingServerId)
                 throws RemoteException

Specified by:

put in interface HashtableServer

Throws:

RemoteException

get

public ResultObject get(String key,
                        long storageSystemThreadId)
                 throws RemoteException

Specified by:

get in interface HashtableServer

Throws:

RemoteException

getObjects

public Vector<ResultObject> getObjects(Vector<String> keyList)
                                throws RemoteException

Specified by:

getObjects in interface HashtableServer

Throws:

RemoteException

putObjects

public Vector<ResultObject> putObjects(ConcurrentHashMap<String,Node> objList)
                                throws RemoteException

Specified by:

putObjects in interface HashtableServer

Throws:

RemoteException

exec

public ResultObject exec(NodeData nd)
                  throws RemoteException

Specified by:

exec in interface HashtableServer

Throws:

RemoteException

execBulk

public Vector<ResultObject> execBulk(Vector<NodeData> keyList)
                              throws RemoteException

Specified by:

execBulk in interface HashtableServer

Throws:

RemoteException

putObjects

public Vector<ResultObject> putObjects(ConcurrentHashMap<String,Node> objList,
                                       int callerServerId)
                                throws RemoteException

Specified by:

putObjects in interface HashtableServer

Throws:

RemoteException

contains

public boolean contains(String key)
                 throws RemoteException

Specified by:

contains in interface HashtableServer

Throws:

RemoteException

getAllNodes

public Vector<Node> getAllNodes()
                         throws RemoteException

Specified by:

getAllNodes in interface HashtableServer

Throws:

RemoteException

getAllKeys

public Vector<String> getAllKeys()
                          throws RemoteException

Specified by:

getAllKeys in interface HashtableServer

Throws:

RemoteException

getStats

public String getStats()
                throws RemoteException

Specified by:

getStats in interface HashtableServer

Throws:

RemoteException

clearStatContainers

public void clearStatContainers()
                         throws RemoteException

Specified by:

clearStatContainers in interface HashtableServer

Throws:

RemoteException

getNodeFromTable

public Node getNodeFromTable(String nodeId)
                      throws RemoteException

Specified by:

getNodeFromTable in interface HashtableServer

Throws:

RemoteException

loadNodes

public void loadNodes(Vector<Node> nodes)
               throws RemoteException

Specified by:

loadNodes in interface HashtableServer

Throws:

RemoteException

getServerId

public int getServerId()
                throws RemoteException

Specified by:

getServerId in interface HashtableServer

Throws:

RemoteException

getNumServers

public int getNumServers()
                  throws RemoteException

Specified by:

getNumServers in interface HashtableServer

Throws:

RemoteException

setNumServers

public void setNumServers(int n)
                   throws RemoteException

Specified by:

setNumServers in interface HashtableServer

Throws:

RemoteException

relocate

public ResultObject relocate(int nodeId,
                             String serverName)
                      throws RemoteException

Specified by:

relocate in interface HashtableServer

Throws:

RemoteException

locationChange

public void locationChange(int nodeId,
                           String serverName)
                    throws RemoteException

Specified by:

locationChange in interface HashtableServer

Throws:

RemoteException

lock

public ResultObject lock(int nodeId)
                  throws RemoteException

Specified by:

lock in interface HashtableServer

Throws:

RemoteException

removeLocationTableEntry

public void removeLocationTableEntry(String key)
                              throws RemoteException

Specified by:

removeLocationTableEntry in interface HashtableServer

Throws:

RemoteException

getClusterMeasures

public ClusterMeasures getClusterMeasures()
                                   throws RemoteException

Specified by:

getClusterMeasures in interface HashtableServer

Throws:

RemoteException

cacheInvalidate

public void cacheInvalidate(String nodeID)
                     throws RemoteException

Specified by:

cacheInvalidate in interface HashtableServer

Throws:

RemoteException

getNodeForCaching

public Node getNodeForCaching(String nodeID,
                              int cachingSite)
                       throws RemoteException

Specified by:

getNodeForCaching in interface HashtableServer

Throws:

RemoteException

cachePut

public ResultObject cachePut(String nodeID,
                             Node node,
                             int masterCopySite,
                             long storageSystemThreadId)
                      throws RemoteException

Specified by:

cachePut in interface HashtableServer

Throws:

RemoteException

cachePut

public Vector<ResultObject> cachePut(Map<Integer,Vector<Node>> nodes,
                                     long storageSystemThreadId)
                              throws RemoteException

Specified by:

cachePut in interface HashtableServer

Throws:

RemoteException

getLocalNodes

public Vector<ResultObject> getLocalNodes(Vector<String> nodeIds,
                                          long storageSystemThreadId)
                                   throws RemoteException

Specified by:

getLocalNodes in interface HashtableServer

Throws:

RemoteException

getNodesForCaching

public Vector<Node> getNodesForCaching(Vector<String> nodeIds,
                                       int callingSite)
                                throws RemoteException

Specified by:

getNodesForCaching in interface HashtableServer

Throws:

RemoteException

writeThroughToCache

public void writeThroughToCache(String paramString,
                                Object value)
                         throws RemoteException

Specified by:

writeThroughToCache in interface HashtableServer

Throws:

RemoteException

writeThroughToCacheBulk

public void writeThroughToCacheBulk(ConcurrentHashMap<String,Node> map)
                             throws RemoteException

Specified by:

writeThroughToCacheBulk in interface HashtableServer

Throws:

RemoteException

getNodeFromCacheTable

public Node getNodeFromCacheTable(String nodeId)
                           throws RemoteException

Specified by:

getNodeFromCacheTable in interface HashtableServer

Throws:

RemoteException

getCachedObjects

public Vector<Node> getCachedObjects(Vector<String> nodeIds)
                              throws RemoteException

Specified by:

getCachedObjects in interface HashtableServer

Throws:

RemoteException

cacheEvictMasterNotify

public void cacheEvictMasterNotify(String cachingServerId,
                                   Hashtable<String,Long> evictedNodes)
                            throws RemoteException

Specified by:

cacheEvictMasterNotify in interface HashtableServer

Throws:

RemoteException