public class SessionReconstructionFilter extends teetime.framework.AbstractConsumerStage<ExecutionTrace>
Constructor and Description |
---|
SessionReconstructionFilter(java.util.concurrent.TimeUnit timeunit,
java.lang.Long maxThinkTime)
Creates a new session reconstruction filter using the given configuration.
|
Modifier and Type | Method and Description |
---|---|
protected void |
execute(ExecutionTrace executionTrace)
Processes an incoming execution.
|
teetime.framework.OutputPort<ExecutionTraceBasedSession> |
getOutputPort() |
void |
onTerminating() |
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, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted
public SessionReconstructionFilter(java.util.concurrent.TimeUnit timeunit, java.lang.Long maxThinkTime)
timeunit
- used time unit, e.g., NANOSECONDSmaxThinkTime
- max time to collect session information (null implies
Long.MAX_VALUE)public teetime.framework.OutputPort<ExecutionTraceBasedSession> getOutputPort()
protected void execute(ExecutionTrace executionTrace) throws java.lang.Exception
execute
in class teetime.framework.AbstractConsumerStage<ExecutionTrace>
executionTrace
- The execution trace to process.java.lang.Exception
public void onTerminating()
onTerminating
in class teetime.framework.AbstractStage
Copyright 2021 Kieker Project, http://kieker-monitoring.net