|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectexecuting.MapperSideExecuter
executing.MapperSideExecuter_Xgrid
public class MapperSideExecuter_Xgrid
Xgrid implementation of an execution layer. This layer communicates with the CompletionAnnouncer_Xgrid object in the servers.
MapperSideExecuter
,
Serialized FormField Summary |
---|
Fields inherited from class executing.MapperSideExecuter |
---|
NOT_IMPLEMENTED |
Constructor Summary | |
---|---|
MapperSideExecuter_Xgrid()
|
Method Summary | |
---|---|
long |
deleteJob(long id,
java.lang.String hostname,
java.lang.String password)
This method deletes the job with id "id" on hostname "hostname". |
double |
getActiveCPU(long id,
java.lang.String hostname,
java.lang.String password)
|
int |
getCompletionAnnouncer_XgridPort()
|
java.lang.String |
getDateStarted(long id,
java.lang.String hostname,
java.lang.String password)
|
java.lang.String |
getDateStopped(long id,
java.lang.String hostname,
java.lang.String password)
|
java.lang.String |
getJobStatus(long id,
java.lang.String hostname,
java.lang.String password)
|
java.lang.String |
getKeyBeforeEqual(java.lang.String input)
|
double |
getPercentageDone(long id,
java.lang.String hostname,
java.lang.String password)
This methods returns percentage done when given the id of job. |
java.lang.String |
getValueAfterEqual(java.lang.String input)
|
void |
notifyCompletionAnnouncer(java.lang.String serverHostName,
int serverID,
long xgridID,
long jobID)
This method notifies the Completion Announcer that a job has been submitted to the server The message format is: jobID#secondaryJobID#ServerNumber#TimeExpectedForJobToTake |
void |
setCompletionAnnouncer_XgridPort(int completionAnnouncer_XgridPort)
|
void |
startExecuter()
Nothing to start/ |
long |
stopJob(long id,
java.lang.String hostname,
java.lang.String password)
This method stops the job with id "id" on hostname "hostname"\ |
long |
submitLoopJob(java.lang.String hostName,
java.lang.String password,
int serverID,
long jobID,
long iter,
double ratio)
This method sends a job to the specific Server using the Xgrid technology. |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public MapperSideExecuter_Xgrid()
Method Detail |
---|
public int getCompletionAnnouncer_XgridPort()
public void setCompletionAnnouncer_XgridPort(int completionAnnouncer_XgridPort)
public void startExecuter()
startExecuter
in class MapperSideExecuter
public long submitLoopJob(java.lang.String hostName, java.lang.String password, int serverID, long jobID, long iter, double ratio)
submitLoopJob
in class MapperSideExecuter
hostName
- is the server that a job is sent topassword
- is the xgrid passwordserverID
- is the id assigned to the server. (The coloumn in the Mue
matrix)jobID
- is the jobID assigned to that Job by the Mapperiter
- is the iterations of the loop job. (Please see Appendix D)ratio
- is the ratio that this loop job is adjusted by.
public void notifyCompletionAnnouncer(java.lang.String serverHostName, int serverID, long xgridID, long jobID) throws java.io.IOException
jobID
- the id of the job object that is sent to the server.serverID
- is the ID of the server that will execute the job
java.io.IOException
CompletionAnnouncer_Xgrid
public double getPercentageDone(long id, java.lang.String hostname, java.lang.String password)
getPercentageDone
in class MapperSideExecuter
id
- is job idhostname
- is the hostname of the server executing that job
MapperSideExecuter.getPercentageDone(long, String, String)
public java.lang.String getDateStarted(long id, java.lang.String hostname, java.lang.String password)
getDateStarted
in class MapperSideExecuter
id
- is job idhostname
- is the hostname of the server executing that job.
MapperSideExecuter.getDateStarted(long, String, String)
public java.lang.String getDateStopped(long id, java.lang.String hostname, java.lang.String password)
getDateStopped
in class MapperSideExecuter
id
- is job idhostname
- is the hostname of the server executing that job
MapperSideExecuter.getDateStopped(long, String, String)
public java.lang.String getJobStatus(long id, java.lang.String hostname, java.lang.String password)
getJobStatus
in class MapperSideExecuter
id
- is job idhostname
- is the hostname of the server executing that job
MapperSideExecuter.getJobStatus(long, String, String)
public double getActiveCPU(long id, java.lang.String hostname, java.lang.String password)
public long stopJob(long id, java.lang.String hostname, java.lang.String password)
MapperSideExecuter
stopJob
in class MapperSideExecuter
id
- is job idhostname
- is the hostname of the server executing that job
MapperSideExecuter.stopJob(long, String, String)
public long deleteJob(long id, java.lang.String hostname, java.lang.String password)
MapperSideExecuter
deleteJob
in class MapperSideExecuter
id
- is job idhostname
- is the hostname of the server executing that job
MapperSideExecuter.deleteJob(long, String, String)
public java.lang.String getKeyBeforeEqual(java.lang.String input)
input
- String
public java.lang.String getValueAfterEqual(java.lang.String input)
input
- String
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |