teetime.stage.basic.merger

Class Merger<T>

java.lang.Object

teetime.framework.AbstractStage

teetime.stage.basic.merger.Merger<T>

Direct Known Subclasses:

DynamicMerger

public class Merger<T>
extends AbstractStage

This stage merges data from the input ports, by taking elements according to the chosen merge strategy and by putting them to the output port. New input ports can be created by calling getNewInputPort().

Since:

1.0

Author:

Christian Wulf

Stage sketch:

   +---------------------------+
   |                           |
 +---+                         |
 |   | +-----------+           |
 +---+             |           |
   |               |           |
                   |         +---+
   .      . . . ---+-------> |   |
                   |         +---+
   |               |           |
 +---+             |           |
 |   | +-----------+           |
 +---+                         |
   |                           |
   +---------------------------+


               

Field Summary

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
Merger() A merger using the NonBlockingFiniteRoundRobinStrategy}.
Merger(IMergerStrategy strategy)

Method Summary

Modifier and Type	Method and Description
protected void	execute() Contains the logic of this stage and is invoked (possibly multiple times) by the framework.
List<InputPort<?>>	getInputPorts()
InputPort<T>	getNewInputPort()
OutputPort<T>	getOutputPort()
IMergerStrategy	getStrategy()
void	setStrategy(IMergerStrategy strategy)

Methods inherited from class teetime.framework.AbstractStage

abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, 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 Detail

Merger

public Merger()

A merger using the NonBlockingFiniteRoundRobinStrategy}.

Merger

public Merger(IMergerStrategy strategy)

Method Detail

execute

protected void execute()

Description copied from class: AbstractStage

Contains the logic of this stage and is invoked (possibly multiple times) by the framework.

Specified by:

execute in class AbstractStage

setStrategy

public void setStrategy(IMergerStrategy strategy)

getStrategy

public IMergerStrategy getStrategy()

getInputPorts

public List<InputPort<?>> getInputPorts()

Overrides:

getInputPorts in class AbstractStage

getNewInputPort

public InputPort<T> getNewInputPort()

getOutputPort

public OutputPort<T> getOutputPort()