public interface FlowRunner
Modifier and Type | Method and Description |
---|---|
void |
awaitCompletion()
Blocks until the flow execution is complete.
|
void |
awaitCompletion(long timeout,
java.util.concurrent.TimeUnit unit)
Blocks until the flow execution is complete.
|
FlowRunner |
onStatusChanged(FlowStatusListener listener)
Sets the status change listener on the flowrunner object
|
RunFlowResponse |
runFlow(java.lang.String flow)
Runs the entire flow, with full defaults
|
RunFlowResponse |
runFlow(java.lang.String flow,
java.util.List<java.lang.String> steps)
Runs the flow, with a specific set of steps, with all defaults from step
|
RunFlowResponse |
runFlow(java.lang.String flow,
java.util.List<java.lang.String> steps,
java.lang.String jobId)
Runs the flow, with a specific set of steps, with all custom settings
|
RunFlowResponse |
runFlow(java.lang.String flow,
java.util.List<java.lang.String> steps,
java.lang.String jobId,
java.util.Map<java.lang.String,java.lang.Object> options)
Runs the flow, with a specific set of steps, with all custom settings
|
RunFlowResponse |
runFlow(java.lang.String flow,
java.util.List<java.lang.String> steps,
java.lang.String jobId,
java.util.Map<java.lang.String,java.lang.Object> options,
java.util.Map<java.lang.String,java.lang.Object> stepConfig)
Runs the flow, with a specific set of steps, with all custom settings
|
RunFlowResponse |
runFlow(java.lang.String flow,
java.lang.String jobId)
Runs the flow, with a specific set of steps, with all custom settings
|
RunFlowResponse |
runFlow(java.lang.String flow,
java.lang.String jobId,
java.util.Map<java.lang.String,java.lang.Object> options)
Runs the flow, with a specific set of steps, with all custom settings
|
void |
stopJob(java.lang.String jobId)
Runs the flow.
|
RunFlowResponse runFlow(java.lang.String flow, java.lang.String jobId)
flow
- the flow to runjobId
- the jobid to be used for the flowRunFlowResponse runFlow(java.lang.String flow, java.util.List<java.lang.String> steps, java.lang.String jobId)
flow
- the flow to runsteps
- the steps in the flow to runjobId
- the jobid to be used for the flowRunFlowResponse runFlow(java.lang.String flow, java.lang.String jobId, java.util.Map<java.lang.String,java.lang.Object> options)
flow
- the flow to runjobId
- the jobid to be used for the flowoptions
- the key/value options to be passedRunFlowResponse runFlow(java.lang.String flow, java.util.List<java.lang.String> steps, java.lang.String jobId, java.util.Map<java.lang.String,java.lang.Object> options)
flow
- the flow to runsteps
- the steps in the flow to runjobId
- the jobid to be used for the flowoptions
- the key/value options to be passedRunFlowResponse runFlow(java.lang.String flow, java.util.List<java.lang.String> steps, java.lang.String jobId, java.util.Map<java.lang.String,java.lang.Object> options, java.util.Map<java.lang.String,java.lang.Object> stepConfig)
flow
- the flow to runsteps
- the steps in the flow to runjobId
- the jobid to be used for the flowoptions
- the key/value options to be passedstepConfig
- the key/value config to override the running of the stepRunFlowResponse runFlow(java.lang.String flow, java.util.List<java.lang.String> steps)
flow
- the flow to runsteps
- the steps in the flow to runRunFlowResponse runFlow(java.lang.String flow)
flow
- the flow to runvoid stopJob(java.lang.String jobId)
jobId
- the id of the running flowvoid awaitCompletion()
void awaitCompletion(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException, java.util.concurrent.TimeoutException
timeout
- the maximum time to waitunit
- the time unit of the timeout argumentjava.lang.InterruptedException
- if interrupted while waitingjava.util.concurrent.TimeoutException
- if times outFlowRunner onStatusChanged(FlowStatusListener listener)
listener
- - the listener for when the status changes