com.pervasive.datarush.cal.dr

Class PseudoDistributedJobExecutor

java.lang.Object

com.pervasive.datarush.cal.dr.AbstractDRJobExecutor

com.pervasive.datarush.cal.dr.PseudoDistributedJobExecutor

All Implemented Interfaces:

JobExecutorService

public class PseudoDistributedJobExecutor
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
PseudoDistributedJobExecutor(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)

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

ensureJobMaster, getJobInformation, startShutdown, submit

Methods inherited from class java.lang.Object

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

Constructor Detail

PseudoDistributedJobExecutor

public PseudoDistributedJobExecutor(FileClient fileClient,
                            JobSpecifier jobSpec)

Method Detail

start

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

Specified by:

start in class AbstractDRJobExecutor

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