|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface AsyncExecutor
An asynchronous executor engine, capable of running, cancelling, obtaining results calculated by a native executable wrapper in Executable interface. Implementation agnostic. Executables can be run either locally to the JVM or on the cluster.
Method Summary | |
---|---|
boolean |
cancelJob(java.lang.String jobId)
Stop running job. |
boolean |
cleanup(java.lang.String jobId)
Remove all files and a job directory for a jobid. |
JobStatus |
getJobStatus(java.lang.String jobId)
Query the status of the job |
ConfiguredExecutable<?> |
getResults(java.lang.String jobId)
Retrieve the results of the job. |
java.lang.String |
getWorkDirectory(java.lang.String jobId)
|
java.lang.String |
submitJob(ConfiguredExecutable<?> executable)
Submits job for the execution Immediate execution is not guaranteed, this method puts the job in the queue. |
Method Detail |
---|
java.lang.String submitJob(ConfiguredExecutable<?> executable) throws JobSubmissionException
JobSubmissionException
- if submission fails. This usually happens due to the problem on a server side.ConfiguredExecutable<?> getResults(java.lang.String jobId) throws ResultNotAvailableException
jobId
- job identifier obtained at the job submission
ResultNotAvailableException
- if the result is not available for whatever reason.
Could be due to execution failure, or due to the results being removed from the server at
the time of request.java.lang.String getWorkDirectory(java.lang.String jobId)
jobId
- unique job identifier
boolean cleanup(java.lang.String jobId)
jobId
-
boolean cancelJob(java.lang.String jobId)
JobStatus getJobStatus(java.lang.String jobId)
String
- jobId - unique job identifier
JobStatus
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |