public class StepInjectorFlowRunner extends FlowRunner
FlowRunner.SimpleLogger| Constructor and Description |
|---|
StepInjectorFlowRunner() |
| Modifier and Type | Method and Description |
|---|---|
Step |
findStep(java.lang.String stepName,
java.lang.Class stepClass)
Find a step in the flow
|
void |
injectStreaming(Data toInject,
Step target,
boolean lastData)
Inject streaming data into the target step in the flow
|
void |
injectWithExecutionFinishedCallback(Data toInject,
ExecutionFinishedCallback callback,
Step target)
Inject data into the flow
|
void |
reset()
Rest the runner
|
addExecutionFinishedCallback, flowBusy, getExecutionEnvironment, getFlow, getLaunchStartPointsSequentially, getLogger, getLoggingLevel, getSettings, main, removeExecutionFinishedCallback, run, runParallel, runSequentially, setExecutionEnvironment, setFlow, setLaunchStartPointsSequentially, setLogger, setLoggingLevel, setSettings, stopProcessing, waitUntilFinished, wasStoppedpublic void reset()
public void injectWithExecutionFinishedCallback(Data toInject, ExecutionFinishedCallback callback, Step target) throws WekaException
toInject - the data to injectcallback - a ExecutionFinishedCallback to notify when
execution completestarget - the target Step to inject toWekaException - if a problem occurspublic Step findStep(java.lang.String stepName, java.lang.Class stepClass) throws WekaException
stepName - the name of the Step to findstepClass - the class of the step to findWekaException - if the named step is not in the flow or the found
step is not of the supplied classpublic void injectStreaming(Data toInject, Step target, boolean lastData) throws WekaException
toInject - a streaming Data object to injecttarget - the target step to inject tolastData - true if this is the last piece of data in the streamWekaException - if a problem occurs