@KFStep(name="WriteToWekaLog", category="Flow", toolTipText="Write data to the log", iconPath="weka/gui/knowledgeflow/icons/WriteWekaLog.gif") public class WriteWekaLog extends BaseStep
Constructor and Description |
---|
WriteWekaLog() |
Modifier and Type | Method and Description |
---|---|
java.util.List<java.lang.String> |
getIncomingConnectionTypes()
Get a list of acceptable incoming connection types (at this point in time)
|
java.lang.String |
getIncrementalLoggingFrequency()
Get how frequently to write an incremental data point to the log
|
LoggingLevel |
getLoggingLevel()
Get the logging level to use
|
java.util.List<java.lang.String> |
getOutgoingConnectionTypes()
Get currently generatable outgoing connection types
|
void |
processIncoming(Data data)
Process an incoming piece of data
|
void |
setIncrementalLoggingFrequency(java.lang.String frequency)
Set how frequently to write an incremental data point to the log
|
void |
setLoggingLevel(LoggingLevel level)
Set the logging level to use
|
void |
stepInit()
Initialize the step
|
environmentSubstitute, getCustomEditorForStep, getDefaultSettings, getInteractiveViewers, getInteractiveViewersImpls, getName, getStepManager, globalInfo, isResourceIntensive, isStopRequested, outputStructureForConnectionType, outputStructureForConnectionType, setName, setStepIsResourceIntensive, setStepManager, setStepMustRunSingleThreaded, start, stepMustRunSingleThreaded, stop
@OptionMetadata(displayName="Logging level", description="The level at which to write log messages", displayOrder=1) public void setLoggingLevel(LoggingLevel level)
level
- the level to usepublic LoggingLevel getLoggingLevel()
@OptionMetadata(displayName="Incremental logging frequency", description="How often to write an incremental/streaming data point to the log", displayOrder=2) public void setIncrementalLoggingFrequency(java.lang.String frequency)
frequency
- the frequency (in data points) to write to the logpublic java.lang.String getIncrementalLoggingFrequency()
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 payload to processWekaException
- if a problem occurspublic java.util.List<java.lang.String> getIncomingConnectionTypes()
public java.util.List<java.lang.String> getOutgoingConnectionTypes()