public class DAX2Metadata extends Object implements Callback
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_ADAG_COUNT_ATTRIBUTE
Default attribute value for the count attribute
|
static 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 Map |
mMetadata
The metadata of the workflow.
|
private PegasusProperties |
mProps
The handle to the properties object.
|
static String |
PARSING_DONE_ERROR_MESSAGE
The parsing completed message.
|
Constructor and Description |
---|
DAX2Metadata(PegasusProperties properties,
String dax)
The overloaded constructor.
|
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 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 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.
|
Object |
getConstructedObject()
Returns an ADag object corresponding to the abstract plan it has generated.
|
public static final String PARSING_DONE_ERROR_MESSAGE
public static final String DEFAULT_ADAG_COUNT_ATTRIBUTE
public static final String DEFAULT_ADAG_INDEX_ATTRIBUTE
private PegasusProperties mProps
private boolean mDone
private Map mMetadata
public DAX2Metadata(PegasusProperties properties, String dax)
properties
- the properties passed to the planner.dax
- 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 parents)
public void cbDone()
public 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.Copyright © 2011 The University of Southern California. All Rights Reserved.