kieker.tools.traceAnalysis.filter.flow
Class EventRecordTraceGenerationFilter

java.lang.Object
  kieker.analysis.plugin.AbstractPlugin
      kieker.analysis.plugin.filter.AbstractFilterPlugin
          kieker.tools.traceAnalysis.filter.AbstractTraceAnalysisFilter
              kieker.tools.traceAnalysis.filter.AbstractTraceProcessingFilter
                  kieker.tools.traceAnalysis.filter.flow.EventRecordTraceGenerationFilter

All Implemented Interfaces:

IFilterPlugin, IPlugin

public class EventRecordTraceGenerationFilter
extends AbstractTraceProcessingFilter

TODO: The implementation of this plugin was based on the TraceReconstructionFilter. We should check for possible abstractions later on. TODO: Note that we are currently not evaluating if traces are valid We should import the invalid traces handling from TraceReconstructionFilter

Author:

Andre van Hoorn

Nested Class Summary

Nested classes/interfaces inherited from interface kieker.analysis.plugin.IPlugin

IPlugin.PluginInputPortReference

Field Summary

static String	CONFIG_PROPERTY_NAME_MAX_TRACE_DURATION_MILLIS
static String	INPUT_PORT_NAME_TRACE_EVENT
static String	OUTPUT_PORT_NAME_TRACE

Fields inherited from class kieker.tools.traceAnalysis.filter.AbstractTraceProcessingFilter

MAX_DURATION_MILLIS

Fields inherited from class kieker.tools.traceAnalysis.filter.AbstractTraceAnalysisFilter

REPOSITORY_PORT_NAME_SYSTEM_MODEL

Fields inherited from class kieker.analysis.plugin.AbstractPlugin

CONFIG_NAME

Constructor Summary

EventRecordTraceGenerationFilter(Configuration configuration)

Method Summary

Configuration	getCurrentConfiguration() This method should deliver a Configuration object containing the current configuration of this instance.
long	getMaxTimestamp() Returns the maximum timestamp of the received AbstractTraceEvents.
long	getMinTimestamp() Returns the minimum timestamp of the received AbstractTraceEvents.
void	inputTraceEvent(IMonitoringRecord record)
void	printStatusMessage() Returns a user-addressed status message to be logged by the calling tool.
void	terminate(boolean error) Terminates the filter (internally, all pending traces are processed).

Methods inherited from class kieker.tools.traceAnalysis.filter.AbstractTraceProcessingFilter

getErrorCount, getLastTraceIdError, getLastTraceIdSuccess, getSuccessCount, getTotalCount

Methods inherited from class kieker.tools.traceAnalysis.filter.AbstractTraceAnalysisFilter

createExecutionByEntityNames, setErrStream, setOutStream

Methods inherited from class kieker.analysis.plugin.filter.AbstractFilterPlugin

init

Methods inherited from class kieker.analysis.plugin.AbstractPlugin

areAllRepositoryPortsConnected, connect, connect, getAllInputPortNames, getAllOutputPortNames, getConnectedPlugins, getCurrentRepositories, getName, getPluginDescription, getPluginName, isConnectionAllowed

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

INPUT_PORT_NAME_TRACE_EVENT

public static final String INPUT_PORT_NAME_TRACE_EVENT

See Also:

Constant Field Values

OUTPUT_PORT_NAME_TRACE

public static final String OUTPUT_PORT_NAME_TRACE

See Also:

Constant Field Values

CONFIG_PROPERTY_NAME_MAX_TRACE_DURATION_MILLIS

public static final String CONFIG_PROPERTY_NAME_MAX_TRACE_DURATION_MILLIS

See Also:

Constant Field Values

Constructor Detail

EventRecordTraceGenerationFilter

public EventRecordTraceGenerationFilter(Configuration configuration)

Parameters:

configuration -

Method Detail

inputTraceEvent

public void inputTraceEvent(IMonitoringRecord record)

getMinTimestamp

public final long getMinTimestamp()

Returns the minimum timestamp of the received AbstractTraceEvents.

Returns:

the timestamp

getMaxTimestamp

public final long getMaxTimestamp()

Returns the maximum timestamp of the received AbstractTraceEvents.

Returns:

the timestamp

terminate

public void terminate(boolean error)

Terminates the filter (internally, all pending traces are processed).

Specified by:

terminate in interface IFilterPlugin

Overrides:

terminate in class AbstractFilterPlugin

Parameters:

error -

printStatusMessage

public void printStatusMessage()

Description copied from class: AbstractTraceProcessingFilter

Returns a user-addressed status message to be logged by the calling tool. Extending classes may override this method but should call the then-inherited method first.

Overrides:

printStatusMessage in class AbstractTraceProcessingFilter

getCurrentConfiguration

public Configuration getCurrentConfiguration()

Description copied from interface: IPlugin

This method should deliver a Configuration object containing the current configuration of this instance. In other words: The constructor should be able to use the given object to initialize a new instance of this class with the same intern properties.

Returns:

A completely filled configuration object.