Package | Description |
---|---|
edu.isi.pegasus.planner.classes | |
edu.isi.pegasus.planner.cluster.aggregator | |
edu.isi.pegasus.planner.code.generator.condor | |
edu.isi.pegasus.planner.parser.dax | |
edu.isi.pegasus.planner.partitioner.graph | |
edu.isi.pegasus.planner.refiner | |
edu.isi.pegasus.planner.refiner.cleanup | |
edu.isi.pegasus.planner.refiner.createdir | |
edu.isi.pegasus.planner.selector |
Provides the interface and call-out to the site selector mechanism.
|
edu.isi.pegasus.planner.selector.site | |
edu.isi.pegasus.planner.selector.site.heft |
Modifier and Type | Class and Description |
---|---|
class |
AggregatedJob
This class holds all the specifics of an aggregated job.
|
Modifier and Type | Field and Description |
---|---|
private Graph |
AggregatedJob.mGraphImplementor
Handle to the Graph implementor.
|
Modifier and Type | Method and Description |
---|---|
File |
MPIExec.generatePMCInputFile(Graph job,
String name,
boolean isClustered)
Writes out the input file for the aggregated job
|
Modifier and Type | Field and Description |
---|---|
private Graph |
SUBDAXGenerator.mWorkflow |
Modifier and Type | Method and Description |
---|---|
void |
SUBDAXGenerator.initialize(PegasusBag bag,
ADag dag,
Graph workflow,
PrintWriter dagWriter)
Initializes the class.
|
Modifier and Type | Field and Description |
---|---|
protected Graph |
DAX2NewGraph.mWorkflow
The Graph instance that stores the abstract workflow as a Graph.
|
Modifier and Type | Class and Description |
---|---|
class |
MapGraph
An implementation of the Graph that is backed by a Map.
|
Modifier and Type | Field and Description |
---|---|
private Graph |
TopologicalSortIterator.mGraph
The partition that has to be sorted.
|
Modifier and Type | Method and Description |
---|---|
static Graph |
Adapter.convert(ADag dag)
Converts the
ADag to Graph instance. |
Constructor and Description |
---|
TopologicalSortIterator(Graph graph)
The overloaded constructor.
|
Modifier and Type | Method and Description |
---|---|
private Graph |
DeployWorkerPackage.addSetupNodesWithoutUntarNodes(ADag dag,
Set<String> deploymentSites)
Adds only the stage worker nodes to the workflow.
|
private Graph |
DeployWorkerPackage.addSetupNodesWithUntarNodes(ADag dag,
Set<String> deploymentSites)
Adds untar nodes to the workflow, in addition to the stage worker nodes
|
protected Graph |
DataReuseEngine.cascadeDeletionUpwards(Graph workflow,
List<GraphNode> originalJobsInRC)
Cascade the deletion of the jobs upwards in the workflow.
|
Graph |
ReduceEdges.reduce(Graph workflow)
Prunes redundant edges from the workflow.
|
Graph |
DataReuseEngine.reduceWorkflow(Graph workflow,
ReplicaCatalogBridge rcb)
Reduces the workflow on the basis of the existence of lfn's in the
replica catalog.
|
Modifier and Type | Method and Description |
---|---|
void |
ReduceEdges.assignLevels(Graph workflow,
GraphNode root)
Prunes redundant edges from the workflow.
|
protected Graph |
DataReuseEngine.cascadeDeletionUpwards(Graph workflow,
List<GraphNode> originalJobsInRC)
Cascade the deletion of the jobs upwards in the workflow.
|
private List<GraphNode> |
DataReuseEngine.getJobsInRC(Graph workflow,
Set filesInRC)
Returns all the jobs whose output files exist in the Replica Catalog.
|
Graph |
ReduceEdges.reduce(Graph workflow)
Prunes redundant edges from the workflow.
|
Graph |
DataReuseEngine.reduceWorkflow(Graph workflow,
ReplicaCatalogBridge rcb)
Reduces the workflow on the basis of the existence of lfn's in the
replica catalog.
|
private void |
ReduceEdges.reset(Graph workflow)
Resets internal depth and color counters associated with the nodes in the
workflow, before doing any graph traversals.
|
Modifier and Type | Method and Description |
---|---|
Graph |
InPlace.addCleanupJobs(Graph workflow)
Adds cleanup jobs to the workflow.
|
Graph |
CleanupStrategy.addCleanupJobs(Graph workflow)
Adds cleanup jobs to the workflow.
|
Modifier and Type | Method and Description |
---|---|
Graph |
InPlace.addCleanupJobs(Graph workflow)
Adds cleanup jobs to the workflow.
|
Graph |
CleanupStrategy.addCleanupJobs(Graph workflow)
Adds cleanup jobs to the workflow.
|
private void |
InPlace.addCleanUpJobs(String site,
Set leaves,
Graph workflow)
Adds cleanup jobs for the workflow scheduled to a particular site
a breadth first search strategy is implemented based on the depth of the job
in the workflow
|
protected void |
InPlace.applyJobPriorities(Graph workflow)
Adds job priorities to the jobs in the workflow on the basis of
the levels in the traversal order given by the iterator.
|
Modifier and Type | Method and Description |
---|---|
Graph |
Minimal.addCreateDirectoryNodes(Graph workflow,
ADag dag,
Set<String> sites)
Adds create dir nodes to the workflow.
|
Modifier and Type | Method and Description |
---|---|
Graph |
Minimal.addCreateDirectoryNodes(Graph workflow,
ADag dag,
Set<String> sites)
Adds create dir nodes to the workflow.
|
Modifier and Type | Method and Description |
---|---|
void |
SiteSelector.mapWorkflow(Graph workflow,
List sites)
Maps the jobs in the workflow to the various grid sites.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractPerJob.mapWorkflow(Graph workflow,
List sites)
Maps the jobs in the workflow to the various grid sites.
|
void |
Group.mapWorkflow(Graph workflow,
List sites)
The call out to map a list of jobs on to the execution pools.
|
void |
Heft.mapWorkflow(Graph workflow,
List sites)
Maps the jobs in the workflow to the various grid sites.
|
void |
Heft.mapWorkflow(Graph workflow,
List sites,
String label)
Maps the jobs in the workflow to the various grid sites.
|
Modifier and Type | Field and Description |
---|---|
private Graph |
Algorithm.mWorkflow
The workflow in the graph format, that needs to be scheduled.
|
Modifier and Type | Method and Description |
---|---|
void |
Algorithm.schedule(Graph workflow,
List sites,
String label)
Schedules the workflow according to the HEFT algorithm.
|