public abstract class AbstractEventRecordTraceReconstructionStage
extends teetime.framework.AbstractStage
Constructor and Description |
---|
AbstractEventRecordTraceReconstructionStage(java.util.concurrent.TimeUnit timeUnit,
boolean repairEventBasedTraces,
long maxTraceDuration,
long maxTraceTimeout)
Creates a new instance of this class using the given parameters.
|
Modifier and Type | Method and Description |
---|---|
protected void |
execute() |
teetime.framework.OutputPort<TraceEventRecords> |
getInvalidTracesOutputPort() |
teetime.framework.InputPort<java.lang.Long> |
getTimestampsInputPort() |
teetime.framework.OutputPort<TraceEventRecords> |
getValidTracesOutputPort() |
protected void |
newFlowRecordEvent(IFlowRecord record)
This method is the input port for the new events for this filter.
|
protected void |
onTerminating() |
abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, 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 AbstractEventRecordTraceReconstructionStage(java.util.concurrent.TimeUnit timeUnit, boolean repairEventBasedTraces, long maxTraceDuration, long maxTraceTimeout)
timeUnit
- property determining the time unitrepairEventBasedTraces
- repair traces where AfterEvents are missingmaxTraceDuration
- max trace durationmaxTraceTimeout
- max trace timeout, if set to Long.MAX_VALUE no timeout is usedprotected void execute() throws java.lang.Exception
execute
in class teetime.framework.AbstractStage
java.lang.Exception
public teetime.framework.OutputPort<TraceEventRecords> getInvalidTracesOutputPort()
public teetime.framework.OutputPort<TraceEventRecords> getValidTracesOutputPort()
public teetime.framework.InputPort<java.lang.Long> getTimestampsInputPort()
protected void newFlowRecordEvent(IFlowRecord record)
record
- The new record to handle.protected void onTerminating()
onTerminating
in class teetime.framework.AbstractStage
Copyright 2021 Kieker Project, http://kieker-monitoring.net