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

  • Constructor Details

  • Method Details

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