public class MPIExec extends Abstract
Modifier and Type | Field and Description |
---|---|
static String |
COLLAPSE_LOGICAL_NAME
The logical name of the transformation that is able to run multiple
jobs via mpi.
|
static String |
EXECUTABLE_BASENAME
The basename of the executable that is able to run multiple
jobs via mpi.
|
CLUSTERED_JOB_PREFIX, DERIVATION_NAMESPACE, DERIVATION_VERSION, mBag, mClusteredADag, mDirectory, mGridStartFactory, mLogger, MONITORD_COMMENT_MARKER, mProps, mSiteStore, mTCHandle, TRANSFORMATION_NAMESPACE, TRANSFORMATION_VERSION
VERSION
Constructor and Description |
---|
MPIExec()
The default constructor.
|
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.
|
String |
aggregatedJobArguments(AggregatedJob job)
Returns the arguments with which the
AggregatedJob
needs to be invoked with. |
boolean |
entryNotInTC(String site)
Determines whether there is NOT an entry in the transformation catalog
for the job aggregator executable on a particular site.
|
String |
getClusterExecutableBasename()
Returns the executable basename of the clustering executable used.
|
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.
|
constructAbstractAggregatedJob, constructAbstractAggregatedJob, entryNotInTC, getCommentString, getCompleteTranformationName, getTCEntry, setDirectory
public static final String COLLAPSE_LOGICAL_NAME
public static String EXECUTABLE_BASENAME
public void initialize(ADag dag, PegasusBag bag)
initialize
in interface JobAggregator
initialize
in class Abstract
dag
- the workflow that is being clustered.bag
- the bag of objects that is useful for initialization.public void makeAbstractAggregatedJobConcrete(AggregatedJob job)
makeAbstractAggregatedJobConcrete
in interface JobAggregator
makeAbstractAggregatedJobConcrete
in class Abstract
job
- the abstract clustered jobpublic String getClusterExecutableLFN()
COLLAPSE_LOGICAL_NAME
public String getClusterExecutableBasename()
EXECUTABLE_BASENAME
public boolean entryNotInTC(String site)
site
- the site at which existence check is required.public String aggregatedJobArguments(AggregatedJob job)
AggregatedJob
needs to be invoked with. At present any empty argument string is
returned.aggregatedJobArguments
in class Abstract
job
- the AggregatedJob
for which the arguments have
to be constructed.public void setAbortOnFirstJobFailure(boolean fail)
fail
- indicates whether to abort or not .public boolean abortOnFristJobFailure()
Copyright © 2011 The University of Southern California. All Rights Reserved.