| java.lang.Object
 org.griphyn.cPlanner.engine.Engine
org.griphyn.cPlanner.engine.InterPoolEngine
| InterPoolEngine | | public class InterPoolEngine extends Engine implements Refiner(Code) | | This engine calls out to the Site Selector selected by the user and maps the
jobs in the workflow to the execution pools.
author:
Karan Vahi
author:
Gaurang Mehta
version:
$Revision: 423 $ |
| Method Summary | |
| public List | convertToList(Vector v)
Converts a Vector to a List. | | public List | convertToList(Set s)
Converts a Set to a List. | | public void | determineSites()
This is where the callout to the Partitioner should take place, that
partitions the workflow into clusters and sends to the site selector only
those list of jobs that are ready to be scheduled. | | public PegasusBag | getPegasusBag()
Returns the bag of intialization objects. | | public ADag | getWorkflow()
Returns a reference to the workflow that is being refined by the refiner. | | public XMLProducer | getXMLProducer()
Returns a reference to the XMLProducer, that generates the XML fragment
capturing the actions of the refiner. | | protected void | logRefinerAction(SubInfo job)
Logs the action taken by the refiner on a job as a XML fragment in
the XML Producer. | | public void | scheduleJobs(ADag dag, List sites)
It schedules a list of jobs on the execution pools by calling out to the
site selector specified. |
| InterPoolEngine | | public InterPoolEngine(PegasusProperties props)(Code) | | Default constructor.
Parameters:
props - the properties to be used. |
| InterPoolEngine | | public InterPoolEngine(ADag aDag, PegasusProperties props, PlannerOptions options)(Code) | | Overloaded constructor.
Parameters:
aDag - the ADag object corresponding to the Dagfor which we want to determine on which pools to runthe nodes of the Dag.
Parameters:
props - the properties to be used.
Parameters:
options - The options specified by the user to run the planner. |
| convertToList | | public List convertToList(Vector v)(Code) | | Converts a Vector to a List. It only copies by reference.
Parameters:
v - Vector a ArrayList |
| convertToList | | public List convertToList(Set s)(Code) | | Converts a Set to a List. It only copies by reference.
Parameters:
s - Set a ArrayList |
| determineSites | | public void determineSites()(Code) | | This is where the callout to the Partitioner should take place, that
partitions the workflow into clusters and sends to the site selector only
those list of jobs that are ready to be scheduled.
|
| getPegasusBag | | public PegasusBag getPegasusBag()(Code) | | Returns the bag of intialization objects.
PegasusBag |
| getWorkflow | | public ADag getWorkflow()(Code) | | Returns a reference to the workflow that is being refined by the refiner.
ADAG object. |
| getXMLProducer | | public XMLProducer getXMLProducer()(Code) | | Returns a reference to the XMLProducer, that generates the XML fragment
capturing the actions of the refiner. This is used for provenace
purposes.
XMLProducer |
| logRefinerAction | | protected void logRefinerAction(SubInfo job)(Code) | | Logs the action taken by the refiner on a job as a XML fragment in
the XML Producer.
Parameters:
job - the SubInfo containing the job that was mappedto a site. |
| scheduleJobs | | public void scheduleJobs(ADag dag, List sites)(Code) | | It schedules a list of jobs on the execution pools by calling out to the
site selector specified. It is upto to the site selector to determine if
the job can be run on the list of sites passed.
Parameters:
dag - the abstract workflow.
Parameters:
sites - the list of execution sites, specified by the user. |
|
|