|
Class Summary |
| CleanupEngine |
The refiner that results in the creation of cleanup jobs within the workflow. |
| CreateDirectory |
This common interface that identifies the basic functions that need to be
implemented to introduce random directories in which the jobs are executed on
the remote execution pools. |
| DataReuseEngine |
The data reuse engine reduces the workflow on the basis of existing output
files of the workflow found in the Replica Catalog. |
| DeployWorkerPackage |
The refiner that is responsible for adding
- setup nodes that deploy a worker package on each deployment site at start
of workflow execution
- cleanup nodes that undeploy a worker package on each deployment site at end
workflow execution |
| Engine |
The class which is a superclass of all the various Engine classes. |
| InterPoolEngine |
This engine calls out to the Site Selector selected by the user and maps the
jobs in the workflow to the execution pools. |
| MainEngine |
The central class that calls out to the various other components of Pegasus. |
| NodeCollapser |
This collapses the nodes of the same logical name scheduled on the same
pool into fewer fat nodes. |
| ReductionEngine |
Reduction engine for Planner 2. |
| RemoveDirectory |
Ends up creating a cleanup dag that deletes the remote directories that
were created by the create dir jobs. |
| ReplicaCatalogBridge |
This coordinates the look up to the Replica Location Service, to determine
the logical to physical mappings. |
| TransferEngine |
The transfer engine, which on the basis of the pools on which the jobs are to
run, adds nodes to transfer the data products. |