Package kieker.analysis.generic

Class AnalysisThroughputStage

java.lang.Object
teetime.framework.AbstractStage
kieker.analysis.generic.AnalysisThroughputStage
public class AnalysisThroughputStage
extends teetime.framework.AbstractStage
An instance of this class computes the throughput in terms of the number of objects received per time unit.
Since:
1.8
Author:
Jan Waller, Lars Bluemke

  • Field Summary

    Fields inherited from class teetime.framework.AbstractStage

    logger

  • Constructor Summary

    Constructors 
    Constructor Description
    AnalysisThroughputStage()
    Default constructor.

  • Method Summary

    Modifier and Type Method Description
    protected void execute()  
    teetime.framework.InputPort<IMonitoringRecord> getRecordsInputPort()  
    teetime.framework.OutputPort<IMonitoringRecord> getRecordsOutputPort()  
    teetime.framework.OutputPort<java.lang.Double> getThroughputOutputPort()  
    teetime.framework.InputPort<java.lang.Long> getTimestampsInputPort()  
    protected void onStarting()  

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