public final class AsyncLocalRunner extends java.lang.Object implements AsyncExecutor
Modifier and Type | Field and Description |
---|---|
private static org.apache.log4j.Logger |
log |
Constructor and Description |
---|
AsyncLocalRunner() |
Modifier and Type | Method and Description |
---|---|
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 taskId)
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.
|
public java.lang.String getWorkDirectory(java.lang.String jobId)
getWorkDirectory
in interface AsyncExecutor
jobId
- unique job identifierpublic boolean cancelJob(java.lang.String jobId)
AsyncExecutor
cancelJob
in interface AsyncExecutor
public JobStatus getJobStatus(java.lang.String jobId)
AsyncExecutor
getJobStatus
in interface AsyncExecutor
JobStatus
public java.lang.String submitJob(ConfiguredExecutable<?> executable) throws JobSubmissionException
AsyncExecutor
submitJob
in interface AsyncExecutor
JobSubmissionException
- if submission fails. This usually happens due to the problem on a server side.public boolean cleanup(java.lang.String jobId)
AsyncExecutor
cleanup
in interface AsyncExecutor
jobId
- public ConfiguredExecutable<?> getResults(java.lang.String taskId) throws ResultNotAvailableException
AsyncExecutor
getResults
in interface AsyncExecutor
taskId
- job identifier obtained at the job submissionResultNotAvailableException
- 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.