-
- All Known Implementing Classes:
com.pervasive.datarush.cal.dr.AbstractDRJobExecutor
,YarnClusterJobExecutor
public interface JobExecutorService
Client-side API for submitting units of work to the job master.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description StorageManager
getExternalStorageManager()
Returns a storage manager that can be used for transfering files to/from the job.JobInformation
getJobInformation()
Returns the job information associated with this servicevoid
startShutdown(JobStatus status)
Asynchronously begins shutdown.<T> MonitoredFuture<T>
submit(JobCallable<T> callable)
Does the following: Starts the job master if not already started. Invokes the init method on the server side. Starts execution on the server side Returns a handle for monitoring execution
-
-
-
Method Detail
-
getExternalStorageManager
StorageManager getExternalStorageManager()
Returns a storage manager that can be used for transfering files to/from the job. This is a non-parallel storage manager.- Returns:
- the storage manager
- Throws:
UnsupportedOperationException
- if the job master is non-remote
-
getJobInformation
JobInformation getJobInformation()
Returns the job information associated with this service- Returns:
- the job info
-
submit
<T> MonitoredFuture<T> submit(JobCallable<T> callable)
Does the following:- Starts the job master if not already started.
- Invokes the init method on the server side.
- Starts execution on the server side
- Returns a handle for monitoring execution
-
startShutdown
void startShutdown(JobStatus status)
Asynchronously begins shutdown. Following a call to this methods, all other methods on this class will throwIllegalStateException
.- Parameters:
status
- final status of the job
-
-