@KFStep(name="Job", category="Flow", toolTipText="Execute a flow as a \'job\' and wait for it to finish", iconPath="weka/gui/knowledgeflow/icons/Job.gif") public class Job extends BaseStep
Constructor and Description |
---|
Job() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getCustomEditorForStep()
Get the custom editor for this step
|
java.io.File |
getFlowFile() |
java.util.List<java.lang.String> |
getIncomingConnectionTypes()
Get a list of incoming connection types that this step can accept.
|
java.util.List<java.lang.String> |
getOutgoingConnectionTypes()
Get a list of outgoing connection types that this step can produce.
|
void |
processIncoming(Data data)
Process an incoming data payload (if the step accepts incoming connections)
|
void |
setFlowFile(java.io.File flowFile) |
void |
start()
Start processing.
|
void |
stepInit()
Initialize the step.
|
environmentSubstitute, getDefaultSettings, getInteractiveViewers, getInteractiveViewersImpls, getName, getStepManager, globalInfo, isResourceIntensive, isStopRequested, outputStructureForConnectionType, outputStructureForConnectionType, setName, setStepIsResourceIntensive, setStepManager, setStepMustRunSingleThreaded, stepMustRunSingleThreaded, stop
@FilePropertyMetadata(fileChooserDialogType=0, directoriesOnly=false) @OptionMetadata(displayName="Flow file", description="The flow to execute", displayOrder=0) public void setFlowFile(java.io.File flowFile)
public java.io.File getFlowFile()
public void stepInit() throws WekaException
Step
WekaException
- if a problem occurs during initializationpublic void start() throws WekaException
BaseStep
start
in interface BaseStepExtender
start
in interface Step
start
in class BaseStep
WekaException
- if a problem occurspublic void processIncoming(Data data) throws WekaException
BaseStep
processIncoming
in interface BaseStepExtender
processIncoming
in interface Step
processIncoming
in class BaseStep
data
- the payload to processWekaException
- if a problem occurspublic java.util.List<java.lang.String> getIncomingConnectionTypes()
Step
public java.util.List<java.lang.String> getOutgoingConnectionTypes()
Step
public java.lang.String getCustomEditorForStep()
getCustomEditorForStep
in interface Step
getCustomEditorForStep
in class BaseStep