kieker.analysis.trace

Class ValidEventRecordTraceCounter

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<TraceEventRecords>

kieker.analysis.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 and Description
ValidEventRecordTraceCounter() Creates a new instance of this class using the given parameters.

Method Summary

Modifier and Type	Method and 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 Detail

ValidEventRecordTraceCounter

public ValidEventRecordTraceCounter()

Creates a new instance of this class using the given parameters.

Parameters:

logInvalidTraces - if true invalid traces are logged in the error log

Method Detail

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.