Modifier and Type | Field and Description |
---|---|
protected boolean |
mDone
A flag to specify whether the graph has been generated for the partition
or not.
|
protected String |
mLabel
The label of the abstract dax.
|
protected PegasusProperties |
mProps
The handle to the properties object.
|
protected Graph |
mWorkflow
The Graph instance that stores the abstract workflow as a Graph.
|
Constructor and Description |
---|
DAX2NewGraph() |
Modifier and Type | Method and Description |
---|---|
void |
cbCompoundTransformation(CompoundTransformation compoundTransformation)
Callback when a compound transformation is encountered in the DAX
|
void |
cbDocument(Map attributes)
Callback when the opening tag was parsed.
|
void |
cbDone()
Callback to signal that traversal of the DAX is complete.
|
void |
cbExecutable(TransformationCatalogEntry tce)
Callback when a transformation catalog entry is encountered in the DAX
|
void |
cbFile(ReplicaLocation rl)
Callback when a replica catalog entry is encountered in the DAX
|
void |
cbJob(Job job)
This constructs a graph node for the job and ends up storing it in the
internal map.
|
void |
cbParents(String child,
List parents)
This updates the internal graph nodes of child with references to it's
parents referred to by the list of parents passed.
|
void |
cbWfInvoke(Invoke invoke)
Callback when a invoke entry is encountered in the top level inside the adag element in the DAX.
|
GraphNode |
get(String key)
Returns the
GraphNode of the corresponding id. |
Object |
getConstructedObject()
Returns the workflow represented in the
Graph form. |
String |
getNameOfDAX()
Returns the name of the dax.
|
void |
initialize(PegasusBag bag,
String dax)
The overloaded constructor.
|
protected Graph mWorkflow
protected boolean mDone
protected String mLabel
protected PegasusProperties mProps
public void initialize(PegasusBag bag, String dax)
initialize
in interface Callback
bag
- the bag of initialization objects containing the properties
and the loggerdax
- the path to the DAX file.public Object getConstructedObject()
Graph
form.getConstructedObject
in interface Callback
Graph
containing the abstract workflow referred
in the dax.public void cbDocument(Map attributes)
cbDocument
in interface Callback
attributes
- is a map of attribute key to attribute valuepublic void cbWfInvoke(Invoke invoke)
cbWfInvoke
in interface Callback
invoke
- the invoke objectpublic void cbJob(Job job)
public void cbParents(String child, List parents)
public String getNameOfDAX()
public void cbDone()
public GraphNode get(String key)
GraphNode
of the corresponding id.key
- the id of the node.GraphNode
.public void cbCompoundTransformation(CompoundTransformation compoundTransformation)
cbCompoundTransformation
in interface Callback
compoundTransformation
- the compound transforamtionpublic void cbFile(ReplicaLocation rl)
public void cbExecutable(TransformationCatalogEntry tce)
cbExecutable
in interface Callback
tce
- the transformationc catalog entry object.