public abstract class BaseStep extends java.lang.Object implements Step, BaseStepExtender, java.io.Serializable
Constructor and Description |
---|
BaseStep()
Constructor
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
environmentSubstitute(java.lang.String source)
Substitute the values of environment variables in the given string
|
java.lang.String |
getCustomEditorForStep()
Return the fully qualified name of a custom editor component (JComponent)
to use for editing the properties of the step.
|
Defaults |
getDefaultSettings()
Get default settings for the step (if any).
|
java.util.Map<java.lang.String,java.lang.String> |
getInteractiveViewers()
When running in a graphical execution environment a step can make one or
more popup Viewer components available.
|
java.util.Map<java.lang.String,StepInteractiveViewer> |
getInteractiveViewersImpls()
An alternative to getStepInteractiveViewers that returns a Map of
instantiated StepInteractiveViewer objects.
|
java.lang.String |
getName()
Get the name of this step
|
StepManager |
getStepManager()
Get the step manager for this step
|
java.lang.String |
globalInfo()
Attempt to get default "about" information for this step by grabbing the
toolTip from the KFStep annotation.
|
boolean |
isResourceIntensive()
Get whether this step is resource intensive (cpu/memory) or not.
|
boolean |
isStopRequested()
Convenience method that calls
StepManager.isStopRequested() |
Instances |
outputStructureForConnectionType(java.lang.String connectionName)
If possible, get the output structure for the named connection type as a
header-only set of instances.
|
Instances |
outputStructureForConnectionType(java.lang.String connectionName,
Environment env)
If possible, get the output structure for the named connection type as a
header-only set of instances.
|
void |
processIncoming(Data data)
Process an incoming data payload (if the step accepts incoming connections)
|
void |
setName(java.lang.String name)
Set the name of this step
|
void |
setStepIsResourceIntensive(boolean isResourceIntensive)
Set whether this step is resource intensive (cpu/memory) or not.
|
void |
setStepManager(StepManager manager)
Set the step manager for this step
|
void |
setStepMustRunSingleThreaded(boolean mustRunSingleThreaded)
Set whether this step must run single threaded.
|
void |
start()
Start processing.
|
boolean |
stepMustRunSingleThreaded()
Get whether this step must run single threaded.
|
void |
stop()
Request that processing be stopped.
|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getIncomingConnectionTypes, getOutgoingConnectionTypes, stepInit
getIncomingConnectionTypes, getOutgoingConnectionTypes, stepInit
public java.lang.String globalInfo()
@NotPersistable public StepManager getStepManager()
getStepManager
in interface Step
public void setStepManager(StepManager manager)
setStepManager
in interface Step
manager
- the step manager to use@ProgrammaticProperty public void setStepIsResourceIntensive(boolean isResourceIntensive)
isResourceIntensive
- true if this step is resource intensive.public boolean isResourceIntensive()
@ProgrammaticProperty public void setStepMustRunSingleThreaded(boolean mustRunSingleThreaded)
mustRunSingleThreaded
- true if the step must run single threadedpublic boolean stepMustRunSingleThreaded()
public java.lang.String getName()
@ProgrammaticProperty public void setName(java.lang.String name)
public void start() throws WekaException
start
in interface BaseStepExtender
start
in interface Step
WekaException
- if a problem occurspublic void stop()
isStopRequested()
periodically to see if they should stop
processing.public Instances outputStructureForConnectionType(java.lang.String connectionName) throws WekaException
outputStructureForConnectionType
in interface Step
connectionName
- the name of the connection type to get the output
structure forWekaException
- if a problem occurspublic Instances outputStructureForConnectionType(java.lang.String connectionName, Environment env) throws WekaException
outputStructureForConnectionType
in interface Step
connectionName
- the name of the connection type to get the output
structure forenv
- Environment variablesWekaException
- if a problem occurspublic void processIncoming(Data data) throws WekaException
processIncoming
in interface BaseStepExtender
processIncoming
in interface Step
data
- the payload to processWekaException
- if a problem occurspublic java.lang.String getCustomEditorForStep()
getCustomEditorForStep
in interface Step
public java.util.Map<java.lang.String,java.lang.String> getInteractiveViewers()
getInteractiveViewers
in interface Step
public java.util.Map<java.lang.String,StepInteractiveViewer> getInteractiveViewersImpls()
getInteractiveViewersImpls
in interface Step
public Defaults getDefaultSettings()
getDefaultSettings
in interface Step
public boolean isStopRequested()
StepManager.isStopRequested()
public java.lang.String environmentSubstitute(java.lang.String source)
source
- the source string to substitute in