kieker.analysisteetime.util.stage

Class AbstractBiCombinerStage<I,J>

java.lang.Object

teetime.framework.AbstractStage

kieker.analysisteetime.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 and 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 and Description
AbstractBiCombinerStage()

Method Summary

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

inputPort1

protected final teetime.framework.InputPort<I> inputPort1

inputPort2

protected final teetime.framework.InputPort<J> inputPort2

Constructor Detail

AbstractBiCombinerStage

public AbstractBiCombinerStage()

Method Detail

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)