kieker.analysisteetime.util.stage.trigger

Class ForwardOnTriggerStage<T>

java.lang.Object

teetime.framework.AbstractStage

kieker.analysisteetime.util.stage.trigger.ForwardOnTriggerStage<T>

Type Parameters:

T - Type of elements

All Implemented Interfaces:

teetime.stage.basic.ITransformation<T,T>

public class ForwardOnTriggerStage<T>
extends teetime.framework.AbstractStage
implements teetime.stage.basic.ITransformation<T,T>

Stage that queues all incoming elements and forwards them when receiving Trigger.

Since:

1.14

Author:

Sören Henning

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ForwardOnTriggerStage.SendStrategy

Field Summary

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
ForwardOnTriggerStage()
ForwardOnTriggerStage(ForwardOnTriggerStage.SendStrategy sendStrategy)

Method Summary

Modifier and Type	Method and Description
protected void	execute()
teetime.framework.InputPort<T>	getInputPort()
teetime.framework.OutputPort<T>	getOutputPort()
teetime.framework.InputPort<Trigger>	getTriggerInputPort()

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

ForwardOnTriggerStage

public ForwardOnTriggerStage()

ForwardOnTriggerStage

public ForwardOnTriggerStage(ForwardOnTriggerStage.SendStrategy sendStrategy)

Method Detail

execute

protected void execute()

Specified by:

execute in class teetime.framework.AbstractStage

getTriggerInputPort

public teetime.framework.InputPort<Trigger> getTriggerInputPort()

getInputPort

public teetime.framework.InputPort<T> getInputPort()

Specified by:

getInputPort in interface teetime.stage.basic.ITransformation<T,T>

getOutputPort

public teetime.framework.OutputPort<T> getOutputPort()

Specified by:

getOutputPort in interface teetime.stage.basic.ITransformation<T,T>