beehive.util

Class StorageSystem

java.lang.Object

beehive.util.StorageSystem

public class StorageSystem
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.String>	locationTable
HashtableServer	myHashTableServer
int	myId
java.lang.String	myURL
boolean	recordStats
java.util.Vector<java.lang.String>	relocating
java.util.concurrent.ConcurrentHashMap<java.lang.Integer,java.lang.String>	serverLocationMapping
java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.Integer>	serverMapping
java.util.concurrent.ConcurrentHashMap<java.lang.Integer,HashtableServer>	servers
boolean	startCompute
boolean	writeThroughCache

Constructor Summary

Constructors

Constructor and Description
StorageSystem(java.util.Vector<java.lang.String> hostList) Constructor without reference to local hashtable server object, backwards compatible
StorageSystem(java.util.Vector<java.lang.String> hostList, HashtableServer paramHashtableServer) Constructor with reference to local hashtable server object
StorageSystem(java.util.Vector<java.lang.String> hostList, HashtableServer paramHashtableServer, boolean writeThrough) Constructor for caching case

Method Summary

Modifier and Type	Method and Description
void	clearStatContainers()
void	enableStats() Turn on stat recording
NodeData	exec(NodeData n)
java.util.Vector<NodeData>	execParallel(java.util.Vector<NodeData> paramVector)
HashtableServer	findServer(int nodeId)
java.util.Vector<java.lang.String>	getAllKeys(java.lang.String url)
java.util.Vector<Node>	getAllNodes()
ClusterMeasures	getClusterMeasures(java.lang.String url)
java.util.Vector<Node>	getLocalNodes(java.util.Vector<java.lang.String> paramVector)
java.util.Vector<Node>	getLocalNodes(java.util.Vector<java.lang.String> paramVector, boolean withCaching)
java.lang.String	getLocation(java.lang.String nodeId)
java.lang.String	getLocationURL(java.lang.String nodeId)
Node	getNode(java.lang.String paramString) get node from local or remote and return to application
Node	getNode(java.lang.String paramString, boolean withCaching) similar to getNode, with an additional application level directive to control caching
NodeData	getNodeProperties(NodeData n) Reflection API of the storage system to get properties for a given nodeId
java.util.Vector<NodeData>	getNodePropertiesParallel(java.util.Vector<NodeData> paramVector) Bulk reflection API of the storage system to get the properties for the given nodeIds
java.util.Vector<Node>	getNodesParallel(java.util.Vector<java.lang.String> paramVector) bulk call for getNode
java.util.Vector<Node>	getNodesParallel(java.util.Vector<java.lang.String> paramVector, boolean withCaching) bulk call for getNode, with an additional application level directive to control caching
int	getNumberOfServers() get the number of servers in the cluster
int	getServerID(int nodeID)
java.lang.String	getStats()
java.lang.String	getStats(boolean includeHashtable) External API to get stats
void	putNode(java.lang.String paramString, Node paramNode) put node, called from the application to put a node in the local or remote server
void	putNodesParallel(java.util.Vector<Node> nodeList) Bulk call to putNode, called by the application Calls are bucketised to the respective servers
boolean	relocate(java.lang.String nodeId)
boolean	relocate(java.lang.String nodeId, boolean lock)
void	updateNodeProperties(NodeData n) update Reflection API for the storage system
void	updateNodePropertiesParallel(java.util.Vector<NodeData> nodeList) updateNodeProperties for the bulk case

Methods inherited from class java.lang.Object

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

Field Detail

servers

public java.util.concurrent.ConcurrentHashMap<java.lang.Integer,HashtableServer> servers

serverMapping

public java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.Integer> serverMapping

locationTable

public java.util.concurrent.ConcurrentHashMap<java.lang.String,java.lang.String> locationTable

serverLocationMapping

public java.util.concurrent.ConcurrentHashMap<java.lang.Integer,java.lang.String> serverLocationMapping

relocating

public java.util.Vector<java.lang.String> relocating

myURL

public java.lang.String myURL

myId

public int myId

myHashTableServer

public HashtableServer myHashTableServer

recordStats

public boolean recordStats

writeThroughCache

public boolean writeThroughCache

startCompute

public boolean startCompute

Constructor Detail

StorageSystem

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

Constructor without reference to local hashtable server object, backwards compatible

Parameters:

hostList -

Throws:

java.rmi.RemoteException

StorageSystem

public StorageSystem(java.util.Vector<java.lang.String> hostList,
                     HashtableServer paramHashtableServer)
              throws java.rmi.RemoteException

Constructor with reference to local hashtable server object

Parameters:

hostList -

paramHashtableServer -

Throws:

java.rmi.RemoteException

StorageSystem

