com.pervasive.datarush.cal.dr

Class DRClusterJobExecutor

java.lang.Object

com.pervasive.datarush.cal.dr.AbstractDRJobExecutor

com.pervasive.datarush.cal.dr.DRClusterJobExecutor

All Implemented Interfaces:

JobExecutorService

public class DRClusterJobExecutor
extends AbstractDRJobExecutor

Nested Class Summary

Nested classes/interfaces inherited from class com.pervasive.datarush.cal.dr.AbstractDRJobExecutor

AbstractDRJobExecutor.JobMasterHelper

Field Summary

Fields inherited from class com.pervasive.datarush.cal.dr.AbstractDRJobExecutor

fileClient, jobSpec, MUTEX

Constructor Summary

Constructors

Constructor and Description
DRClusterJobExecutor(FileClient fileClient, JobSpecifier jobSpec)

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.
protected AbstractDRJobExecutor.JobMasterHelper	start(FileClient fileClient, JobSpecifier jobSpec)
void	startShutdown(JobStatus status) Asynchronously begins shutdown.

Methods inherited from class com.pervasive.datarush.cal.dr.AbstractDRJobExecutor

ensureJobMaster, getJobInformation, submit

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DRClusterJobExecutor

public DRClusterJobExecutor(FileClient fileClient,
                    JobSpecifier jobSpec)

Method Detail

start

protected AbstractDRJobExecutor.JobMasterHelper start(FileClient fileClient,
                                          JobSpecifier jobSpec)

Specified by:

start in class AbstractDRJobExecutor

startShutdown

public void startShutdown(JobStatus status)

Description copied from interface: JobExecutorService

Asynchronously begins shutdown. Following a call to this methods, all other methods on this class will throw IllegalStateException.

Specified by:

startShutdown in interface JobExecutorService

Overrides:

startShutdown in class AbstractDRJobExecutor

Parameters:

status - final status of the job

getExternalStorageManager

public StorageManager getExternalStorageManager()

Description copied from interface: JobExecutorService

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