Package kieker.analysis.util.stage

Class AbstractBiCombinerStage<I,​J>

java.lang.Object
teetime.framework.AbstractStage
kieker.analysis.util.stage.AbstractBiCombinerStage<I,​J>
Type Parameters:
I - Type of elements at first input port
J - Type of elements at second input port
Direct Known Subclasses:
JAXBMarshalStage
public abstract class AbstractBiCombinerStage<I,​J>
extends teetime.framework.AbstractStage
Abstract stage that combines the elements from its two input ports.
Since:
1.14
Author:
Sören Henning

  • Field Summary

    Fields 
    Modifier and Type Field Description
    protected teetime.framework.InputPort<I> inputPort1  
    protected teetime.framework.InputPort<J> inputPort2  

    Fields inherited from class teetime.framework.AbstractStage

    logger

  • Constructor Summary

    Constructors 
    Constructor Description
    AbstractBiCombinerStage()  

  • Method Summary

    Modifier and Type Method Description
    protected abstract void combine​(I element1, J element2)  
    protected void execute()  
    teetime.framework.InputPort<I> getInputPort1()  
    teetime.framework.InputPort<J> getInputPort2()  

    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

  • Field Details

    • inputPort1

      protected final teetime.framework.InputPort<I> inputPort1

    • inputPort2

      protected final teetime.framework.InputPort<J> inputPort2

  • Constructor Details

  • Method Details

    • getInputPort1

      public final teetime.framework.InputPort<I> getInputPort1()

    • getInputPort2

      public final teetime.framework.InputPort<J> getInputPort2()

    • execute

      protected void execute()
      Specified by:
      execute in class teetime.framework.AbstractStage

    • combine

      protected abstract void combine​(I element1, J element2)