teetime.stage

Class ElementThroughputMeasuringStage<T>

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<I>

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

teetime.stage.basic.AbstractFilter<T>

teetime.stage.ElementThroughputMeasuringStage<T>

All Implemented Interfaces:

ITransformation<T,T>

public final class ElementThroughputMeasuringStage<T>
extends AbstractFilter<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
ElementThroughputMeasuringStage()

Method Summary

Modifier and Type	Method and Description
protected void	execute(T element) Contains the logic of this stage and is invoked (possibly multiple times) by the framework.
List<Long>	getThroughputs()
InputPort<Long>	getTriggerInputPort()
void	onStarting() Event that is triggered, if all of the following conditions hold: after passing the validation phase and after the threads are ready-to-run and just before the threads execute any stage.

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, 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

Methods inherited from interface teetime.stage.basic.ITransformation

getInputPort

Constructor Detail

ElementThroughputMeasuringStage

public ElementThroughputMeasuringStage()

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

onStarting

public void onStarting()

Description copied from class: AbstractStage

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

• after passing the validation phase and
• after the threads are ready-to-run and
• just before the threads execute any stage.

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

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

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:

onStarting in class AbstractStage

getThroughputs

public List<Long> getThroughputs()

getTriggerInputPort

public InputPort<Long> getTriggerInputPort()