org.palladiosimulator.experimentanalysis.windowaggregators

Class SlidingWindowAggregator

java.lang.Object

org.palladiosimulator.experimentanalysis.windowaggregators.SlidingWindowAggregator

All Implemented Interfaces:

ISlidingWindowListener

Direct Known Subclasses:

SlidingWindowUtilizationAggregator

public abstract class SlidingWindowAggregator
extends java.lang.Object
implements ISlidingWindowListener

This class is the base class of all ISlidingWindowListener that aggregate/process the measurements collected by a SlidingWindow once it is full (i.e., it moved on).
In terms of signal processing and time series analysis/statistics, this class can be thought of as a base class for any moving average implementation.

Author:

Florian Rosenthal

See Also:

SlidingWindowRecorder

Constructor Summary

Constructors

Constructor and Description
SlidingWindowAggregator() Initializes a new instance of the SlidingWindowAggregator class which shall not be connected to a recorder (data sink) yet.
SlidingWindowAggregator(java.util.Collection<org.palladiosimulator.recorderframework.IRecorder> recordersToWriteInto) Initializes a new instance of the SlidingWindowAggregator class with the given parameter.
SlidingWindowAggregator(org.palladiosimulator.recorderframework.IRecorder recorderToWriteInto) Initializes a new instance of the SlidingWindowAggregator class with the given parameter.

Method Summary

Modifier and Type	Method and Description
void	addRecorder(org.palladiosimulator.recorderframework.IRecorder recorder)
void	onSlidingWindowFull(java.lang.Iterable<org.palladiosimulator.measurementframework.MeasuringValue> windowData, javax.measure.Measure<java.lang.Double,javax.measure.quantity.Duration> windowLeftBound, javax.measure.Measure<java.lang.Double,javax.measure.quantity.Duration> windowLength) This callback method is triggered by each observed window once it is full, that is, just before it is about to move on.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.palladiosimulator.experimentanalysis.ISlidingWindowListener

getExpectedWindowDataMetric

Constructor Detail

SlidingWindowAggregator

public SlidingWindowAggregator()

Initializes a new instance of the SlidingWindowAggregator class which shall not be connected to a recorder (data sink) yet.

See Also:

addRecorder(IRecorder)

SlidingWindowAggregator

public SlidingWindowAggregator(org.palladiosimulator.recorderframework.IRecorder recorderToWriteInto)

Initializes a new instance of the SlidingWindowAggregator class with the given parameter.

Parameters:

recorderToWriteInto - An IRecorder this instance writes the aggregated window data into. Typically, a recorder that writes into a persistence framework like EDP 2 is passed here.

Throws:

java.lang.NullPointerException - If the given IRecorder is null.

SlidingWindowAggregator

public SlidingWindowAggregator(java.util.Collection<org.palladiosimulator.recorderframework.IRecorder> recordersToWriteInto)

Initializes a new instance of the SlidingWindowAggregator class with the given parameter.

Parameters:

recordersToWriteInto - A @Collection of IRecorders this instance writes the aggregated window data into. Typically, recorders that write data into persistence frameworks like EDP 2 are passed here.

Throws:

java.lang.NullPointerException - If the given collection of IRecorders is null.

java.lang.IllegalArgumentException - If the given collection of recorders is empty.

Method Detail

addRecorder

public void addRecorder(org.palladiosimulator.recorderframework.IRecorder recorder)

onSlidingWindowFull

public final void onSlidingWindowFull(java.lang.Iterable<org.palladiosimulator.measurementframework.MeasuringValue> windowData,
                                      javax.measure.Measure<java.lang.Double,javax.measure.quantity.Duration> windowLeftBound,
                                      javax.measure.Measure<java.lang.Double,javax.measure.quantity.Duration> windowLength)

Description copied from interface: ISlidingWindowListener

This callback method is triggered by each observed window once it is full, that is, just before it is about to move on.

Specified by:

onSlidingWindowFull in interface ISlidingWindowListener

Parameters:

windowData - An Iterable containing the currently collected window data, that is, all MeasuringValues within the window's current bounds.

windowLeftBound - A Measure denoting the window's current lower/left bound.

windowLength - A Measure denoting the current window length.