teetime.stage

Class StatelessCounter<T>

java.lang.Object

teetime.framework.AbstractStage

teetime.stage.StatelessCounter<T>

All Implemented Interfaces:

ITransformation<T,T>

public class StatelessCounter<T>
extends AbstractStage
implements ITransformation<T,T>

Field Summary

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
StatelessCounter()

Method Summary

Modifier and Type	Method and Description
protected void	execute() Contains the logic of this stage and is invoked (possibly multiple times) by the framework.
InputPort<T>	getInputPort()
OutputPort<T>	getOutputPort()

Methods inherited from class teetime.framework.AbstractStage

abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, getTerminationStrategy, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

StatelessCounter

public StatelessCounter()

Method Detail

execute

protected void execute()

Description copied from class: AbstractStage

Contains the logic of this stage and is invoked (possibly multiple times) by the framework.

Specified by:

execute in class AbstractStage

getInputPort

public InputPort<T> getInputPort()

Specified by:

getInputPort in interface ITransformation<T,T>

getOutputPort

public OutputPort<T> getOutputPort()

Specified by:

getOutputPort in interface ITransformation<T,T>