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(GraphNode parent,
GraphNode child)
Adds an edge between two already existing nodes in the graph.
|
void |
addEdge(java.lang.String parent,
java.lang.String child)
Adds an edge between two already existing nodes in the graph.
|
void |
addEdges(java.lang.String child,
java.util.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.
|
java.util.Iterator |
bottomUpIterator()
Returns an iterator that traverses the graph bottom up from the leaves.
|
java.lang.Object |
clone()
Returns a new copy of the Object.
|
java.util.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
|
java.lang.String |
getDAXID()
Clustered jobs never originate in the DAX.
|
JobAggregator |
getJobAggregator()
Returns the JobAggregator that created this aggregated job.
|
java.util.List<GraphNode> |
getLeaves()
Returns the leaf nodes of the Graph.
|
GraphNode |
getNode(java.lang.String identifier)
Returns the node matching the id passed.
|
java.util.List<GraphNode> |
getRoots()
Returns the root nodes of the Graph.
|
boolean |
isEmpty()
Returns a boolean if there are no nodes in the graph.
|
java.util.Iterator<GraphNode> |
iterator()
Returns an iterator that traverses through the graph using a graph
traversal algorithm.
|
java.util.Iterator<GraphNode> |
nodeIterator()
Returns an iterator for the nodes in the Graph.
|
int |
numberOfConsitutentJobs()
Returns the number of constituent jobs.
|
boolean |
remove(java.lang.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 |
resetEdges()
Resets all the dependencies in the Graph, while preserving the nodes.
|
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.
|
java.util.Iterator<GraphNode> |
topologicalSortIterator()
Returns an iterator for the graph that traverses in topological sort
order.
|
java.lang.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, getSubmissionCredential, getTXName, getTXNamespace, getTXVersion, getUniverse, getVDSSuperNode, isMPIJob, mergeProfiles, requiresCredentials, 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, setSubmissionCredential, 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 java.lang.String getDAXID()
public java.lang.Object clone()
public java.util.Iterator<Job> constituentJobsIterator()
public Job getConstituentJob(int index)
index
- the index to retrieve frompublic int numberOfConsitutentJobs()
public java.lang.String toString()
public void addNode(GraphNode node)
public void addEdge(java.lang.String parent, java.lang.String child)
public void addEdge(GraphNode parent, GraphNode child)
public void addEdges(java.lang.String child, java.util.List parents)
public GraphNode getNode(java.lang.String identifier)
public void addRoot(GraphNode root)
public boolean remove(java.lang.String identifier)
public void resetEdges()
resetEdges
in interface Graph
public java.util.Iterator<GraphNode> nodeIterator()
nodeIterator
in interface Graph
public java.util.Iterator<GraphNode> iterator()
public java.util.Iterator bottomUpIterator()
bottomUpIterator
in interface Graph
public java.util.Iterator<GraphNode> topologicalSortIterator()
topologicalSortIterator
in interface Graph
public int size()
public java.util.List<GraphNode> getRoots()
public java.util.List<GraphNode> getLeaves()