teetime.stage.basic.merger.dynamic

Class DynamicMerger<T>

java.lang.Object

teetime.framework.AbstractStage

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

teetime.stage.basic.merger.dynamic.DynamicMerger<T>

public class DynamicMerger<T>
extends Merger<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected BlockingQueue<PortAction<DynamicMerger<T>>>	portActions

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
DynamicMerger()
DynamicMerger(IMergerStrategy strategy)

Method Summary

Modifier and Type	Method and Description
boolean	addPortActionRequest(PortAction<DynamicMerger<T>> newPortActionRequest)
protected void	checkForPendingPortActionRequest()
protected void	execute() Contains the logic of this stage and is invoked (possibly multiple times) by the framework.
void	onTerminating() Event that is triggered, if all of the following conditions hold: while executing the P&F configuration and after receiving the termination signal.
void	removeDynamicPort(InputPort<?> inputPort)

Methods inherited from class teetime.stage.basic.merger.Merger

getInputPorts, getNewInputPort, getOutputPort, getStrategy, setStrategy

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, onValidating, 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

portActions

protected final BlockingQueue<PortAction<DynamicMerger<T>>> portActions

Constructor Detail

DynamicMerger

public DynamicMerger()

DynamicMerger

public DynamicMerger(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.

Overrides:

execute in class Merger<T>

onTerminating

public void onTerminating()

Description copied from class: AbstractStage

Event that is triggered, if all of the following conditions hold:

• while executing the P&F configuration and
• after receiving the termination signal.

If stage developers want to override this method, they must always call the super implementation last:

 @Override
 protected void onTerminating() {
        // insert your code here
        super.onTerminating();
 }
 

To throw a checked exception, wrap it to an unchecked exception, e.g. to an IllegalArgumentException.IllegalArgumentException(String, Throwable). Always pass the original exception to the new unchecked exception to allow easy debugging.

Overrides:

onTerminating in class AbstractStage

checkForPendingPortActionRequest

protected void checkForPendingPortActionRequest()

removeDynamicPort

public void removeDynamicPort(InputPort<?> inputPort)

Overrides:

removeDynamicPort in class AbstractStage

addPortActionRequest

public boolean addPortActionRequest(PortAction<DynamicMerger<T>> newPortActionRequest)