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 final teetime.framework.InputPort<I>
    inputPort1
     
    protected final 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()
     
    final teetime.framework.InputPort<I>
    getInputPort1()
     
    final 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

    • AbstractBiCombinerStage

      public AbstractBiCombinerStage()

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