java.util.Map<java.lang.String,java.lang.String> |
Braindump.defaultBrainDumpEntries(ADag workflow) |
Returns default braindump entries.
|
java.util.Collection<java.io.File> |
Braindump.generateCode(ADag dag) |
Generates the code for the executable workflow in terms of a braindump
file that contains workflow metadata useful for monitoring daemons etc.
|
void |
Braindump.generateCode(ADag dag,
Job job) |
Method not implemented.
|
java.util.Collection<java.io.File> |
Braindump.generateCode(ADag dag,
java.util.Map<java.lang.String,java.lang.String> additionalEntries) |
Generates the code for the executable workflow in terms of a braindump
file that contains workflow metadata useful for monitoring daemons etc.
|
java.util.Collection<java.io.File> |
DAXReplicaStore.generateCode(ADag dag) |
Generates the notifications input file.
|
void |
DAXReplicaStore.generateCode(ADag dag,
Job job) |
Not implemented
|
java.util.Collection<java.io.File> |
MonitordNotify.generateCode(ADag dag) |
Generates the notifications input file.
|
void |
MonitordNotify.generateCode(ADag dag,
Job job) |
Not implemented
|
java.util.Collection<java.io.File> |
PBS.generateCode(ADag dag) |
Generates the code for the concrete workflow in the GRMS input format.
|
void |
PBS.generateCode(ADag dag,
Job job) |
Generates the code for a single job in the input format of the workflow
executor being used.
|
java.util.Collection<java.io.File> |
PMC.generateCode(ADag dag) |
Generates the code for the concrete workflow in the GRMS input format.
|
void |
PMC.generateCode(ADag dag,
Job job) |
Generates the code for a single job in the input format of the workflow
executor being used.
|
java.util.Collection<java.io.File> |
Shell.generateCode(ADag dag) |
Generates the code for the concrete workflow in the GRMS input format.
|
void |
Shell.generateCode(ADag dag,
Job job) |
Generates the code for a single job in the input format of the workflow
executor being used.
|
java.util.Collection<java.io.File> |
Stampede.generateCode(ADag dag) |
Generates the code for the executable workflow in terms of a braindump
file that contains workflow metadata useful for monitoring daemons etc.
|
void |
Stampede.generateCode(ADag dag,
Job job) |
Method not implemented.
|
java.util.Collection<java.io.File> |
Stork.generateCode(ADag dag) |
Generates the code for the concrete workflow in the input format of the
workflow executor being used.
|
void |
Stork.generateCode(ADag dag,
Job job) |
Generates the code for a single job in the Stork format.
|
protected void |
Stampede.generateEventsForDAXTask(java.io.PrintWriter writer,
ADag workflow,
Job job) |
Generates stampede events corresponding to jobs/tasks in the DAX
|
protected void |
Stampede.generateEventsForExecutableJob(java.io.PrintWriter writer,
ADag dag,
Job job) |
Generates stampede events corresponding to an executable job
|
protected java.lang.String |
Braindump.getSubmitHostname() |
Returns the submit hostname
|
void |
Abstract.initialize(PegasusBag bag) |
Initializes the Code Generator implementation.
|
void |
Braindump.initialize(PegasusBag bag) |
Initializes the Code Generator implementation.
|
void |
DAXReplicaStore.initialize(PegasusBag bag) |
Initializes the Code Generator implementation.
|
void |
MonitordNotify.initialize(PegasusBag bag) |
Initializes the Code Generator implementation.
|
void |
PBS.initialize(PegasusBag bag) |
Initializes the Code Generator implementation.
|
void |
PMC.initialize(PegasusBag bag) |
Initializes the Code Generator implementation.
|
void |
Shell.initialize(PegasusBag bag) |
Initializes the Code Generator implementation.
|
void |
Stampede.initialize(PegasusBag bag) |
Initializes the Code Generator implementation.
|
void |
Stork.initialize(PegasusBag bag) |
Initializes the Code Generator implementation.
|
private void |
Shell.initializeWriteHandle(java.lang.String filename) |
It initializes the write handle to the output file.
|
void |
Abstract.reset() |
Resets the Code Generator implementation.
|
void |
DAXReplicaStore.reset() |
Not implemented
|
void |
MonitordNotify.reset() |
Not implemented
|
void |
Stampede.reset() |
|
protected void |
Abstract.writeOutStampedeEvents(ADag workflow) |
Writes out the stampedeEventGenerator events for the workflow.
|