Modifier and Type | Method and Description |
---|---|
AggregatedJob |
JobAggregator.constructAbstractAggregatedJob(List jobs,
String name,
String id)
Constructs an abstract aggregated job that has a handle to the appropriate
JobAggregator that will be used to aggregate the jobs.
|
Modifier and Type | Method and Description |
---|---|
abstract void |
Abstract.determineInputOutputFiles(AggregatedJob job,
List<Job> orderedJobs)
Determine the input and output files of the job on the basis of the
order of the constituent jobs in the AggregatedJob.
|
void |
Vertical.determineInputOutputFiles(AggregatedJob job,
List<Job> orderedJobs)
Determine the input and output files of the job on the basis of the
order of the constituent jobs in the AggregatedJob.
|
protected void |
Horizontal.logRefinerAction(AggregatedJob clusteredJob,
JobAggregator aggregator)
Records the refiner action into the Provenace Store as a XML fragment.
|
void |
JobAggregator.makeAbstractAggregatedJobConcrete(AggregatedJob job)
Enables the abstract clustered job for execution and converts it to it's
executable form
|
Modifier and Type | Method and Description |
---|---|
AggregatedJob |
Abstract.constructAbstractAggregatedJob(List jobs,
String name,
String id)
Constructs a new aggregated job that contains all the jobs passed to it.
|
AggregatedJob |
Abstract.constructAbstractAggregatedJob(List jobs,
String name,
String id,
String mergeLFN)
Constructs an abstract aggregated job that has a handle to the appropriate
JobAggregator that will be used to aggregate the jobs.
|
Modifier and Type | Method and Description |
---|---|
String |
MPIExec.aggregatedJobArguments(AggregatedJob job)
Returns the arguments with which the
AggregatedJob
needs to be invoked with. |
abstract String |
Abstract.aggregatedJobArguments(AggregatedJob job)
Returns the arguments with which the
AggregatedJob
needs to be invoked with. |
String |
SeqExec.aggregatedJobArguments(AggregatedJob job)
Returns the arguments with which the
AggregatedJob
needs to be invoked with. |
protected String |
SeqExec.logFile(AggregatedJob job)
Returns the name of the log file to used on the remote site, for the
seqexec job.
|
void |
MPIExec.makeAbstractAggregatedJobConcrete(AggregatedJob job)
Enables the abstract clustered job for execution and converts it to it's
executable form.
|
void |
Abstract.makeAbstractAggregatedJobConcrete(AggregatedJob job)
Enables the abstract clustered job for execution and converts it to it's
executable form
|
void |
SeqExec.makeAbstractAggregatedJobConcrete(AggregatedJob job)
Enables the abstract clustered job for execution and converts it to it's
executable form.
|
protected File |
MPIExec.writeOutInputFileForJobAggregator(AggregatedJob job)
Writes out the input file for the aggregated job
|
protected File |
Abstract.writeOutInputFileForJobAggregator(AggregatedJob job)
Writes out the input file for the aggregated job
|
Modifier and Type | Method and Description |
---|---|
boolean |
GridStart.enable(AggregatedJob job,
boolean isGlobusJob)
Enables a job to run on the grid.
|
Modifier and Type | Method and Description |
---|---|
void |
CondorStyle.apply(AggregatedJob job)
Apply a style to an AggregatedJob
|
Modifier and Type | Method and Description |
---|---|
void |
Abstract.apply(AggregatedJob job)
Apply a style to an AggregatedJob
|
Modifier and Type | Method and Description |
---|---|
AggregatedJob |
NoGridStart.enable(AggregatedJob aggJob,
Collection jobs)
Enables a collection of jobs and puts them into an AggregatedJob.
|
Modifier and Type | Method and Description |
---|---|
boolean |
Kickstart.enable(AggregatedJob job,
boolean isGlobusJob)
Enables a constituentJob to run on the grid.
|
boolean |
NoGridStart.enable(AggregatedJob job,
boolean isGlobusJob)
Enables a job to run on the grid.
|
boolean |
PegasusLite.enable(AggregatedJob job,
boolean isGlobusJob)
Enables a job to run on the grid.
|
AggregatedJob |
NoGridStart.enable(AggregatedJob aggJob,
Collection jobs)
Enables a collection of jobs and puts them into an AggregatedJob.
|