com.pervasive.datarush.cal

Interface JobExecutorService

All Known Implementing Classes:

AbstractDRJobExecutor, DRClusterJobExecutor, PseudoDistributedJobExecutor, YarnClusterJobExecutor

public interface JobExecutorService

Client-side API for submitting units of work to the job master.

Method Summary

Methods

Modifier and Type	Method and 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 service
void	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:

1. Starts the job master if not already started.
2. Invokes the init method on the server side.
3. Starts execution on the server side
4. 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 throw IllegalStateException.

Parameters:

status - final status of the job