public interface FlowExecutor
Modifier and Type | Method and Description |
---|---|
void |
addExecutionFinishedCallback(ExecutionFinishedCallback callback)
Add a callback to notify when execution finishes
|
BaseExecutionEnvironment |
getExecutionEnvironment()
Return the execution environment object for this flow executor
|
Flow |
getFlow()
Get the flow to be executed
|
Logger |
getLogger()
Get the log in use
|
LoggingLevel |
getLoggingLevel()
Get the logging level to log at
|
Settings |
getSettings()
Convenience method for getting current settings - implementers should
delegate the the execution environment
|
void |
removeExecutionFinishedCallback(ExecutionFinishedCallback callback)
Remove a callback
|
void |
runParallel()
Run the flow by launching all start points in parallel
|
void |
runSequentially()
Run the flow sequentially (i.e.
|
void |
setExecutionEnvironment(BaseExecutionEnvironment env)
Set the execution environment to use
|
void |
setFlow(Flow flow)
Set the flow to be executed
|
void |
setLogger(Logger logger)
Set a log to use
|
void |
setLoggingLevel(LoggingLevel level)
Set the level to log at
|
void |
setSettings(Settings settings)
Convenience method for applying settings - implementers should delegate the
the execution environment
|
void |
stopProcessing()
Stop all processing
|
void |
waitUntilFinished()
Block until all steps are no longer busy
|
boolean |
wasStopped()
Returns true if execution was stopped via the stopProcessing() method
|
void setFlow(Flow flow)
flow
- the flow to executeFlow getFlow()
void setLogger(Logger logger)
logger
- the log tos useLogger getLogger()
void setLoggingLevel(LoggingLevel level)
level
- the level to log at (logging messages at this level or below
will be displayed in the log)LoggingLevel getLoggingLevel()
void setExecutionEnvironment(BaseExecutionEnvironment env)
env
- the execution environment to usevoid setSettings(Settings settings)
settings
- the settings to useSettings getSettings()
BaseExecutionEnvironment getExecutionEnvironment()
void runSequentially() throws WekaException
WekaException
- if a problem occurs during executionvoid runParallel() throws WekaException
WekaException
- if a problem occurs during executionvoid waitUntilFinished()
void stopProcessing()
boolean wasStopped()
void addExecutionFinishedCallback(ExecutionFinishedCallback callback)
callback
- the callback to notifyvoid removeExecutionFinishedCallback(ExecutionFinishedCallback callback)
callback
- the callback to remove