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, reportSuccesscreateExecutionByEntityNames, createExecutionByEntityNames, createExecutionByEntityNames, createExecutionByEntityNames, getSystemModelRepository, printDebugLogMessage, printErrorLogMessagecreateInputPort, execute, getInputPortabort, 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, workCompletedpublic 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.Exceptionpublic java.util.concurrent.ConcurrentMap<ExecutionTrace,java.lang.Integer> getEquivalenceClassMap()
protected void onTerminating()
onTerminating in class teetime.framework.AbstractStagepublic 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