kieker.analysis.trace

Class SessionReconstructionFilter

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<ExecutionTrace>

kieker.analysis.trace.SessionReconstructionFilter

public class SessionReconstructionFilter
extends teetime.framework.AbstractConsumerStage<ExecutionTrace>

This filter reconstructs sessions from execution or message traces.

Since:

1.10

Author:

Holger Knoche, Reiner Jung -- teetime port

Field Summary

Fields inherited from class teetime.framework.AbstractConsumerStage

inputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
SessionReconstructionFilter(java.util.concurrent.TimeUnit timeunit, java.lang.Long maxThinkTime) Creates a new session reconstruction filter using the given configuration.

Method Summary

Modifier and Type	Method and Description
protected void	execute(ExecutionTrace executionTrace) Processes an incoming execution.
teetime.framework.OutputPort<ExecutionTraceBasedSession>	getOutputPort()
void	onTerminating()

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

SessionReconstructionFilter

public SessionReconstructionFilter(java.util.concurrent.TimeUnit timeunit,
                                   java.lang.Long maxThinkTime)

Creates a new session reconstruction filter using the given configuration.

Parameters:

timeunit - used time unit, e.g., NANOSECONDS

maxThinkTime - max time to collect session information (null implies Long.MAX_VALUE)

Method Detail

getOutputPort

public teetime.framework.OutputPort<ExecutionTraceBasedSession> getOutputPort()

execute

protected void execute(ExecutionTrace executionTrace)
                throws java.lang.Exception

Processes an incoming execution.

Specified by:

execute in class teetime.framework.AbstractConsumerStage<ExecutionTrace>

Parameters:

executionTrace - The execution trace to process.

Throws:

java.lang.Exception

onTerminating

public void onTerminating()

Overrides:

onTerminating in class teetime.framework.AbstractStage