| org.griphyn.cPlanner.cluster.JobAggregator
All known Subclasses: org.griphyn.cPlanner.cluster.aggregator.Abstract,
| JobAggregator | | public interface JobAggregator (Code) | | The interface that dictates how the jobs are clumped together into one single
larger job. The interface does not dictate how the graph structure is
to be modified as a result of the clumping. That is handled outside of the
implementing class in NodeCollapser.
author:
Karan Vahi vahi@isi.edu
version:
$Revision: 450 $ |
| Field Summary | |
| final public static String | VERSION
The version number associated with this API of Job Aggregator. |
| Method Summary | |
| public boolean | abortOnFristJobFailure()
Returns a boolean indicating whether to fail the aggregated job on
detecting the first failure during execution of constituent jobs. | | public AggregatedJob | construct(List jobs, String name, String id)
Constructs a new aggregated job that contains all the jobs passed to it.
The new aggregated job, appears as a single job in the workflow and
replaces the jobs it contains in the workflow.
Parameters:
jobs - the list of SubInfo objects that need to becollapsed. | | public boolean | entryNotInTC(String site)
Determines whether there is NOT an entry in the transformation catalog
for the job aggregator executable on a particular site.
Parameters:
site - the site at which existence check is required. | | public String | getCollapserLFN()
Returns the logical name of the transformation that is used to
collapse the jobs. | | public void | initialize(ADag dag, PegasusBag bag)
| | public void | setAbortOnFirstJobFailure(boolean fail)
Setter method to indicate , failure on first consitutent job should
result in the abort of the whole aggregated job. |
| VERSION | | final public static String VERSION(Code) | | The version number associated with this API of Job Aggregator.
|
| abortOnFristJobFailure | | public boolean abortOnFristJobFailure()(Code) | | Returns a boolean indicating whether to fail the aggregated job on
detecting the first failure during execution of constituent jobs.
boolean indicating whether to fail or not. |
| construct | | public AggregatedJob construct(List jobs, String name, String id)(Code) | | Constructs a new aggregated job that contains all the jobs passed to it.
The new aggregated job, appears as a single job in the workflow and
replaces the jobs it contains in the workflow.
Parameters:
jobs - the list of SubInfo objects that need to becollapsed. All the jobs being collapsed should be scheduledat the same pool, to maintain correct semantics.
Parameters:
name - the logical name of the jobs in the list passed to thisfunction.
Parameters:
id - the id that is given to the new job. the SubInfo object corresponding to the aggregatedjob containing the jobs passed as List in the input,null if the list of jobs is empty |
| entryNotInTC | | public boolean entryNotInTC(String site)(Code) | | Determines whether there is NOT an entry in the transformation catalog
for the job aggregator executable on a particular site.
Parameters:
site - the site at which existence check is required. boolean true if an entry does not exists, false otherwise. |
| getCollapserLFN | | public String getCollapserLFN()(Code) | | Returns the logical name of the transformation that is used to
collapse the jobs.
the the logical name of the collapser executable. |
| initialize | | public void initialize(ADag dag, PegasusBag bag)(Code) | | Initializes the JobAggregator impelementation
Parameters:
dag - the workflow that is being clustered.
Parameters:
bag - the bag of objects that is useful for initialization. |
| setAbortOnFirstJobFailure | | public void setAbortOnFirstJobFailure(boolean fail)(Code) | | Setter method to indicate , failure on first consitutent job should
result in the abort of the whole aggregated job.
Parameters:
fail - indicates whether to abort or not . |
|
|