kieker.analysisteetime.plugin.filter.forward

Class AnalysisThroughputFilter

java.lang.Object

teetime.framework.AbstractStage

kieker.analysisteetime.plugin.filter.forward.AnalysisThroughputFilter

public class AnalysisThroughputFilter
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 and Description
AnalysisThroughputFilter() Default constructor.

Method Summary

Modifier and Type	Method and Description
protected void	execute()
teetime.framework.OutputPort<java.lang.Long>	getRecordsCountOutputPort()
teetime.framework.InputPort<IMonitoringRecord>	getRecordsInputPort()
teetime.framework.OutputPort<IMonitoringRecord>	getRecordsOutputPort()
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

Constructor Detail

AnalysisThroughputFilter

public AnalysisThroughputFilter()

Default constructor.

Method Detail

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<java.lang.Long> getTimestampsInputPort()

getRecordsOutputPort

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

getRecordsCountOutputPort

public teetime.framework.OutputPort<java.lang.Long> getRecordsCountOutputPort()