Class AggregatedTraceUnwrapperStage
java.lang.Object
teetime.framework.AbstractStage
teetime.framework.AbstractConsumerStage<I>
teetime.stage.basic.AbstractTransformation<AggregatedTraceWrapper,Trace>
kieker.analysis.architecture.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
-
Constructor Summary
Constructors Constructor Description AggregatedTraceUnwrapperStage()
-
Method Summary
Modifier and Type Method Description protected void
execute(AggregatedTraceWrapper wrapper)
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
-
Constructor Details
-
AggregatedTraceUnwrapperStage
public AggregatedTraceUnwrapperStage()
-
-
Method Details
-
execute
- Specified by:
execute
in classteetime.framework.AbstractConsumerStage<AggregatedTraceWrapper>
-