public class DAX2CDAG extends Object implements Callback
Modifier and Type | Field and Description |
---|---|
private boolean |
mAddDataDependencies
To track whether we auto detect data dependancies or not.
|
protected Map<String,CompoundTransformation> |
mCompoundTransformations
Map of Compound Transformations indexed by complete name of the compound
transformation.
|
private ADag |
mDag
The ADag object which contains information corresponding to the ADag in
the XML file.
|
private boolean |
mDone
A flag to specify whether the graph has been generated for the partition
or not.
|
private Map<String,Job> |
mFileCreationMap
Map to track a LFN with the job that creates the file corresponding to the
LFN.
|
private Map<String,String> |
mJobMap
The mapping of the idrefs of a job to the job name.
|
private LogManager |
mLogger
The handle to the logger
|
private Notifications |
mNotifications
All the notifications associated with the adag
|
private PegasusProperties |
mProps
The handle to the properties object.
|
protected ReplicaStore |
mReplicaStore
Handle to the replica store that stores the replica catalog
user specifies in the DAX
|
protected TransformationStore |
mTransformationStore
Handle to the transformation store that stores the transformation catalog
user specifies in the DAX
|
Constructor and Description |
---|
DAX2CDAG() |
Modifier and Type | Method and Description |
---|---|
private void |
addDataDependencies()
Goes through the ADag and computes any data dependencies.
|
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 when the parsing of the document is done.
|
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)
Callback for the job from section 2 jobs.
|
void |
cbParents(String child,
List<PCRelation> parents)
Callback for child and parentID relationships from section 3.
|
void |
cbWfInvoke(Invoke invoke)
Callback when a invoke entry is encountered in the top level inside the adag element in DAX.
|
Object |
getConstructedObject()
Returns an ADag object corresponding to the abstract plan it has generated.
|
void |
initialize(PegasusBag bag,
String dax)
The overloaded constructor.
|
private ADag mDag
private Map<String,String> mJobMap
private PegasusProperties mProps
private boolean mDone
protected ReplicaStore mReplicaStore
protected TransformationStore mTransformationStore
protected Map<String,CompoundTransformation> mCompoundTransformations
private Notifications mNotifications
private boolean mAddDataDependencies
private Map<String,Job> mFileCreationMap
private LogManager mLogger
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 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<PCRelation> parents)
public void cbDone()
public Object getConstructedObject()
getConstructedObject
in interface Callback
public void cbCompoundTransformation(CompoundTransformation compoundTransformation)
cbCompoundTransformation
in interface Callback
compoundTransformation
- the compound transformationpublic void cbFile(ReplicaLocation rl)
public void cbExecutable(TransformationCatalogEntry tce)
cbExecutable
in interface Callback
tce
- the transformation catalog entry object.private void addDataDependencies()