Package kieker.analysis.util.stage.trigger

Class TriggerEveryXthStage

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<I>

teetime.stage.basic.AbstractTransformation<Object,Trigger>

kieker.analysis.util.stage.trigger.TriggerEveryXthStage

All Implemented Interfaces:

teetime.stage.basic.ITransformation<Object,Trigger>

public class TriggerEveryXthStage
extends teetime.stage.basic.AbstractTransformation<Object,Trigger>

This stage sends a Trigger after every x-th incoming object.

Since:

1.14

Author:

Sören Henning

Field Summary

Fields inherited from class teetime.stage.basic.AbstractTransformation

outputPort

Fields inherited from class teetime.framework.AbstractConsumerStage

inputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor	Description
TriggerEveryXthStage(int threshold)

Method Summary

Modifier and Type	Method	Description
protected void	execute(Object object)

Methods inherited from class teetime.stage.basic.AbstractTransformation

getOutputPort

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

Methods inherited from interface teetime.stage.basic.ITransformation

getInputPort

Constructor Details

TriggerEveryXthStage

public TriggerEveryXthStage(int threshold)

Method Details

execute

protected void execute(Object object)

Specified by:

execute in class teetime.framework.AbstractConsumerStage<Object>