| java.lang.Object
 org.griphyn.cPlanner.cluster.aggregator.Abstract
org.griphyn.cPlanner.cluster.aggregator.MPIExec
| MPIExec | | public class MPIExec extends Abstract (Code) | | This class aggregates the smaller jobs in a manner such that
they are launched at remote end, by mpiexec on n nodes where n is the nodecount
associated with the aggregated job that is being lauched by mpiexec.
The executable mpiexec is a VDS tool distributed in the VDS worker package, and
can be usually found at $PEGASUS_HOME/bin/mpiexec.
author:
Karan Vahi vahi@isi.edu
version:
$Revision: 450 $ |
| Field Summary | |
| final public static String | COLLAPSE_LOGICAL_NAME
The logical name of the transformation that is able to run multiple
jobs sequentially. |
| Constructor Summary | |
| public | MPIExec()
The default constructor. |
| 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 String | aggregatedJobArguments(AggregatedJob job)
Returns the arguments with which the AggregatedJob
needs to be invoked with. | | 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.
The aggregated job is executed at a site, using mpiexec that
executes each of the smaller jobs in the aggregated job on n number of
nodes where n is the nodecount associated with the job.
All the sub jobs are in turn launched via kickstart if kickstart is
installed at the site where the job resides.
Parameters:
jobs - the list of SubInfo objects that need to becollapsed. | | protected AggregatedJob | enable(AggregatedJob mergedJob, List jobs)
Enables the constitutent jobs that make up a aggregated job. | | 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. |
| COLLAPSE_LOGICAL_NAME | | final public static String COLLAPSE_LOGICAL_NAME(Code) | | The logical name of the transformation that is able to run multiple
jobs sequentially.
|
| MPIExec | | public MPIExec()(Code) | | The default constructor.
|
| 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. |
| aggregatedJobArguments | | public String aggregatedJobArguments(AggregatedJob job)(Code) | | Returns the arguments with which the AggregatedJob
needs to be invoked with. At present any empty argument string is
returned.
Parameters:
job - the AggregatedJob for which the arguments haveto be constructed. argument string |
| 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.
The aggregated job is executed at a site, using mpiexec that
executes each of the smaller jobs in the aggregated job on n number of
nodes where n is the nodecount associated with the job.
All the sub jobs are in turn launched via kickstart if kickstart is
installed at the site where the job resides.
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 AggregatedJob object corresponding to the aggregatedjob containing the jobs passed as List in the input,null if the list of jobs is empty |
| enable | | protected AggregatedJob enable(AggregatedJob mergedJob, List jobs)(Code) | | Enables the constitutent jobs that make up a aggregated job. Makes sure
that they all are enabled via no kickstart
Parameters:
mergedJob - the clusteredJob
Parameters:
jobs - the constitutent jobs AggregatedJob |
| 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.
See Also: MPIExec.COLLAPSE_LOGICAL_NAME |
| 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. Ignores any value
passed, as MPIExec does not handle it for time being.
Parameters:
fail - indicates whether to abort or not . |
| Methods inherited from org.griphyn.cPlanner.cluster.aggregator.Abstract | abstract public String aggregatedJobArguments(AggregatedJob job)(Code)(Java Doc)
public AggregatedJob construct(List jobs, String name, String id)(Code)(Java Doc)
protected AggregatedJob construct(List jobs, String name, String id, String mergeLFN)(Code)(Java Doc)
abstract protected AggregatedJob enable(AggregatedJob mergedJob, List jobs)(Code)(Java Doc)
protected boolean entryNotInTC(String namespace, String name, String version, String site)(Code)(Java Doc)
public static String getCompleteTranformationName(String name)(Code)(Java Doc)
protected TransformationCatalogEntry getTCEntry(SubInfo job)(Code)(Java Doc)
public void initialize(ADag dag, PegasusBag bag)(Code)(Java Doc)
protected void setDirectory(String directory)(Code)(Java Doc)
|
|
|