@KFStep(name="Block", category="Flow", toolTipText="Block until a specific step has finished procesing", iconPath="weka/gui/knowledgeflow/icons/DiamondPlain.gif") public class Block extends BaseStep
Constructor and Description |
---|
Block() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getCustomEditorForStep()
Get the fully qualified class name of the custom editor for this step
|
java.util.List<java.lang.String> |
getIncomingConnectionTypes()
Get a list of incoming connection types that this step can accept at this
time
|
java.util.List<java.lang.String> |
getOutgoingConnectionTypes()
Get a list of outgoing connection types that this step can produce at this
time
|
java.lang.String |
getStepToWaitFor()
Get the step to wait for
|
void |
processIncoming(Data data)
Process incoming data
|
void |
setStepToWaitFor(java.lang.String stepToWaitFor)
Set the step to wait for
|
void |
stepInit()
Initialize the step
|
environmentSubstitute, getDefaultSettings, getInteractiveViewers, getInteractiveViewersImpls, getName, getStepManager, globalInfo, isResourceIntensive, isStopRequested, outputStructureForConnectionType, outputStructureForConnectionType, setName, setStepIsResourceIntensive, setStepManager, setStepMustRunSingleThreaded, start, stepMustRunSingleThreaded, stop
@OptionMetadata(displayName="Wait until this step has completed", description="This step will prevent data from passing downstream until the specified step has finished processing") public void setStepToWaitFor(java.lang.String stepToWaitFor)
stepToWaitFor
- the step to wait forpublic java.lang.String getStepToWaitFor()
public void stepInit() throws WekaException
WekaException
- if a problem occurspublic void processIncoming(Data data) throws WekaException
processIncoming
in interface BaseStepExtender
processIncoming
in interface Step
processIncoming
in class BaseStep
data
- the data to processWekaException
- if a problem occurspublic java.util.List<java.lang.String> getIncomingConnectionTypes()
public java.util.List<java.lang.String> getOutgoingConnectionTypes()
public java.lang.String getCustomEditorForStep()
getCustomEditorForStep
in interface Step
getCustomEditorForStep
in class BaseStep