beehive.server

Interface HashtableServer

All Superinterfaces:

Remote

All Known Implementing Classes:

HashtableServerImpl, HashTableThriftHandler

public interface HashtableServer
extends Remote

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 n)
Vector<Node>	getNodesForCaching(Vector<String> nodeIds, int callingSite)
int	getNumServers()
Vector<ResultObject>	getObjects(Vector<String> keyList)
Vector<ResultObject>	getObjectsProperties(Vector<NodeData> keyList)
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 n)
Vector<ResultObject>	updateNodePropertiesParallel(Vector<NodeData> objList)
void	writeThroughToCache(String paramString, Object value)
void	writeThroughToCacheBulk(ConcurrentHashMap<String,Node> map)

Method Detail

ping

Date ping()
   throws RemoteException

Throws:

RemoteException

put

ResultObject put(String key,
                 Object value)
          throws RemoteException

Throws:

RemoteException

put

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

Throws:

RemoteException

get

ResultObject get(String key,
                 long storageSystemThreadId)
          throws RemoteException

Throws:

RemoteException

getObjects

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

Throws:

RemoteException

putObjects

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

Throws:

RemoteException

getNodeProperties

ResultObject getNodeProperties(NodeData n)
                        throws RemoteException

Throws:

RemoteException

getObjectsProperties

Vector<ResultObject> getObjectsProperties(Vector<NodeData> keyList)
                                   throws RemoteException

Throws:

RemoteException

updateNodeProperties

ResultObject updateNodeProperties(NodeData n)
                           throws RemoteException

Throws:

RemoteException

updateNodePropertiesParallel

Vector<ResultObject> updateNodePropertiesParallel(Vector<NodeData> objList)
                                           throws RemoteException

Throws:

RemoteException

exec

ResultObject exec(NodeData nd)
           throws RemoteException

Throws:

RemoteException

execBulk

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

Throws:

RemoteException

putObjects

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

Throws:

RemoteException

contains

boolean contains(String key)
          throws RemoteException

Throws:

RemoteException

getAllNodes

Vector<Node> getAllNodes()
                  throws RemoteException

Throws:

RemoteException

getAllKeys

Vector<String> getAllKeys()
                   throws RemoteException

Throws:

RemoteException

getStats

String getStats()
         throws RemoteException

Throws:

RemoteException

clearStatContainers

void clearStatContainers()
                  throws RemoteException

Throws:

RemoteException

getNodeFromTable

Node getNodeFromTable(String nodeId)
               throws RemoteException

Throws:

RemoteException

loadNodes

void loadNodes(Vector<Node> nodes)
        throws RemoteException

Throws:

RemoteException

getServerId

int getServerId()
         throws RemoteException

Throws:

RemoteException

getNumServers

int getNumServers()
           throws RemoteException

Throws:

RemoteException

setNumServers

void setNumServers(int n)
            throws RemoteException

Throws:

RemoteException

relocate

ResultObject relocate(int nodeId,
                      String serverName)
               throws RemoteException

Throws:

RemoteException

locationChange

void locationChange(int nodeId,
                    String serverName)
             throws RemoteException

Throws:

RemoteException

lock

ResultObject lock(int nodeId)
           throws RemoteException

Throws:

RemoteException

removeLocationTableEntry

void removeLocationTableEntry(String key)
                       throws RemoteException

Throws:

RemoteException

getClusterMeasures

ClusterMeasures getClusterMeasures()
                            throws RemoteException

Throws:

RemoteException

cacheInvalidate

void cacheInvalidate(String nodeID)
              throws RemoteException

Throws:

RemoteException

getNodeForCaching

Node getNodeForCaching(String nodeID,
                       int cachingSite)
                throws RemoteException

Throws:

RemoteException

cachePut

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

Throws:

RemoteException

cachePut

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

Throws:

RemoteException

getLocalNodes

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

Throws:

RemoteException

getNodesForCaching

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

Throws:

RemoteException

writeThroughToCache

void writeThroughToCache(String paramString,
                         Object value)
                  throws RemoteException

Throws:

RemoteException

writeThroughToCacheBulk

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

Throws:

RemoteException

getNodeFromCacheTable

Node getNodeFromCacheTable(String nodeId)
                    throws RemoteException

Throws:

RemoteException

getCachedObjects

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

Throws:

RemoteException

cacheEvictMasterNotify

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

Throws:

RemoteException