public final class EventRecordTraceReconstructionStage extends AbstractEventRecordTraceReconstructionStage
Constructor and Description |
---|
EventRecordTraceReconstructionStage(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.InputPort<IFlowRecord> |
getTraceRecordsInputPort() |
protected void |
onTerminating() |
getInvalidTracesOutputPort, getTimestampsInputPort, getValidTracesOutputPort, newFlowRecordEvent
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 EventRecordTraceReconstructionStage(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 AbstractEventRecordTraceReconstructionStage
java.lang.Exception
protected void onTerminating()
AbstractEventRecordTraceReconstructionStage
onTerminating
in class AbstractEventRecordTraceReconstructionStage
public teetime.framework.InputPort<IFlowRecord> getTraceRecordsInputPort()
Copyright 2021 Kieker Project, http://kieker-monitoring.net