kieker.tools.traceAnalysis.plugins.executionFilter
Class TimestampFilter

java.lang.Object
  kieker.tools.traceAnalysis.plugins.executionFilter.TimestampFilter

All Implemented Interfaces:

IAnalysisPlugin

public class TimestampFilter
extends Object
implements IAnalysisPlugin

Allows to filter Execution objects based on their tin and tout timestamps.

Author:

Andre van Hoorn

Field Summary

static long	MAX_TIMESTAMP
static long	MIN_TIMESTAMP

Constructor Summary

TimestampFilter(long ignoreExecutionsBeforeTimestamp, long ignoreExecutionsAfterTimestamp)
Creates a filter instance that only passes Execution objects e with the property e.tin >= ignoreExecutionsBeforeTimestamp and e.tout <= ignoreExecutionsAfterTimestamp.

Method Summary

boolean	execute() Initiates the start of a component.
IInputPort<Execution>	getExecutionInputPort()
IOutputPort<Execution>	getExecutionOutputPort()
void	terminate(boolean error) Initiates a termination of the component.

Methods inherited from class java.lang.Object

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

Field Detail

MAX_TIMESTAMP

public static final long MAX_TIMESTAMP

See Also:

Constant Field Values

MIN_TIMESTAMP

public static final long MIN_TIMESTAMP

See Also:

Constant Field Values

Constructor Detail

TimestampFilter

public TimestampFilter(long ignoreExecutionsBeforeTimestamp,
                       long ignoreExecutionsAfterTimestamp)

Creates a filter instance that only passes Execution objects e with the property e.tin >= ignoreExecutionsBeforeTimestamp and e.tout <= ignoreExecutionsAfterTimestamp.

Parameters:

ignoreExecutionsBeforeTimestamp -

ignoreExecutionsAfterTimestamp -

Method Detail

getExecutionInputPort

public IInputPort<Execution> getExecutionInputPort()

getExecutionOutputPort

public IOutputPort<Execution> getExecutionOutputPort()

execute

public boolean execute()

Description copied from interface: IAnalysisPlugin

Initiates the start of a component. This method is called once when a TpanInstance's run() method is called. This implementation must not be blocking! Asynchronous consumers would spawn (an) aynchronous thread(s) in this method.

Specified by:

execute in interface IAnalysisPlugin

Returns:

true on success; false otherwise.

terminate

public void terminate(boolean error)

Description copied from interface: IAnalysisPlugin

Initiates a termination of the component. The value of the parameter error indicates whether an error occured.

Specified by:

terminate in interface IAnalysisPlugin

Parameters:

error - true iff an error occured.