public class DRClusterJobExecutor extends AbstractDRJobExecutor
AbstractDRJobExecutor.JobMasterHelper
fileClient, jobSpec, MUTEX
Constructor and Description |
---|
DRClusterJobExecutor(FileClient fileClient,
JobSpecifier jobSpec) |
Modifier and Type | Method and Description |
---|---|
StorageManager |
getExternalStorageManager()
Returns a storage manager that can be used for transfering files to/from the job.
|
protected AbstractDRJobExecutor.JobMasterHelper |
start(FileClient fileClient,
JobSpecifier jobSpec) |
void |
startShutdown(JobStatus status)
Asynchronously begins shutdown.
|
ensureJobMaster, getJobInformation, submit
public DRClusterJobExecutor(FileClient fileClient, JobSpecifier jobSpec)
protected AbstractDRJobExecutor.JobMasterHelper start(FileClient fileClient, JobSpecifier jobSpec)
start
in class AbstractDRJobExecutor
public void startShutdown(JobStatus status)
JobExecutorService
IllegalStateException
.startShutdown
in interface JobExecutorService
startShutdown
in class AbstractDRJobExecutor
status
- final status of the jobpublic StorageManager getExternalStorageManager()
JobExecutorService
Copyright © 2016 Actian Corporation. All Rights Reserved.