| java.lang.Object
 org.griphyn.cPlanner.cluster.aggregator.Abstract
All known Subclasses: org.griphyn.cPlanner.cluster.aggregator.MPIExec, org.griphyn.cPlanner.cluster.aggregator.SeqExec,
| Abstract | | abstract public class Abstract implements JobAggregator(Code) | | An abstract implementation of the JobAggregator interface, which the other
implementations can choose to extend.
author:
Karan Vahi vahi@isi.edu
version:
$Revision: 450 $ |
| Constructor Summary | |
| public | Abstract()
The default constructor. |
| Method Summary | |
| abstract 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.
Parameters:
jobs - the list of SubInfo objects that need to becollapsed. | | protected AggregatedJob | construct(List jobs, String name, String id, String mergeLFN)
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. | | abstract protected AggregatedJob | enable(AggregatedJob mergedJob, List jobs)
Enables the constitutent jobs that make up a aggregated job. | | protected boolean | entryNotInTC(String namespace, String name, String version, String site)
Determines whether there is NOT an entry in the transformation catalog
for a particular transformation on a particular site.
Parameters:
namespace - the logical namespace of the transformation.
Parameters:
name - the logical name of the transformation.
Parameters:
version - the version of the transformation.
Parameters:
site - the site at which existence check is required. | | public static String | getCompleteTranformationName(String name)
A convenience method to return the complete transformation name being
used to construct jobs in this class. | | protected TransformationCatalogEntry | getTCEntry(SubInfo job)
Helper method to get an entry from the transformation catalog for an
installed executable. | | public void | initialize(ADag dag, PegasusBag bag)
| | protected void | setDirectory(String directory)
Sets the directory where the stdin files are to be generated. |
| DERIVATION_NAMESPACE | | final public static String DERIVATION_NAMESPACE(Code) | | The derivation namespace for the cluster jobs.
|
| DERIVATION_VERSION | | final public static String DERIVATION_VERSION(Code) | | The version number for the derivations for cluster jobs.
|
| FAT_JOB_PREFIX | | final public static String FAT_JOB_PREFIX(Code) | | The prefix that is assigned to the jobname of the collapsed jobs to
get the jobname for the fat job.
|
| TRANSFORMATION_NAMESPACE | | final public static String TRANSFORMATION_NAMESPACE(Code) | | The transformation namespace for the cluster jobs.
|
| TRANSFORMATION_VERSION | | final public static String TRANSFORMATION_VERSION(Code) | | The version number for the derivations for cluster jobs
|
| mClusteredADag | | protected ADag mClusteredADag(Code) | | The handle to the ADag object that contains the workflow being
clustered.
|
| mDirectory | | protected String mDirectory(Code) | | The directory, where the stdin file of the fat jobs are created.
It should be the submit file directory that the user mentions at
runtime.
|
| mLogger | | protected LogManager mLogger(Code) | | The handle to the LogManager that logs all the messages.
|
| Abstract | | public Abstract()(Code) | | The default constructor.
|
| aggregatedJobArguments | | abstract 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.
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 |
| construct | | protected AggregatedJob construct(List jobs, String name, String id, String mergeLFN)(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.
Parameters:
mergeLFN - the logical name for the aggregated job that has to beconstructed. 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 | | abstract 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 | | protected boolean entryNotInTC(String namespace, String name, String version, String site)(Code) | | Determines whether there is NOT an entry in the transformation catalog
for a particular transformation on a particular site.
Parameters:
namespace - the logical namespace of the transformation.
Parameters:
name - the logical name of the transformation.
Parameters:
version - the version of the transformation.
Parameters:
site - the site at which existence check is required. boolean true if an entry does not exists, false otherwise. |
| getCompleteTranformationName | | public static String getCompleteTranformationName(String name)(Code) | | A convenience method to return the complete transformation name being
used to construct jobs in this class.
Parameters:
name - the name of the transformation the complete transformation name |
| getTCEntry | | protected TransformationCatalogEntry getTCEntry(SubInfo job)(Code) | | Helper method to get an entry from the transformation catalog for an
installed executable. It does the traversal from the list of entries
to return a single TransformationCatalogEntry object, and dies with
an appropriate error message if the object is not found.
The pool and the name are retrieved from job object.
Parameters:
job - the job whose corresponding TransformationCatalogEntry you want. the TransformationCatalogEntry corresponding to the entry in theTC. |
| 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. |
| setDirectory | | protected void setDirectory(String directory)(Code) | | Sets the directory where the stdin files are to be generated.
Parameters:
directory - the path to the directory to which it needs to be set. |
|
|