public class DAX2Metadata extends java.lang.Object implements Callback
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DEFAULT_ADAG_COUNT_ATTRIBUTE
Default attribute value for the count attribute
|
static java.lang.String |
DEFAULT_ADAG_INDEX_ATTRIBUTE
Default index value for the count attribute
|
private boolean |
mDone
A flag to specify whether the graph has been generated for the partition
or not.
|
private java.util.Map |
mMetadata
The metadata of the workflow.
|
private PegasusProperties |
mProps
The handle to the properties object.
|
static java.lang.String |
PARSING_DONE_ERROR_MESSAGE
The parsing completed message.
|
Constructor and Description |
---|
DAX2Metadata() |
Modifier and Type | Method and Description |
---|---|
void |
cbCompoundTransformation(CompoundTransformation compoundTransformation)
Callback when a compound transformation is encountered in the DAX
|
void |
cbDocument(java.util.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(java.lang.String child,
java.util.List parents)
Callback for child and parent relationships from section 3.
|
void |
cbWfInvoke(Invoke invoke)
Callback when a invoke entry is encountered in the top level inside the adag element in the DAX.
|
java.lang.Object |
getConstructedObject()
Returns an ADag object corresponding to the abstract plan it has generated.
|
void |
initialize(PegasusBag bag,
java.lang.String dax)
The overloaded constructor.
|
public static final java.lang.String PARSING_DONE_ERROR_MESSAGE
public static final java.lang.String DEFAULT_ADAG_COUNT_ATTRIBUTE
public static final java.lang.String DEFAULT_ADAG_INDEX_ATTRIBUTE
private PegasusProperties mProps
private boolean mDone
private java.util.Map mMetadata
public void initialize(PegasusBag bag, java.lang.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(java.util.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(java.lang.String child, java.util.List parents)
public void cbDone()
public java.lang.Object getConstructedObject()
getConstructedObject
in interface Callback
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.