weka.knowledgeflow.steps

Class StatsCalculator

java.lang.Object

weka.knowledgeflow.steps.BaseStep

weka.knowledgeflow.steps.StatsCalculator

All Implemented Interfaces:

java.io.Serializable, BaseStepExtender, Step

@KFStep(name="StatsCalculator",
        category="Examples",
        toolTipText="Compute summary stats for an attribute",
        iconPath="weka/gui/knowledgeflow/icons/DiamondPlain.gif")
public class StatsCalculator
extends BaseStep

Simple example batch processing step. Computes stats for a user-specified attribute

Version:

$Revision: $

Author:

Mark Hall (mhall{[at]}pentaho{[dot]}com)

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StatsCalculator()

Method Summary

Modifier and Type	Method and Description
java.lang.String	getAttName() Get the name of the attribute to compute stats for
java.util.List<java.lang.String>	getIncomingConnectionTypes() Get a list of acceptable incoming connection types
java.util.List<java.lang.String>	getOutgoingConnectionTypes() Get a list of outgoing connection types
void	processIncoming(Data data) Process incoming data
void	setAttName(java.lang.String attName) Set the name of the attribute to compute stats for
void	stepInit() Initialize the step.

Methods inherited from class weka.knowledgeflow.steps.BaseStep

environmentSubstitute, getCustomEditorForStep, getDefaultSettings, getInteractiveViewers, getInteractiveViewersImpls, getName, getStepManager, globalInfo, isResourceIntensive, isStopRequested, outputStructureForConnectionType, setName, setStepIsResourceIntensive, setStepManager, start, stop

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StatsCalculator

public StatsCalculator()

Method Detail

stepInit

public void stepInit()
              throws WekaException

Initialize the step.

Throws:

WekaException - if no attribute name is specified

getIncomingConnectionTypes

public java.util.List<java.lang.String> getIncomingConnectionTypes()

Get a list of acceptable incoming connection types

Returns:

a list of acceptable incoming connection types

getOutgoingConnectionTypes

public java.util.List<java.lang.String> getOutgoingConnectionTypes()

Get a list of outgoing connection types

Returns:

a list of outgoing connection types

setAttName

public void setAttName(java.lang.String attName)

Set the name of the attribute to compute stats for

Parameters:

attName - the name of the attribute to compute stats for

getAttName

public java.lang.String getAttName()

Get the name of the attribute to compute stats for

Returns:

the name of the attribute to compute stats for

processIncoming

public void processIncoming(Data data)
                     throws WekaException

Process incoming data

Specified by:

processIncoming in interface BaseStepExtender

Specified by:

processIncoming in interface Step

Overrides:

processIncoming in class BaseStep

Parameters:

data - the payload to process

Throws:

WekaException - if a problem occurs