Modifier and Type | Class and Description |
---|---|
class |
ADag
This class object contains the info about a Dag.
|
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.
|
private Graph |
ADag.mGraphImplementor
Handle to the Graph implementor.
|
Modifier and Type | Method and Description |
---|---|
java.io.File |
MPIExec.generatePMCInputFile(Graph job,
java.lang.String name,
boolean isClustered)
Writes out the input file for the aggregated job
|
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.
|
Constructor and Description |
---|
TopologicalSortIterator(Graph graph)
The overloaded constructor.
|
Modifier and Type | Method and Description |
---|---|
protected Graph |
DataReuseEngine.cascadeDeletionUpwards(Graph workflow,
java.util.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,
java.util.List<GraphNode> originalJobsInRC)
Cascade the deletion of the jobs upwards in the workflow.
|
private java.util.List<GraphNode> |
DataReuseEngine.getJobsInRC(Graph workflow,
java.util.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(java.lang.String site,
java.util.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 | Field and Description |
---|---|
private Graph |
Algorithm.mWorkflow
The workflow in the graph format, that needs to be scheduled.
|