public class TraceRecordsTraceReconstructionStage extends AbstractEventRecordTraceReconstructionStage
Constructor and Description |
---|
TraceRecordsTraceReconstructionStage(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<TraceEventRecords> |
getTraceEventRecordsInputPort() |
getInvalidTracesOutputPort, getTimestampsInputPort, getValidTracesOutputPort, newFlowRecordEvent, 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 TraceRecordsTraceReconstructionStage(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
public teetime.framework.InputPort<TraceEventRecords> getTraceEventRecordsInputPort()
Copyright 2021 Kieker Project, http://kieker-monitoring.net