public interface JobAggregator
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
VERSION
The version number associated with this API of Job Aggregator.
|
Modifier and Type | Method and Description |
---|---|
boolean |
abortOnFristJobFailure()
Returns a boolean indicating whether to fail the aggregated job on
detecting the first failure during execution of constituent jobs.
|
AggregatedJob |
constructAbstractAggregatedJob(java.util.List jobs,
java.lang.String name,
java.lang.String id)
Constructs an abstract aggregated job that has a handle to the appropriate
JobAggregator that will be used to aggregate the jobs.
|
boolean |
entryNotInTC(java.lang.String site)
Determines whether there is NOT an entry in the transformation catalog
for the job aggregator executable on a particular site.
|
java.lang.String |
getClusterExecutableBasename()
Returns the executable basename of the clustering executable used.
|
java.lang.String |
getClusterExecutableLFN()
Returns the logical name of the transformation that is used to
collapse the jobs.
|
void |
initialize(ADag dag,
PegasusBag bag)
Initializes the JobAggregator impelementation
|
void |
makeAbstractAggregatedJobConcrete(AggregatedJob job)
Enables the abstract clustered job for execution and converts it to it's
executable form
|
void |
setAbortOnFirstJobFailure(boolean fail)
Setter method to indicate , failure on first consitutent job should
result in the abort of the whole aggregated job.
|
boolean |
topologicalOrderingRequired()
A boolean indicating whether ordering is important while traversing
through the aggregated job.
|
static final java.lang.String VERSION
void initialize(ADag dag, PegasusBag bag)
dag
- the workflow that is being clustered.bag
- the bag of objects that is useful for initialization.AggregatedJob constructAbstractAggregatedJob(java.util.List jobs, java.lang.String name, java.lang.String id)
jobs
- the list of SubInfo
objects that need to be
collapsed. All the jobs being collapsed should be scheduled
at the same pool, to maintain correct semantics.name
- the logical name of the jobs in the list passed to this
function.id
- the id that is given to the new job.SubInfo
object corresponding to the aggregated
job containing the jobs passed as List in the input,
null if the list of jobs is emptyvoid makeAbstractAggregatedJobConcrete(AggregatedJob job)
job
- the abstract clustered jobboolean topologicalOrderingRequired()
void setAbortOnFirstJobFailure(boolean fail)
fail
- indicates whether to abort or not .boolean abortOnFristJobFailure()
boolean entryNotInTC(java.lang.String site)
site
- the site at which existence check is required.java.lang.String getClusterExecutableLFN()
java.lang.String getClusterExecutableBasename()