Package kieker.analysis.util.stage.trigger

Class ForwardOnTriggerStage<T>

java.lang.Object
teetime.framework.AbstractStage
kieker.analysis.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 Description
    static class  ForwardOnTriggerStage.SendStrategy  

  • Field Summary

    Fields inherited from class teetime.framework.AbstractStage

    logger

  • Constructor Summary

    Constructors 
    Constructor Description
    ForwardOnTriggerStage()  
    ForwardOnTriggerStage​(ForwardOnTriggerStage.SendStrategy sendStrategy)  

  • Method Summary

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