public class TraceEquivalenceClassFilter extends AbstractTraceProcessingStage<ExecutionTrace>
Modifier and Type | Class and Description |
---|---|
static class |
TraceEquivalenceClassFilter.TraceEquivalenceClassModes
This enum represents the different trace equivalence class modes.
|
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CONFIG_PROPERTY_NAME_EQUIVALENCE_MODE
This is the name of the property determining the equivalence mode.
|
static TraceEquivalenceClassFilter.TraceEquivalenceClassModes |
DEFAULT_EQUIVALENCE_MODE
This constant determines the default equivalence mode (the default value is disabled).
|
static java.lang.String |
INPUT_PORT_NAME_EXECUTION_TRACE
This is the name of the input port receiving new execution traces.
|
Constructor and Description |
---|
TraceEquivalenceClassFilter(SystemModelRepository systemModelRepository,
TraceEquivalenceClassFilter.TraceEquivalenceClassModes equivalenceMode)
Creates a new instance of this class using the given parameters.
|
Modifier and Type | Method and Description |
---|---|
protected void |
execute(ExecutionTrace et)
This method represents the input port of this filter, processing incoming execution traces.
|
java.util.concurrent.ConcurrentMap<ExecutionTrace,java.lang.Integer> |
getEquivalenceClassMap() |
teetime.framework.OutputPort<java.util.Map<ExecutionTrace,java.lang.Integer>> |
getEquivalenceMapOutputPort() |
teetime.framework.OutputPort<ExecutionTrace> |
getExecutionTraceOutputPort() |
teetime.framework.OutputPort<MessageTrace> |
getMessageTraceOutputPort() |
protected void |
onTerminating() |
getErrorCount, getLastTraceIdError, getLastTraceIdSuccess, getSuccessCount, getTotalCount, printStatusMessage, reportError, reportSuccess
createExecutionByEntityNames, createExecutionByEntityNames, createExecutionByEntityNames, createExecutionByEntityNames, getSystemModelRepository, printDebugLogMessage, printErrorLogMessage
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 static final java.lang.String INPUT_PORT_NAME_EXECUTION_TRACE
public static final java.lang.String CONFIG_PROPERTY_NAME_EQUIVALENCE_MODE
public static final TraceEquivalenceClassFilter.TraceEquivalenceClassModes DEFAULT_EQUIVALENCE_MODE
public TraceEquivalenceClassFilter(SystemModelRepository systemModelRepository, TraceEquivalenceClassFilter.TraceEquivalenceClassModes equivalenceMode)
systemModelRepository
- system model repositoryequivalenceMode
- equivalence modeprotected void execute(ExecutionTrace et) throws java.lang.Exception
execute
in class teetime.framework.AbstractConsumerStage<ExecutionTrace>
et
- The next execution trace.java.lang.Exception
public java.util.concurrent.ConcurrentMap<ExecutionTrace,java.lang.Integer> getEquivalenceClassMap()
protected void onTerminating()
onTerminating
in class teetime.framework.AbstractStage
public teetime.framework.OutputPort<java.util.Map<ExecutionTrace,java.lang.Integer>> getEquivalenceMapOutputPort()
public teetime.framework.OutputPort<ExecutionTrace> getExecutionTraceOutputPort()
public teetime.framework.OutputPort<MessageTrace> getMessageTraceOutputPort()
Copyright 2021 Kieker Project, http://kieker-monitoring.net