Package kieker.analysis.architecture.trace.flow

Class TraceAggregationStage

java.lang.Object
teetime.framework.AbstractStage
kieker.analysis.architecture.trace.flow.TraceAggregationStage
public class TraceAggregationStage
extends teetime.framework.AbstractStage
This stage collects incoming traces for a specified amount of time. Any traces representing the same series of events will be used to calculate statistical informations like the average runtime of this kind of trace. Only one specimen of these traces containing this information will be forwarded from this filter. Statistical outliers regarding the runtime of the trace will be treated special and therefore send out as they are and will not be mixed with others.
Since:
1.9
Author:
Jan Waller, Florian Biss

  • Field Summary

    Fields inherited from class teetime.framework.AbstractStage

    logger

  • Constructor Summary

    Constructors 
    Constructor Description
    TraceAggregationStage​(java.util.concurrent.TimeUnit timeunit, long maxCollectionDuration)
    Creates a new instance of this class using the given parameters.

  • Method Summary

    Modifier and Type Method Description
    protected void execute()  
    void onTerminating()

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

    • TraceAggregationStage

      public TraceAggregationStage​(java.util.concurrent.TimeUnit timeunit, long maxCollectionDuration)
      Creates a new instance of this class using the given parameters.
      Parameters:
      timeunit - timeunit used in traces
      maxCollectionDuration - max duration of a trace

  • Method Details

    • execute

      protected void execute() throws java.lang.Exception
      Specified by:
      execute in class teetime.framework.AbstractStage
      Throws:
      java.lang.Exception

    • onTerminating

      public void onTerminating()
      Overrides:
      onTerminating in class teetime.framework.AbstractStage