weka.knowledgeflow.steps

Class RoundRobin

java.lang.Object

weka.knowledgeflow.steps.BaseStep

weka.knowledgeflow.steps.RoundRobin

All Implemented Interfaces:

java.io.Serializable, BaseStepExtender, Step

@KFStep(name="RoundRobin",
        category="Examples",
        toolTipText="Round robin instances to outputs",
        iconPath="weka/gui/knowledgeflow/icons/DiamondPlain.gif")
public class RoundRobin
extends BaseStep

Simple example step that demonstrates stream processing - round robins incoming instances among the outgoing connections.

Version:

$Revision: $

Author:

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RoundRobin()

Method Summary

Modifier and Type	Method and Description
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	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

RoundRobin

public RoundRobin()

Method Detail

stepInit

public void stepInit()
              throws WekaException

Initialize the step

Throws:

WekaException - if a problem occurs

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

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