kieker.tools.opad.filter
Class TimeSeriesPointAggregatorFilter
java.lang.Object
kieker.analysis.analysisComponent.AbstractAnalysisComponent
kieker.analysis.plugin.AbstractPlugin
kieker.analysis.plugin.filter.AbstractFilterPlugin
kieker.tools.opad.filter.TimeSeriesPointAggregatorFilter
- All Implemented Interfaces:
- IAnalysisComponent, IFilterPlugin, IPlugin
public class TimeSeriesPointAggregatorFilter
- extends AbstractFilterPlugin
This Filter aggregates the incoming DoubleTImeSeriesPoints over a configurable period of time.
- Since:
- 1.10
- Author:
- Tom Frotscher, Teerat Pitakrat
Methods inherited from class kieker.analysis.plugin.AbstractPlugin |
areAllRepositoryPortsConnected, connect, connect, deliver, getAllDisplayNames, getAllInputPortNames, getAllOutputPortNames, getAllRepositoryPortNames, getConnectedPlugins, getCurrentRepositories, getDefaultConfiguration, getIncomingPlugins, getPluginDescription, getPluginName, getRepository, getState, isConnectionAllowed, notifyNewIncomingConnection, notifyNewOutgoingConnection, shutdown, start |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface kieker.analysis.plugin.IPlugin |
connect, getAllDisplayNames, getAllInputPortNames, getAllOutputPortNames, getAllRepositoryPortNames, getConnectedPlugins, getCurrentRepositories, getName, getPluginDescription, getPluginName, getState |
INPUT_PORT_NAME_TSPOINT
public static final java.lang.String INPUT_PORT_NAME_TSPOINT
- See Also:
- Constant Field Values
OUTPUT_PORT_NAME_AGGREGATED_TSPOINT
public static final java.lang.String OUTPUT_PORT_NAME_AGGREGATED_TSPOINT
- See Also:
- Constant Field Values
OUTPUT_PORT_NAME_AGGREGATION_WINDOW
public static final java.lang.String OUTPUT_PORT_NAME_AGGREGATION_WINDOW
- The name of the output port delivering the aggregated window.
- See Also:
- Constant Field Values
CONFIG_PROPERTY_NAME_AGGREGATION_METHOD
public static final java.lang.String CONFIG_PROPERTY_NAME_AGGREGATION_METHOD
- The name of the property determining the aggregation method.
- See Also:
- Constant Field Values
CONFIG_PROPERTY_NAME_AGGREGATION_SPAN
public static final java.lang.String CONFIG_PROPERTY_NAME_AGGREGATION_SPAN
- See Also:
- Constant Field Values
CONFIG_PROPERTY_NAME_AGGREGATION_TIMEUNIT
public static final java.lang.String CONFIG_PROPERTY_NAME_AGGREGATION_TIMEUNIT
- See Also:
- Constant Field Values
CONFIG_PROPERTY_NAME_AGGREGATION_TIMESCOPE
public static final java.lang.String CONFIG_PROPERTY_NAME_AGGREGATION_TIMESCOPE
- See Also:
- Constant Field Values
CONFIG_PROPERTY_VALUE_AGGREGATION_TIMESCOPE_PER_VARIABLE
public static final java.lang.String CONFIG_PROPERTY_VALUE_AGGREGATION_TIMESCOPE_PER_VARIABLE
- Time scope
PER_VARIABLE: The aggregated value of each variable is processed only when a new input of that variable arrives. This is the default behavior.
GLOBAL: All variables are processed when any input arrives.
- See Also:
- Constant Field Values
CONFIG_PROPERTY_VALUE_AGGREGATION_TIMESCOPE_GLOBAL
public static final java.lang.String CONFIG_PROPERTY_VALUE_AGGREGATION_TIMESCOPE_GLOBAL
- See Also:
- Constant Field Values
TimeSeriesPointAggregatorFilter
public TimeSeriesPointAggregatorFilter(Configuration configuration,
IProjectContext projectContext)
getCurrentConfiguration
public Configuration getCurrentConfiguration()
- Description copied from class:
AbstractAnalysisComponent
- 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.
- Specified by:
getCurrentConfiguration
in interface IAnalysisComponent
- Specified by:
getCurrentConfiguration
in interface IPlugin
- Specified by:
getCurrentConfiguration
in class AbstractAnalysisComponent
- Returns:
- A completely filled configuration object.
inputTSPoint
public void inputTSPoint(NamedDoubleTimeSeriesPoint input)
- This method represents the input port for the incoming measurements.
- Parameters:
input
- The next incoming measurement
Copyright 2015 Kieker Project, http://kieker-monitoring.net