beehive.worker

Class Worker

java.lang.Object

java.rmi.server.RemoteObject

java.rmi.server.RemoteServer

java.rmi.server.UnicastRemoteObject

beehive.worker.Worker

All Implemented Interfaces:

Serializable, Runnable, Remote

public abstract class Worker
extends UnicastRemoteObject
implements Runnable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
Config	configParams
StorageSystem	dataStorage
long	endTime
Logger	log
boolean	master
RWSetInfo	rwsetinfo
long	startTime
StatContainer	statCommitTaskTime
StatContainer	statComputeTime
StatContainer	statDoTaskTime
StatContainer	statGetTaskTime
StatContainer	statValidateTime
static long	STS_DELAY
HashSet<Task>	tasksCreated
Hashtable<String,Node>	updatedNodes
Hashtable<String,NodeData>	updatedNodesData
int	workerId
WorkerStatus	workerStatus
LocalWorkpoolImpl	workpool

Fields inherited from class java.rmi.server.RemoteObject

ref

Constructor Summary

Constructors

Constructor and Description
Worker(String configFile, LocalWorkpoolImpl wpool, int workerNum, StorageSystem dataStore, boolean master)

Method Summary

Modifier and Type	Method and Description
TransactionInfo	beginTransaction()
void	cleanUp()
void	commitTask(Task t) Commits the completed, valid task and removes it from the workpool.
abstract void	doTask(Task tsk) Each concrete Worker class is responsible for defining its own logic on how to execute the given task
boolean	earlyValidation(Task t, Vector<Node> readNodes, Vector<NodeData> readNodesData) A means to validate tasks before execution of the task itself
Vector<Node>	getLocalNeighbors(Node u)
Vector<String>	getNeighborIds(Node u)
Vector<Node>	getNeighbors(Node u)
Vector<Node>	getRemoteNeighbors(Vector<String> nbrKeys)
String	getStats()
void	recordStat(StatContainer stat, float value)
Vector<Node>	refetchNodes(HashSet<String> refetchSet, Vector<Node> neighborNodes) TODO : Move this to the respective worker class like PreFlowPushWorker
void	run() Continuously queries the workpool for tasks to execute until the system has reached termination.

Methods inherited from class java.rmi.server.UnicastRemoteObject

clone, exportObject, exportObject, exportObject, unexportObject

Methods inherited from class java.rmi.server.RemoteServer

getClientHost, getLog, setLog

Methods inherited from class java.rmi.server.RemoteObject

equals, getRef, hashCode, toString, toStub

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

workpool

public LocalWorkpoolImpl workpool

dataStorage

public StorageSystem dataStorage

rwsetinfo

public RWSetInfo rwsetinfo

updatedNodes

public Hashtable<String,Node> updatedNodes

updatedNodesData

public Hashtable<String,NodeData> updatedNodesData

tasksCreated

public HashSet<Task> tasksCreated

configParams

public Config configParams

workerId

public int workerId

master

public boolean master

startTime

public long startTime

endTime

public long endTime

workerStatus

public WorkerStatus workerStatus

log

public Logger log

STS_DELAY

public static long STS_DELAY

statGetTaskTime

public StatContainer statGetTaskTime

statDoTaskTime

public StatContainer statDoTaskTime

statComputeTime

public StatContainer statComputeTime

statValidateTime

public StatContainer statValidateTime

statCommitTaskTime

public StatContainer statCommitTaskTime

Constructor Detail

Worker

public Worker(String configFile,
              LocalWorkpoolImpl wpool,
              int workerNum,
              StorageSystem dataStore,
              boolean master)
       throws RemoteException

Parameters:

configFile - The configuration for the workers

wpool - The workpool this worker will its tasks from

workerNum - The total number of workers at the server

dataStore - The StorageSystem this worker will put and get nodes from

master - True if this worker is the master, false otherwise.

Throws:

RemoteException - Thrown if this worker could not be constructed

Method Detail

cleanUp

public void cleanUp()

getNeighbors

public Vector<Node> getNeighbors(Node u)
                          throws Exception

Returns:

All of the node's neighbors

Throws:

Exception - Thrown if the neighbors could not be fetched.

getLocalNeighbors

public Vector<Node> getLocalNeighbors(Node u)
                               throws Exception

Returns:

All of the node's neighbors that are on the worker's server

Throws:

Exception - Thrown if the neighbors could not be fetched

getRemoteNeighbors

public Vector<Node> getRemoteNeighbors(Vector<String> nbrKeys)
                                throws Exception

Parameters:

nbrKeys - The nodeIds of a node's neighbors that are on a different server than the worker's server

Returns:

The nodes whose ids are passed in.

Throws:

Exception - Thrown if the neighbors could not be fetched.

getNeighborIds

public Vector<String> getNeighborIds(Node u)

Returns:

The nodeIds of a node's neighbors

beginTransaction

public TransactionInfo beginTransaction()
                                 throws RemoteException

Returns:

A TransactionInfo representing the current transaction.

Throws:

RemoteException - Thrown if the transaction could not be started.

doTask

public abstract void doTask(Task tsk)
                     throws Exception

Each concrete Worker class is responsible for defining its own logic on how to execute the given task

Parameters:

tsk - The task that is to be executed.

Throws:

Exception

commitTask

public void commitTask(Task t)

Commits the completed, valid task and removes it from the workpool. Any nodes or respective nodedata that was updated as a result of the task will be reflected in the storage system after this call.

Parameters:

t - The task that is to be committed.

earlyValidation

public boolean earlyValidation(Task t,
                               Vector<Node> readNodes,
                               Vector<NodeData> readNodesData)

A means to validate tasks before execution of the task itself

Parameters:

t - The task that is to be validated

readNodes - The neighbors of the node that the task is associated with

readNodesData - The nodedata of the neighbors of the node that the task is associated with

Returns:

True if the task is valid, false otherwise.

refetchNodes

public Vector<Node> refetchNodes(HashSet<String> refetchSet,
                                 Vector<Node> neighborNodes)
                          throws Exception

TODO : Move this to the respective worker class like PreFlowPushWorker

Not used

Throws:

Exception

run

public void run()

Continuously queries the workpool for tasks to execute until the system has reached termination.

Specified by:

run in interface Runnable

recordStat

public void recordStat(StatContainer stat,
                       float value)

getStats

public String getStats()