Package | Description |
---|---|
edu.isi.pegasus.planner.catalog.transformation | |
edu.isi.pegasus.planner.classes | |
edu.isi.pegasus.planner.dax | |
edu.isi.pegasus.planner.parser.dax |
Modifier and Type | Method and Description |
---|---|
Collection<Invoke> |
TransformationCatalogEntry.getNotifications(Invoke.WHEN when)
Returns a collection of all the notifications that need to be
done for a particular condition
|
Modifier and Type | Method and Description |
---|---|
void |
TransformationCatalogEntry.addNotification(Invoke invoke)
Adds a Invoke object correpsonding to a notification.
|
Modifier and Type | Field and Description |
---|---|
private EnumMap<Invoke.WHEN,List<Invoke>> |
Notifications.mInvokeMap
An enum map that associates the various notification events with the list
of actions that need to be taken.
|
Modifier and Type | Method and Description |
---|---|
Collection<Invoke> |
CompoundTransformation.getNotifications(Invoke.WHEN when)
Returns a collection of all the notifications that need to be
done for a particular condition
|
Collection<Invoke> |
ADag.getNotifications(Invoke.WHEN when)
Returns a collection of all the notifications that need to be
done for a particular condition
|
Collection<Invoke> |
Job.getNotifications(Invoke.WHEN when)
Returns a collection of all the notifications that need to be
done for a particular condition
|
Collection<Invoke> |
Notifications.getNotifications(Invoke.WHEN when)
Returns a collection of all the notifications that need to be
done for a particular condition
|
Modifier and Type | Method and Description |
---|---|
void |
Notifications.add(Invoke notification)
Adds a Invoke object correpsonding to a notification.
|
void |
CompoundTransformation.addNotification(Invoke invoke)
Adds a Invoke object correpsonding to a notification.
|
void |
ADag.addNotification(Invoke invoke)
Adds a Invoke object corresponding to a notification.
|
void |
Job.addNotification(Invoke invoke)
Adds a Invoke object correpsonding to a notification.
|
Modifier and Type | Method and Description |
---|---|
private void |
Notifications.addAll(Invoke.WHEN when,
Collection<Invoke> invokes)
Convenience method at add all the notifications corresponding
to a particular event
|
Modifier and Type | Field and Description |
---|---|
private List<Invoke> |
ADAG.mInvokes
List of Notification objects
|
protected List<Invoke> |
AbstractJob.mInvokes |
protected List<Invoke> |
Transformation.mInvokes |
protected List<Invoke> |
Executable.mInvokes
List of Notification objects
|
Modifier and Type | Method and Description |
---|---|
Invoke |
Invoke.clone()
Create a copy of this Invoke object
|
Invoke |
Invoke.setWhat(String what)
Set what executable to invoke and how
|
Invoke |
Invoke.setWhen(Invoke.WHEN when)
Set when to invoke
|
Modifier and Type | Method and Description |
---|---|
List<Invoke> |
ADAG.getInvoke()
Returns a list of Invoke objects associated with the workflow
|
List<Invoke> |
AbstractJob.getInvoke()
Returns list of Invoke objects
|
List<Invoke> |
Transformation.getInvoke()
Return the list of Notification objects
|
List<Invoke> |
Executable.getInvoke()
Return the list of Notification objects
|
List<Invoke> |
ADAG.getNotification()
Returns a list of Invoke objects associated with the workflow.
|
List<Invoke> |
AbstractJob.getNotification()
Same as getInvoke().
|
List<Invoke> |
Transformation.getNotification()
Return the list of Notification objects (same as getInvoke()
|
List<Invoke> |
Executable.getNotification()
Return the list of Notification objects (same as getInvoke)
|
Modifier and Type | Method and Description |
---|---|
ADAG |
ADAG.addInvoke(Invoke invoke)
Add a Notification for this Workflow
|
AbstractJob |
AbstractJob.addInvoke(Invoke invoke)
Add notification to the job
|
Transformation |
Transformation.addInvoke(Invoke invoke)
Add a Notification for this Transformation
|
Executable |
Executable.addInvoke(Invoke invoke)
Add a Notification for this Executable
Same as add Notification
|
ADAG |
ADAG.addNotification(Invoke invoke)
Add a Notification for this Workflow
|
AbstractJob |
AbstractJob.addNotification(Invoke invoke)
Add notification to the job
|
Executable |
Executable.addNotification(Invoke invoke)
Add a Notification for this Executable
Same as addInvoke
|
Modifier and Type | Method and Description |
---|---|
ADAG |
ADAG.addInvokes(List<Invoke> invokes)
Add a List of Notifications for this Workflow
|
AbstractJob |
AbstractJob.addInvokes(List<Invoke> invokes)
Add Notifications to the job
|
Transformation |
Transformation.addInvokes(List<Invoke> invokes)
Add a List of Notifications for this Transformation
|
Executable |
Executable.addInvokes(List<Invoke> invokes)
Add a List of Notifications for this Executable
Same as addNotifications
|
ADAG |
ADAG.addNotifications(List<Invoke> invokes)
Add a List of Notifications for this Workflow
|
AbstractJob |
AbstractJob.addNotifications(List<Invoke> invokes)
Add Notifications to the job
|
Transformation |
Transformation.addNotifications(List<Invoke> invokes)
Add a List of Notifications for this Transformation.
|
Executable |
Executable.addNotifications(List<Invoke> invokes)
Add a List of Notifications for this Executable.
|
Constructor and Description |
---|
Invoke(Invoke i)
Copy Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
ExampleDAXCallback.cbWfInvoke(Invoke invoke)
Callback when a invoke entry is encountered in the top level inside the adag element in the DAX.
|
void |
DAX2Metadata.cbWfInvoke(Invoke invoke)
Callback when a invoke entry is encountered in the top level inside the adag element in the DAX.
|
void |
DAX2CDAG.cbWfInvoke(Invoke invoke)
Callback when a invoke entry is encountered in the top level inside the adag element in DAX.
|
void |
DAX2Graph.cbWfInvoke(Invoke invoke)
Callback when a invoke entry is encountered in the top level inside the adag element in the DAX.
|
void |
Callback.cbWfInvoke(Invoke invoke)
Callback when a invoke is encountered in the DAX from the top level inside
adag tag.
|
void |
DAX2NewGraph.cbWfInvoke(Invoke invoke)
Callback when a invoke entry is encountered in the top level inside the adag element in the DAX.
|