| java.lang.Object
 org.griphyn.cPlanner.engine.Engine
org.griphyn.cPlanner.engine.ReductionEngine
| ReductionEngine | | public class ReductionEngine extends Engine implements Refiner(Code) | | Reduction engine for Planner 2.
Given a ADAG it looks up the replica catalog and
determines which output files are in the
Replica Catalog, and on the basis of these
ends up reducing the dag.
author:
Karan Vahi
author:
Gaurang Mehta
version:
$Revision: 258 $ |
| Method Summary | |
| public Vector | getDeletedLeafJobs()
All the deleted jobs which
happen to be leaf nodes. | | 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. | | public ADag | makeRedDagObject(ADag orgDag, Vector vDelJobs)
makes the Reduced Dag object which
corresponding to the deleted jobs
which are specified.
Note : We are plainly copying the
inputFiles and the outputFiles. | | public ADag | reduceDag(ReplicaCatalogBridge rcb)
Reduces the workflow on the basis of the existence of lfn's in the
replica catalog. |
| ReductionEngine | | public ReductionEngine(ADag orgDag, PegasusProperties properties, PlannerOptions options)(Code) | | The constructor
Parameters:
orgDag - The original Dag object
Parameters:
properties - the PegasusProperties to be used.
Parameters:
options - The options specified bythe user to run theplanner |
| getDeletedLeafJobs | | public Vector getDeletedLeafJobs()(Code) | | All the deleted jobs which
happen to be leaf nodes. This
entails that the output files
of these jobs be transferred
from the location returned
by the Replica Catalog to the
pool specified.
This is a subset of mAllDeletedJobs
Also to determine the deleted
leaf jobs it refers the original
dag, not the reduced dag.
Vector containing the SubInfo of deleted leaf jobs. |
| 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 |
| makeRedDagObject | | public ADag makeRedDagObject(ADag orgDag, Vector vDelJobs)(Code) | | makes the Reduced Dag object which
corresponding to the deleted jobs
which are specified.
Note : We are plainly copying the
inputFiles and the outputFiles. After
reduction this changes but since we
need those only to look up the RC,
which we have done.
Parameters:
orgDag - the original Dag
Parameters:
vDelJobs - the Vector containing thenames of the jobs whoseSubInfos and Relations wewant to remove. the reduced dag, which doesnothave the deleted jobs |
| reduceDag | | public ADag reduceDag(ReplicaCatalogBridge rcb)(Code) | | Reduces the workflow on the basis of the existence of lfn's in the
replica catalog. The existence of files, is determined via the bridge.
Parameters:
rcb - instance of the replica catalog bridge. the reduced dag |
|
|