edu.isi.pegasus.planner.classes
public class AggregatedJob extends Job implements Graph
Modifier and Type | Field and Description |
---|---|
private Graph |
mGraphImplementor
Handle to the Graph implementor.
|
private boolean |
mHasBeenRenderedToExecutableForm
Boolean indicating whether a job has been fully rendered to an executable
job or not i.e the aggregated job has been mapped to the aggregator and
the constituent jobs have been gridstarted or not.
|
private JobAggregator |
mJobAggregator
Handle to the JobAggregator that created this job.
|
CHMOD_JOB, CLEANUP_JOB, COMPUTE_JOB, condorUniverse, condorVariables, CREATE_DIR_JOB, DAG_JOB, dagmanVariables, DAX_JOB, dvName, dvNamespace, dvVersion, envVariables, executable, executionPool, globusRSL, globusScheduler, hints, inputFiles, INTER_POOL_JOB, jobClass, jobID, jobName, level, logicalId, logicalName, namespace, outputFiles, REPLICA_REG_JOB, STAGE_IN_JOB, STAGE_IN_WORKER_PACKAGE_JOB, STAGE_OUT_JOB, stdErr, stdIn, stdOut, strargs, UNASSIGNED_JOB, vdsNS, version
Constructor and Description |
---|
AggregatedJob()
The default constructor.
|
AggregatedJob(int num)
The overloaded constructor.
|
AggregatedJob(Job job,
int num)
The overloaded constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
add(Job job)
Adds a job to the aggregated job.
|
void |
addEdge(String parent,
String child)
Adds an edge between two already existing nodes in the graph.
|
void |
addEdges(String child,
List parents)
A convenience method that allows for bulk addition of edges between
already existing nodes in the graph.
|
void |
addNode(GraphNode node)
Adds a node to the Graph.
|
void |
addRoot(GraphNode root)
Adds a single root node to the Graph.
|
Object |
clone()
Returns a new copy of the Object.
|
Iterator<Job> |
constituentJobsIterator()
Returns an iterator to the constituent jobs of the AggregatedJob.
|
Job |
getConstituentJob(int index)
Returns a job from a particular position in the list of constituent jobs
|
String |
getDAXID()
Clustered jobs never originate in the DAX.
|
JobAggregator |
getJobAggregator()
Returns the JobAggregator that created this aggregated job.
|
List<GraphNode> |
getLeaves()
Returns the leaf nodes of the Graph.
|
GraphNode |
getNode(String identifier)
Returns the node matching the id passed.
|
List<GraphNode> |
getRoots()
Returns the root nodes of the Graph.
|
boolean |
isEmpty()
Returns a boolean if there are no nodes in the graph.
|
Iterator<GraphNode> |
iterator()
Returns an iterator that traverses through the graph using a graph
traversal algorithm.
|
Iterator<GraphNode> |
nodeIterator()
Returns an iterator for the nodes in the Graph.
|
int |
numberOfConsitutentJobs()
Returns the number of constituent jobs.
|
boolean |
remove(String identifier)
Removes a node from the Graph.
|
boolean |
renderedToExecutableForm()
Returns a boolean indicating whether a job has been rendered to an executable
form or not
|
void |
setJobAggregator(JobAggregator aggregator)
Sets the JobAggregator that created this aggregated job.
|
void |
setRenderedToExecutableForm(boolean value)
Returns a boolean indicating whether a job has been rendered to an executable
form or not
|
int |
size()
Returns the number of nodes in the graph.
|
Iterator<GraphNode> |
topologicalSortIterator()
Returns an iterator for the graph that traverses in topological sort
order.
|
String |
toString()
Returns a textual description of the object.
|
addCredentialType, addCredentialType, addInputFile, addNotification, addNotifications, addNotifications, addOutputFile, addProfile, computeRuntime, equals, getArguments, getCompleteDVName, getCompleteTCName, getCredentialTypes, getDirectory, getDOTColor, getDVName, getDVNamespace, getDVVersion, getGridGatewayJobType, getID, getInputFiles, getJobManager, getJobType, getJobTypeDescription, getJobTypeDescription, getLevel, getLogicalID, getName, getNotifications, getNotifications, getOutputFiles, getPreScriptArguments, getPreScriptPath, getRemoteExecutable, getRuntime, getSiteHandle, getStagedExecutableBaseName, getStagedExecutableBaseName, getStagingSiteHandle, getStdErr, getStdIn, getStdOut, getTXName, getTXNamespace, getTXVersion, getUniverse, getVDSSuperNode, isMPIJob, mergeProfiles, resetCredentialTypes, resetNotifications, resetProfiles, runInWorkDirectory, setArguments, setDerivation, setDirectory, setDVName, setDVNamespace, setDVVersion, setExecutableStagingForJob, setInputFiles, setJobManager, setJobType, setLevel, setLogicalID, setName, setOutputFiles, setPreScript, setPreScript, setRemoteExecutable, setRuntime, setRuntime, setSiteHandle, setStagingSiteHandle, setStdErr, setStdIn, setStdOut, setTransformation, setTXName, setTXNamespace, setTXVersion, setTypeRecursive, setUniverse, setVDSSuperNode, toDOT, toDOT, typeInRange, typeRecursive, updateProfiles, updateProfiles, updateProfiles, updateProfiles, userExecutablesStagedForJob
setToString, vectorToString
private boolean mHasBeenRenderedToExecutableForm
private JobAggregator mJobAggregator
private Graph mGraphImplementor
public AggregatedJob()
public AggregatedJob(int num)
num
- the number of constituent jobspublic AggregatedJob(Job job, int num)
job
- the job whose shallow copy is created, and is the main job.num
- the number of constituent jobs.public boolean renderedToExecutableForm()
public void setRenderedToExecutableForm(boolean value)
value
- boolean to set to.public void setJobAggregator(JobAggregator aggregator)
aggregator
- handle to the JobAggregator used for aggregating the jobpublic JobAggregator getJobAggregator()
public void add(Job job)
job
- the job to be added.public String getDAXID()
public Object clone()
public Iterator<Job> constituentJobsIterator()
public Job getConstituentJob(int index)
index
- the index to retrieve frompublic int numberOfConsitutentJobs()
public String toString()
public void addNode(GraphNode node)
public void addEdge(String parent, String child)
public void addEdges(String child, List parents)
public void addRoot(GraphNode root)
addRoot
in interface Graph
root
- the GraphNode
to be added as a root.RuntimeException
- if a node with the same id already exists.public boolean remove(String identifier)
public Iterator<GraphNode> nodeIterator()
nodeIterator
in interface Graph
public Iterator<GraphNode> iterator()
public Iterator<GraphNode> topologicalSortIterator()
topologicalSortIterator
in interface Graph
public int size()