R
- the type of the final outputpublic class Pipeline<R> extends java.lang.Object implements StandardWorkflow<R,Bridge<?,?>>
Constructor and Description |
---|
Pipeline() |
Modifier and Type | Method and Description |
---|---|
Pipeline<R> |
addWorkflow(StandardWorkflow workflow) |
Pipeline<R> |
addWorkflow(StandardWorkflow workflow,
OutputCoordinator coordinator) |
Pipeline<R> |
clearCoordinators() |
Pipeline<R> |
clearWorkflows() |
R |
getResults()
Get the results of this workflow as an object
|
StandardWorkflow<R,Bridge<?,?>> |
init()
Prepares the workflow for a new execution
|
void |
run() |
StandardWorkflow<R,Bridge<?,?>> |
setBridge(Bridge<?,?> bridge)
Links this workflow to a bridge
|
Pipeline<R> |
setCoordinator(OutputCoordinator coordinator,
int step) |
Pipeline |
setParameters(java.util.HashMap<java.lang.String,java.lang.Object> parameters)
Sets parameters for this workflow
|
public Pipeline<R> addWorkflow(StandardWorkflow workflow)
public Pipeline<R> addWorkflow(StandardWorkflow workflow, OutputCoordinator coordinator)
public Pipeline<R> setCoordinator(OutputCoordinator coordinator, int step)
public StandardWorkflow<R,Bridge<?,?>> init()
StandardWorkflow
init
in interface StandardWorkflow<R,Bridge<?,?>>
public StandardWorkflow<R,Bridge<?,?>> setBridge(Bridge<?,?> bridge)
StandardWorkflow
setBridge
in interface StandardWorkflow<R,Bridge<?,?>>
bridge
- The bridgepublic Pipeline setParameters(java.util.HashMap<java.lang.String,java.lang.Object> parameters)
StandardWorkflow
setParameters
in interface StandardWorkflow<R,Bridge<?,?>>
parameters
- An hash map of Name, Value pairspublic R getResults()
StandardWorkflow
getResults
in interface StandardWorkflow<R,Bridge<?,?>>
public void run()
run
in interface java.lang.Runnable