ikr.simlib.statistics.aggregating

Class IntervalAggregatingStatistic<T,V>

java.lang.Object

ikr.simlib.statistics.aggregating.IntervalAggregatingStatistic<T,V>

Type Parameters:

T - type of the input values

V - type of the output values

All Implemented Interfaces:

UnweightedSampleCollector<T>

public class IntervalAggregatingStatistic<T,V>
extends java.lang.Object
implements UnweightedSampleCollector<T>

IntervalAggregatingStatistic aggregates values over a configured interval. Each time the interval is over, the aggregated value is written to the backing statistic and the aggregator is reset. *

Implements the interface UnweightedSampleCollector, so that it can be used as a replacement for a normal statistic in any meter.

The type of input and output can be different, as aggregation may convert the type. Example: the average of long values can be returned as double.

Constructor Summary

Constructors

Constructor and Description
IntervalAggregatingStatistic(UnweightedSampleCollector<V> baseStat, Duration aggregationInterval, Aggregator<? super T,? extends V> aggregator)

Method Summary

Methods

Modifier and Type	Method and Description
void	update(T value)

Methods inherited from class java.lang.Object

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

Constructor Detail

IntervalAggregatingStatistic

public IntervalAggregatingStatistic(UnweightedSampleCollector<V> baseStat,
                            Duration aggregationInterval,
                            Aggregator<? super T,? extends V> aggregator)

Method Detail

update

public void update(T value)

Specified by:

update in interface UnweightedSampleCollector<T>