public StorageSystem(java.util.Vector<java.lang.String> hostList,
                     HashtableServer paramHashtableServer,
                     boolean writeThrough)
              throws java.rmi.RemoteException

Constructor for caching case

Parameters:

hostList -

paramHashtableServer -

writeThrough -

Throws:

java.rmi.RemoteException

Method Detail

getNumberOfServers

public int getNumberOfServers()

get the number of servers in the cluster

Returns:

enableStats

public void enableStats()

Turn on stat recording

getNode

public Node getNode(java.lang.String paramString)
             throws java.rmi.RemoteException

get node from local or remote and return to application

Parameters:

paramString -

Returns:

Throws:

java.rmi.RemoteException

getNode

public Node getNode(java.lang.String paramString,
                    boolean withCaching)
             throws java.rmi.RemoteException

similar to getNode, with an additional application level directive to control caching

Parameters:

paramString -

withCaching -

Returns:

Throws:

java.rmi.RemoteException

getNodesParallel

public java.util.Vector<Node> getNodesParallel(java.util.Vector<java.lang.String> paramVector)
                                        throws java.rmi.RemoteException

bulk call for getNode

Parameters:

paramVector -

Returns:

Throws:

java.rmi.RemoteException

getNodesParallel

public java.util.Vector<Node> getNodesParallel(java.util.Vector<java.lang.String> paramVector,
                                               boolean withCaching)
                                        throws java.rmi.RemoteException

bulk call for getNode, with an additional application level directive to control caching

Parameters:

paramVector -

withCaching -

Returns:

Throws:

java.rmi.RemoteException

getNodeProperties

public NodeData getNodeProperties(NodeData n)
                           throws java.rmi.RemoteException

Reflection API of the storage system to get properties for a given nodeId

Parameters:

nodeId -

properties -

Returns:

NodeData corresponding to the properties requested for the given node

Throws:

java.rmi.RemoteException

getNodePropertiesParallel

public java.util.Vector<NodeData> getNodePropertiesParallel(java.util.Vector<NodeData> paramVector)
                                                     throws java.rmi.RemoteException

Bulk reflection API of the storage system to get the properties for the given nodeIds

Parameters:

nodeIds -

properties -

Returns:

Vector of NodeData corresponding to the properties requested for the given nodes

Throws:

java.rmi.RemoteException

exec

public NodeData exec(NodeData n)
              throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

execParallel

public java.util.Vector<NodeData> execParallel(java.util.Vector<NodeData> paramVector)
                                        throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

putNode

public void putNode(java.lang.String paramString,
                    Node paramNode)
             throws java.rmi.RemoteException

put node, called from the application to put a node in the local or remote server

Parameters:

paramString -

paramNode -

Throws:

java.rmi.RemoteException

putNodesParallel

public void putNodesParallel(java.util.Vector<Node> nodeList)
                      throws java.rmi.RemoteException

Bulk call to putNode, called by the application Calls are bucketised to the respective servers

Parameters:

nodeList -

Throws:

java.rmi.RemoteException

updateNodeProperties

public void updateNodeProperties(NodeData n)
                          throws java.rmi.RemoteException

update Reflection API for the storage system

Parameters:

n - - this is a Node data which tells what the updated properties and TS are

Throws:

java.rmi.RemoteException

updateNodePropertiesParallel

public void updateNodePropertiesParallel(java.util.Vector<NodeData> nodeList)
                                  throws java.rmi.RemoteException

updateNodeProperties for the bulk case

Parameters:

nodeList -

Throws:

java.rmi.RemoteException

getAllKeys

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

Throws:

java.rmi.RemoteException

getClusterMeasures

public ClusterMeasures getClusterMeasures(java.lang.String url)
                                   throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

relocate

public boolean relocate(java.lang.String nodeId)
                 throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

relocate

public boolean relocate(java.lang.String nodeId,
                        boolean lock)
                 throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getLocationURL

public java.lang.String getLocationURL(java.lang.String nodeId)

getLocation

public java.lang.String getLocation(java.lang.String nodeId)

getStats

public java.lang.String getStats()

getStats

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

External API to get stats

Parameters:

includeHashtable -

Returns:

Throws:

java.rmi.RemoteException

findServer

public HashtableServer findServer(int nodeId)

getServerID

public int getServerID(int nodeID)

getLocalNodes

public java.util.Vector<Node> getLocalNodes(java.util.Vector<java.lang.String> paramVector)

getLocalNodes

public java.util.Vector<Node> getLocalNodes(java.util.Vector<java.lang.String> paramVector,
                                            boolean withCaching)
                                     throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getAllNodes

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

Throws:

java.rmi.RemoteException

clearStatContainers

public void clearStatContainers()
                         throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException