kieker.analysisteetime.trace.aggregation

Class AggregatedTraceUnwrapperStage

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<I>

teetime.stage.basic.AbstractTransformation<AggregatedTraceWrapper,Trace>

kieker.analysisteetime.trace.aggregation.AggregatedTraceUnwrapperStage

All Implemented Interfaces:

teetime.stage.basic.ITransformation<AggregatedTraceWrapper,Trace>

public class AggregatedTraceUnwrapperStage
extends teetime.stage.basic.AbstractTransformation<AggregatedTraceWrapper,Trace>

This class is a TeeTime stage that accepts AggregatedTraceWrapper elements at its input port and send sends their containing aggregated trace to the stage�s output port if AggregatedTraceWrapper.isFirst() returns true.

Since:

1.14

Author:

Sören Henning

Field Summary

Fields inherited from class teetime.stage.basic.AbstractTransformation

outputPort

Fields inherited from class teetime.framework.AbstractConsumerStage

inputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
AggregatedTraceUnwrapperStage()

Method Summary

Modifier and Type	Method and Description
protected void	execute(AggregatedTraceWrapper wrapper)

Methods inherited from class teetime.stage.basic.AbstractTransformation

getOutputPort

Methods inherited from class teetime.framework.AbstractConsumerStage

createInputPort, execute, getInputPort

Methods inherited from class teetime.framework.AbstractStage

abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, 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

Methods inherited from interface teetime.stage.basic.ITransformation

getInputPort

Constructor Detail

AggregatedTraceUnwrapperStage

public AggregatedTraceUnwrapperStage()

Method Detail

execute

protected void execute(AggregatedTraceWrapper wrapper)

Specified by:

execute in class teetime.framework.AbstractConsumerStage<AggregatedTraceWrapper>