public class AggregatedTraceCreatorStage extends teetime.stage.basic.AbstractTransformation<Trace,AggregatedTraceWrapper>
Trace
to an AggregatedTraceWrapper
.
It uses an TraceAggregator
under the hood and calls TraceAggregator.handleTrace(Trace)
for every incoming trace.Constructor and Description |
---|
AggregatedTraceCreatorStage(boolean considerFailed) |
Modifier and Type | Method and Description |
---|---|
protected void |
execute(Trace trace) |
createInputPort, execute, getInputPort
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
Copyright 2020 Kieker Project, http://kieker-monitoring.net