| java.lang.Object
 org.griphyn.cPlanner.cluster.aggregator.Abstract
org.griphyn.cPlanner.cluster.aggregator.SeqExec
| SeqExec | | public class SeqExec extends Abstract (Code) | | This class aggregates the smaller jobs in a manner such that
they are launched at remote end, sequentially on a single node using
seqexec. The executable seqexec is a VDS tool distributed in the VDS worker
package, and can be usually found at $PEGASUS_HOME/bin/seqexec.
author:
Karan Vahi vahi@isi.edu
version:
$Revision: 451 $ |
| Constructor Summary | |
| public | SeqExec()
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.
Parameters:
job - the AggregatedJob for which the arguments haveto be constructed. | | 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 seqexec uses kickstart to invoke each of the smaller constituent
jobs. | | 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)
| | protected String | logFile(AggregatedJob job)
Returns the name of the log file to used on the remote site, for the
seqexec job. | | 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.
|
| SEQEXEC_PROGRESS_REPORT_SUFFIX | | final public static String SEQEXEC_PROGRESS_REPORT_SUFFIX(Code) | | The suffix to be applied to seqexec progress report file.
|
| SeqExec | | public SeqExec()(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.
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 seqexec uses kickstart to invoke each of the smaller constituent
jobs. The kickstart output appears on the stdout of the seqexec. Hence,
the seqexec itself is not being kickstarted. At the same time, appropriate
postscript is constructed to be invoked on the job.
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.
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: SeqExec.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. |
| logFile | | protected String logFile(AggregatedJob job)(Code) | | Returns the name of the log file to used on the remote site, for the
seqexec job. Depending upon the property settings, either assigns a
common
Parameters:
job - the AggregatedJob the path to the log file. |
| 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)
|
|
|