public abstract class AbstractDRJobExecutor extends Object implements JobExecutorService
Modifier and Type | Class and Description |
---|---|
protected static class |
AbstractDRJobExecutor.JobMasterHelper |
Modifier and Type | Field and Description |
---|---|
protected FileClient |
fileClient |
protected JobSpecifier |
jobSpec |
protected Object |
MUTEX |
Constructor and Description |
---|
AbstractDRJobExecutor(FileClient fileClient,
JobSpecifier jobSpec) |
Modifier and Type | Method and Description |
---|---|
protected AbstractDRJobExecutor.JobMasterHelper |
ensureJobMaster() |
JobInformation |
getJobInformation()
Returns the job information associated with this service
|
protected abstract AbstractDRJobExecutor.JobMasterHelper |
start(FileClient fileClient,
JobSpecifier jobSpec) |
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
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getExternalStorageManager
protected final FileClient fileClient
protected final JobSpecifier jobSpec
protected final Object MUTEX
public AbstractDRJobExecutor(FileClient fileClient, JobSpecifier jobSpec)
public void startShutdown(JobStatus status)
JobExecutorService
IllegalStateException
.startShutdown
in interface JobExecutorService
status
- final status of the jobprotected final AbstractDRJobExecutor.JobMasterHelper ensureJobMaster()
protected abstract AbstractDRJobExecutor.JobMasterHelper start(FileClient fileClient, JobSpecifier jobSpec)
public final JobInformation getJobInformation()
JobExecutorService
getJobInformation
in interface JobExecutorService
public final <T> MonitoredFuture<T> submit(JobCallable<T> callable)
JobExecutorService
submit
in interface JobExecutorService
Copyright © 2016 Actian Corporation. All Rights Reserved.