Package kieker.analysis.architecture.trace

Class ValidEventRecordTraceCounter

java.lang.Object
teetime.framework.AbstractStage
teetime.framework.AbstractConsumerStage<TraceEventRecords>
kieker.analysis.architecture.trace.ValidEventRecordTraceCounter
public class ValidEventRecordTraceCounter
extends teetime.framework.AbstractConsumerStage<TraceEventRecords>
This sink counts and reports the number of incoming valid TraceEventRecords.
Since:
1.15
Author:
Andre van Hoorn, Reiner Jung -- ported to teetime

  • Field Summary

    Fields inherited from class teetime.framework.AbstractConsumerStage

    inputPort

    Fields inherited from class teetime.framework.AbstractStage

    logger

  • Constructor Summary

    Constructors 
    Constructor Description
    ValidEventRecordTraceCounter()
    Creates a new instance of this class using the given parameters.

  • Method Summary

    Modifier and Type Method Description
    protected void execute​(TraceEventRecords trace)  
    long getLastTraceIdSuccess()
    Delivers the ID of the last trace which has been processed successfully.
    int getSuccessCount()
    Delivers the number of traces which have been processed successfully.
    int getTotalCount()
    Delivers the total number of traces which have been processed.
    protected void onTerminating()  

    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

  • Constructor Details

  • Method Details

    • execute

      protected void execute​(TraceEventRecords trace) throws java.lang.Exception
      Specified by:
      execute in class teetime.framework.AbstractConsumerStage<TraceEventRecords>
      Throws:
      java.lang.Exception

    • onTerminating

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

    • getSuccessCount

      public final int getSuccessCount()
      Delivers the number of traces which have been processed successfully.
      Returns:
      The number of traces.

    • getTotalCount

      public final int getTotalCount()
      Delivers the total number of traces which have been processed.
      Returns:
      The number of traces.

    • getLastTraceIdSuccess

      public final long getLastTraceIdSuccess()
      Delivers the ID of the last trace which has been processed successfully.
      Returns:
      The trace ID.