teetime.stage

Class Counter<T>

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<I>

teetime.stage.basic.AbstractTransformation<E,E>

teetime.stage.basic.AbstractFilter<T>

teetime.stage.Counter<T>

All Implemented Interfaces:

ITransformation<T,T>, ITaskFarmDuplicable<T,T>

public class Counter<T>
extends AbstractFilter<T>
implements ITaskFarmDuplicable<T,T>

Field Summary

Fields inherited from class teetime.stage.basic.AbstractTransformation

outputPort

Fields inherited from class teetime.framework.AbstractConsumerStage

inputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
Counter()

Method Summary

Modifier and Type	Method and Description
ITaskFarmDuplicable<T,T>	duplicate() Creates a new instance of the enclosed stage.
protected void	execute(T element) Contains the logic of this stage and is invoked (possibly multiple times) by the framework.
int	getNumElementsPassed()
void	onTerminating() Event that is triggered, if all of the following conditions hold: while executing the P&F configuration and after receiving the termination signal.

Methods inherited from class teetime.stage.basic.AbstractTransformation

getOutputPort

Methods inherited from class teetime.framework.AbstractConsumerStage

createInputPort, execute, getInputPort

Methods inherited from class teetime.framework.AbstractStage

abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, getTerminationStrategy, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, 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

Methods inherited from interface teetime.stage.taskfarm.ITaskFarmDuplicable

getInputPort, getOutputPort

Constructor Detail

Counter

public Counter()

Method Detail

execute

protected void execute(T element)

Description copied from class: AbstractConsumerStage

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

Specified by:

execute in class AbstractConsumerStage<T>

Parameters:

element - the next non-null element from the (only) input port of this stage

onTerminating

public void onTerminating()

Description copied from class: AbstractStage

Event that is triggered, if all of the following conditions hold:

• while executing the P&F configuration and
• after receiving the termination signal.

If stage developers want to override this method, they must always call the super implementation last:

 @Override
 protected void onTerminating() {
        // insert your code here
        super.onTerminating();
 }
 

To throw a checked exception, wrap it to an unchecked exception, e.g. to an IllegalArgumentException.IllegalArgumentException(String, Throwable). Always pass the original exception to the new unchecked exception to allow easy debugging.

Overrides:

onTerminating in class AbstractStage

getNumElementsPassed

public int getNumElementsPassed()

duplicate

public ITaskFarmDuplicable<T,T> duplicate()

Description copied from interface: ITaskFarmDuplicable

Creates a new instance of the enclosed stage.

Specified by:

duplicate in interface ITaskFarmDuplicable<T,T>

Returns:

new instance