| java.lang.Object
 org.griphyn.cPlanner.selector.site.Abstract
org.griphyn.cPlanner.selector.site.Group
| Group | | public class Group extends Abstract (Code) | | A site selector than ends up doing grouping jobs together on the basis of
an identifier specifed in the dax for the jobs, and schedules them on to the
same site. Currently, the identifier is key group in the vds
profile namespace. All the jobs that do not have a group associated with them
are put in one default group and end up being scheduled on the same pool.
A limitation of this site selector is that it does not check whether all the
jobs can be scheduled on a particular pool or not. It just checks whether
the first job can be or not. The reason for that is after the grouping the
the selector just hands the first job in each group to the other site selectors
that work on jobs. Currently, it hands it to the Random Site Selector.
author:
Karan Vahi
author:
Gaurang Mehta
author:
Mei-Hui Su
version:
$Revision: 298 $ |
| Constructor Summary | |
| public | Group()
The default constructor. |
| Group | | public Group()(Code) | | The default constructor.
|
| description | | public String description()(Code) | | Returns the description of the site selector.
description. |
| initialize | | public void initialize(PegasusBag bag)(Code) | | Initializes the site selector.
Parameters:
bag - the bag of objects that is useful for initialization. |
| mapWorkflow | | public void mapWorkflow(Graph workflow, List sites)(Code) | | The call out to map a list of jobs on to the execution pools. A default
implementation is provided that internally calls mapJob2ExecPool(SubInfo,
String,String,String) to map each of the jobs sequentially to an execution site.
The reason for this method is to support site selectors that
make their decision on a group of jobs i.e use backtracking to reach a good
decision.
The implementation that calls out to an executable using Runtime does not
implement this method, but relies on the default implementation defined
here.
Parameters:
workflow - the workflow that needs to be scheduled.
Parameters:
sites - the list of String objects representing theexecution pools that can be used. |
|
|