See: Description
Interface | Description |
---|---|
Aggregator<T> |
Interface which offers a means of "aggregating" data.
|
TimedAggregatorListener<T> |
Listener to be used with instances of
AbstractTimedAggregator to
receive notifications when the timer kicks in. |
Class | Description |
---|---|
AbstractListBackedAggregator<T> |
An aggregator which stores the data series in a List.
|
AbstractNoStoreAggregator<T> |
An implementation of an aggregator which doesn't store the data series but
instead it processes the data on the fly, as it arrives in
AbstractTimedAggregator.add(Object) and stores the result after each addition. |
AbstractTimedAggregator<T> |
An aggregator which automatically resets the aggregated data at regular
intervals and sends a notification when it is about to do so, so listeners
can decide to gather the information before it is being reset (and log it
etc).
|
ArrayListBackedAggregator<T> |
Implementation of an aggregator which stores the data series in an
ArrayList . |
This package contains the interfaces and utilities needed to implement an aggregation service.
Aggregation refers to being able to add data to a data "sink" which "aggregates" them automatically (e.g. sum them up or average, median etc).
An example of an aggregation service is being able to average a series
of int
values (perhaps generated from a monitoring component)
and be able to constantly report on the average (or mean) value of
this series. There is no specification about the maximum amount of data that
can be aggregated -- some subclasses might impose such restrictions,
if that is the case then that will be specified in their JavaDoc's.
Copyright © 2003–2014 The Apache Software Foundation. All rights reserved.