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<Double>
    getThroughputOutputPort()
     
    teetime.framework.InputPort<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

  • Constructor Details

    • AnalysisThroughputStage

      public AnalysisThroughputStage()
      Default constructor.

  • Method Details

    • execute

      protected void execute()
      Specified by:
      execute in class teetime.framework.AbstractStage

    • onStarting

      protected void onStarting()
      Overrides:
      onStarting in class teetime.framework.AbstractStage

    • getRecordsInputPort

      public teetime.framework.InputPort<IMonitoringRecord> getRecordsInputPort()

    • getTimestampsInputPort

      public teetime.framework.InputPort<Long> getTimestampsInputPort()

    • getRecordsOutputPort

      public teetime.framework.OutputPort<IMonitoringRecord> getRecordsOutputPort()

    • getThroughputOutputPort

      public teetime.framework.OutputPort<Double> getThroughputOutputPort()