public class TimeSeriesPointAggregatorFilter extends AbstractFilterPlugin
IPlugin.PluginInputPortReference, IPlugin.STATE
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CONFIG_PROPERTY_NAME_AGGREGATION_METHOD
The name of the property determining the aggregation method.
|
static java.lang.String |
CONFIG_PROPERTY_NAME_AGGREGATION_SPAN |
static java.lang.String |
CONFIG_PROPERTY_NAME_AGGREGATION_TIMESCOPE |
static java.lang.String |
CONFIG_PROPERTY_NAME_AGGREGATION_TIMEUNIT |
static java.lang.String |
CONFIG_PROPERTY_VALUE_AGGREGATION_TIMESCOPE_GLOBAL |
static 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.
|
static java.lang.String |
INPUT_PORT_NAME_TSPOINT |
static java.lang.String |
OUTPUT_PORT_NAME_AGGREGATED_TSPOINT |
static java.lang.String |
OUTPUT_PORT_NAME_AGGREGATION_WINDOW
The name of the output port delivering the aggregated window.
|
CONFIG_NAME, configuration, log, LOG, projectContext, recordsTimeUnitFromProjectContext
Constructor and Description |
---|
TimeSeriesPointAggregatorFilter(Configuration configuration,
IProjectContext projectContext) |
Modifier and Type | Method and Description |
---|---|
Configuration |
getCurrentConfiguration()
This method should deliver a
Configuration object containing the current configuration of this instance. |
void |
inputTSPoint(NamedDoubleTimeSeriesPoint input)
This method represents the input port for the incoming measurements.
|
init, terminate
areAllRepositoryPortsConnected, connect, connect, deliver, getAllDisplayNames, getAllInputPortNames, getAllOutputPortNames, getAllRepositoryPortNames, getConnectedPlugins, getCurrentRepositories, getDefaultConfiguration, getIncomingPlugins, getPluginDescription, getPluginName, getRepository, getState, isConnectionAllowed, notifyNewIncomingConnection, notifyNewOutgoingConnection, shutdown, start
getName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
connect, getAllDisplayNames, getAllInputPortNames, getAllOutputPortNames, getAllRepositoryPortNames, getConnectedPlugins, getCurrentRepositories, getName, getPluginDescription, getPluginName, getState
public static final java.lang.String INPUT_PORT_NAME_TSPOINT
public static final java.lang.String OUTPUT_PORT_NAME_AGGREGATED_TSPOINT
public static final java.lang.String OUTPUT_PORT_NAME_AGGREGATION_WINDOW
public static final java.lang.String CONFIG_PROPERTY_NAME_AGGREGATION_METHOD
public static final java.lang.String CONFIG_PROPERTY_NAME_AGGREGATION_SPAN
public static final java.lang.String CONFIG_PROPERTY_NAME_AGGREGATION_TIMEUNIT
public static final java.lang.String CONFIG_PROPERTY_NAME_AGGREGATION_TIMESCOPE
public static final java.lang.String CONFIG_PROPERTY_VALUE_AGGREGATION_TIMESCOPE_PER_VARIABLE
public static final java.lang.String CONFIG_PROPERTY_VALUE_AGGREGATION_TIMESCOPE_GLOBAL
public TimeSeriesPointAggregatorFilter(Configuration configuration, IProjectContext projectContext)
public Configuration getCurrentConfiguration()
AbstractAnalysisComponent
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.getCurrentConfiguration
in interface IAnalysisComponent
getCurrentConfiguration
in interface IPlugin
getCurrentConfiguration
in class AbstractAnalysisComponent
public void inputTSPoint(NamedDoubleTimeSeriesPoint input)
input
- The next incoming measurementCopyright 2017 Kieker Project, http://kieker-monitoring.net