beehive.util

Class HashTableThriftHandler

java.lang.Object

beehive.util.HashTableThriftHandler

All Implemented Interfaces:

HashtableServer, java.rmi.Remote

public final class HashTableThriftHandler
extends java.lang.Object
implements HashtableServer

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	RPC_MECHANISM

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
int	acquireLocks(java.util.SortedSet<LockRequest> lockRequests)
void	cacheEvictMasterNotify(java.lang.String cachingServerId, java.util.Hashtable<java.lang.String,java.lang.Long> evictedNodes)
void	cacheInvalidate(java.lang.String nodeID)
java.util.Vector<ResultObject>	cachePut(java.util.Map<java.lang.Integer,java.util.Vector<Node>> nodes, long storageSystemThreadId)
ResultObject	cachePut(java.lang.String nodeID, Node node, int masterCopySite, long storageSystemThreadId)
void	checkpoint()
void	clearStatContainers()
void	commitChanges(java.util.Set<Node> write, java.util.Set<NodeData> writeNd, java.util.Map<java.lang.String,java.lang.Long> read)
boolean	contains(java.lang.String key)
ResultObject	exec(NodeData nd)
java.util.Vector<ResultObject>	execBulk(java.util.Vector<NodeData> keyList)
ResultObject	get(java.lang.String key, long storageSystemThreadId)
java.util.Vector<java.lang.String>	getAllKeys()
java.util.Vector<Node>	getAllNodes()
java.util.Vector<Node>	getCachedObjects(java.util.Vector<java.lang.String> nodeIds)
java.util.Vector<ResultObject>	getLocalNodes(java.util.Vector<java.lang.String> nodeIds, long storageSystemThreadId)
Node	getNodeForCaching(java.lang.String nodeID, int cachingSite)
Node	getNodeFromCacheTable(java.lang.String nodeId)
Node	getNodeFromTable(java.lang.String nodeId)
ResultObject	getNodeProperties(NodeData nodeData)
java.util.Vector<Node>	getNodesForCaching(java.util.Vector<java.lang.String> nodeIds, int callingSite)
int	getNumServers()
java.util.Vector<ResultObject>	getObjects(java.util.Vector<java.lang.String> keyList)
java.util.Vector<ResultObject>	getObjectsProperties(java.util.Vector<NodeData> vec)
int	getServerId()
java.lang.String	getStats()
void	loadNodes(java.util.Vector<Node> nodes)
void	locationChange(int nodeId, java.lang.String serverName)
ResultObject	lock(int nodeId)
java.util.Date	ping()
ResultObject	put(java.lang.String key, java.lang.Object value)
ResultObject	put(java.lang.String key, java.lang.Object value, int callingServerId)
java.util.Vector<ResultObject>	putObjects(java.util.concurrent.ConcurrentHashMap<java.lang.String,Node> objList)
java.util.Vector<ResultObject>	putObjects(java.util.concurrent.ConcurrentHashMap<java.lang.String,Node> objList, int callerServerId)
void	releaseLock(java.util.SortedSet<LockRequest> lockRequests)
ResultObject	relocate(int nodeId, java.lang.String serverName)
void	removeLocationTableEntry(java.lang.String key)
void	setNumServers(int n)
ResultObject	updateNodeProperties(NodeData nodeData)
java.util.Vector<ResultObject>	updateNodePropertiesParallel(java.util.Vector<NodeData> vec)
void	writeThroughToCache(java.lang.String paramString, java.lang.Object value)
void	writeThroughToCacheBulk(java.util.concurrent.ConcurrentHashMap<java.lang.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 java.lang.String RPC_MECHANISM

Constructor Detail

HashTableThriftHandler

public HashTableThriftHandler(StorageSystem storagesystem,
                              java.lang.String host,
                              Config configParams)

Method Detail

updateNodeProperties

public ResultObject updateNodeProperties(NodeData nodeData)
                                  throws java.rmi.RemoteException

Specified by:

updateNodeProperties in interface HashtableServer

Throws:

java.rmi.RemoteException

getNodeProperties

public ResultObject getNodeProperties(NodeData nodeData)
                               throws java.rmi.RemoteException

Specified by:

getNodeProperties in interface HashtableServer

Throws:

java.rmi.RemoteException

updateNodePropertiesParallel

public java.util.Vector<ResultObject> updateNodePropertiesParallel(java.util.Vector<NodeData> vec)
                                                            throws java.rmi.RemoteException

Specified by:

updateNodePropertiesParallel in interface HashtableServer

Throws:

java.rmi.RemoteException

getObjectsProperties

public java.util.Vector<ResultObject> getObjectsProperties(java.util.Vector<NodeData> vec)
                                                    throws java.rmi.RemoteException

Specified by:

getObjectsProperties in interface HashtableServer

Throws:

java.rmi.RemoteException

ping

public java.util.Date ping()
                    throws java.rmi.RemoteException

Specified by:

ping in interface HashtableServer

Throws:

java.rmi.RemoteException

put

public ResultObject put(java.lang.String key,
                        java.lang.Object value)
                 throws java.rmi.RemoteException

Specified by:

put in interface HashtableServer

Throws:

java.rmi.RemoteException

put

public ResultObject put(java.lang.String key,
                        java.lang.Object value,
                        int callingServerId)
                 throws java.rmi.RemoteException

Specified by:

put in interface HashtableServer

Throws:

java.rmi.RemoteException

get

public ResultObject get(java.lang.String key,
                        long storageSystemThreadId)
                 throws java.rmi.RemoteException

Specified by:

get in interface HashtableServer

Throws:

java.rmi.RemoteException

getObjects

public java.util.Vector<ResultObject> getObjects(java.util.Vector<java.lang.String> keyList)
                                          throws java.rmi.RemoteException

Specified by:

getObjects in interface HashtableServer

Throws:

java.rmi.RemoteException

putObjects

public java.util.Vector<ResultObject> putObjects(java.util.concurrent.ConcurrentHashMap<java.lang.String,Node> objList)
                                          throws java.rmi.RemoteException

Specified by:

putObjects in interface HashtableServer

Throws:

java.rmi.RemoteException

exec

public ResultObject exec(NodeData nd)
                  throws java.rmi.RemoteException

Specified by:

exec in interface HashtableServer

Throws:

java.rmi.RemoteException

execBulk

public java.util.Vector<ResultObject> execBulk(java.util.Vector<NodeData> keyList)
                                        throws java.rmi.RemoteException

Specified by:

execBulk in interface HashtableServer

Throws:

java.rmi.RemoteException

putObjects

public java.util.Vector<ResultObject> putObjects(java.util.concurrent.ConcurrentHashMap<java.lang.String,Node> objList,
                                                 int callerServerId)
                                          throws java.rmi.RemoteException

Specified by:

putObjects in interface HashtableServer

Throws:

java.rmi.RemoteException

contains

public boolean contains(java.lang.String key)
                 throws java.rmi.RemoteException

Specified by:

contains in interface HashtableServer

Throws:

java.rmi.RemoteException

getAllNodes

public java.util.Vector<Node> getAllNodes()
                                   throws java.rmi.RemoteException

Specified by:

getAllNodes in interface HashtableServer

Throws:

java.rmi.RemoteException

getAllKeys

public java.util.Vector<java.lang.String> getAllKeys()
                                              throws java.rmi.RemoteException

Specified by:

getAllKeys in interface HashtableServer

Throws:

java.rmi.RemoteException

getStats

public java.lang.String getStats()
                          throws java.rmi.RemoteException

Specified by:

getStats in interface HashtableServer

Throws:

java.rmi.RemoteException

clearStatContainers

public void clearStatContainers()
                         throws java.rmi.RemoteException

Specified by:

clearStatContainers in interface HashtableServer

Throws:

java.rmi.RemoteException

getNodeFromTable

public Node getNodeFromTable(java.lang.String nodeId)
                      throws java.rmi.RemoteException

Specified by:

getNodeFromTable in interface HashtableServer

Throws:

java.rmi.RemoteException

loadNodes

public void loadNodes(java.util.Vector<Node> nodes)
               throws java.rmi.RemoteException

Specified by:

loadNodes in interface HashtableServer

Throws:

java.rmi.RemoteException

getServerId

public int getServerId()
                throws java.rmi.RemoteException

Specified by:

getServerId in interface HashtableServer

Throws:

java.rmi.RemoteException

getNumServers

public int getNumServers()
                  throws java.rmi.RemoteException

Specified by:

getNumServers in interface HashtableServer

Throws:

java.rmi.RemoteException

setNumServers

public void setNumServers(int n)
                   throws java.rmi.RemoteException

Specified by:

setNumServers in interface HashtableServer

Throws:

java.rmi.RemoteException

relocate

public ResultObject relocate(int nodeId,
                             java.lang.String serverName)
                      throws java.rmi.RemoteException

Specified by:

relocate in interface HashtableServer

Throws:

java.rmi.RemoteException

locationChange

public void locationChange(int nodeId,
                           java.lang.String serverName)
                    throws java.rmi.RemoteException

Specified by:

locationChange in interface HashtableServer

Throws:

java.rmi.RemoteException

lock

public ResultObject lock(int nodeId)
                  throws java.rmi.RemoteException

Specified by:

lock in interface HashtableServer

Throws:

java.rmi.RemoteException

removeLocationTableEntry

public void removeLocationTableEntry(java.lang.String key)
                              throws java.rmi.RemoteException

Specified by:

removeLocationTableEntry in interface HashtableServer

Throws:

java.rmi.RemoteException

cacheInvalidate

public void cacheInvalidate(java.lang.String nodeID)
                     throws java.rmi.RemoteException

Specified by:

cacheInvalidate in interface HashtableServer

Throws:

java.rmi.RemoteException

getNodeForCaching

public Node getNodeForCaching(java.lang.String nodeID,
                              int cachingSite)
                       throws java.rmi.RemoteException

Specified by:

getNodeForCaching in interface HashtableServer

Throws:

java.rmi.RemoteException

cachePut

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

Specified by:

cachePut in interface HashtableServer

Throws:

java.rmi.RemoteException

cachePut

public java.util.Vector<ResultObject> cachePut(java.util.Map<java.lang.Integer,java.util.Vector<Node>> nodes,
                                               long storageSystemThreadId)
                                        throws java.rmi.RemoteException

Specified by:

cachePut in interface HashtableServer

Throws:

java.rmi.RemoteException

getLocalNodes

public java.util.Vector<ResultObject> getLocalNodes(java.util.Vector<java.lang.String> nodeIds,
                                                    long storageSystemThreadId)
                                             throws java.rmi.RemoteException

Specified by:

getLocalNodes in interface HashtableServer

Throws:

java.rmi.RemoteException

getNodesForCaching

public java.util.Vector<Node> getNodesForCaching(java.util.Vector<java.lang.String> nodeIds,
                                                 int callingSite)
                                          throws java.rmi.RemoteException

Specified by:

getNodesForCaching in interface HashtableServer

Throws:

java.rmi.RemoteException

writeThroughToCache

public void writeThroughToCache(java.lang.String paramString,
                                java.lang.Object value)
                         throws java.rmi.RemoteException

Specified by:

writeThroughToCache in interface HashtableServer

Throws:

java.rmi.RemoteException

writeThroughToCacheBulk

public void writeThroughToCacheBulk(java.util.concurrent.ConcurrentHashMap<java.lang.String,Node> map)
                             throws java.rmi.RemoteException

Specified by:

writeThroughToCacheBulk in interface HashtableServer

Throws:

java.rmi.RemoteException

getNodeFromCacheTable

public Node getNodeFromCacheTable(java.lang.String nodeId)
                           throws java.rmi.RemoteException

Specified by:

getNodeFromCacheTable in interface HashtableServer

Throws:

java.rmi.RemoteException

getCachedObjects

public java.util.Vector<Node> getCachedObjects(java.util.Vector<java.lang.String> nodeIds)
                                        throws java.rmi.RemoteException

Specified by:

getCachedObjects in interface HashtableServer

Throws:

java.rmi.RemoteException

cacheEvictMasterNotify

public void cacheEvictMasterNotify(java.lang.String cachingServerId,
                                   java.util.Hashtable<java.lang.String,java.lang.Long> evictedNodes)
                            throws java.rmi.RemoteException

Specified by:

cacheEvictMasterNotify in interface HashtableServer

Throws:

java.rmi.RemoteException

checkpoint

public void checkpoint()

Specified by:

checkpoint in interface HashtableServer

acquireLocks

public int acquireLocks(java.util.SortedSet<LockRequest> lockRequests)
                 throws java.rmi.RemoteException

Specified by:

acquireLocks in interface HashtableServer

Throws:

java.rmi.RemoteException

releaseLock

public void releaseLock(java.util.SortedSet<LockRequest> lockRequests)
                 throws java.rmi.RemoteException

Specified by:

releaseLock in interface HashtableServer

Throws:

java.rmi.RemoteException

commitChanges

public void commitChanges(java.util.Set<Node> write,
                          java.util.Set<NodeData> writeNd,
                          java.util.Map<java.lang.String,java.lang.Long> read)
                   throws java.rmi.RemoteException

Specified by:

commitChanges in interface HashtableServer

Throws:

java.rmi.RemoteException