Aggregator

java.lang.Object
- org.qbroker.common.Aggregator

```
public class Aggregator
extends java.lang.Object
```
Aggregator contains a list of stateless operations for aggregations on the properties retrieved from a Map.

In case of average, AveragedOver is required. Its referenced name should be defined before it. In case of standard deviation, VarianceOf is requires. Its referenced name should be defined before it. In case of max or min, the name of the field does not have to exist in the incoming message. But the referenced name by MaxOf or MinOf should be defined before it. If TimePattern is defined for max or min, Aggregation will parse the value to get the timestamp for comparisons.

Author:

yannanlu@yahoo.com

Field Summary

Fields
Modifier and Type	Field and Description
`static int`	`AGGR_APPEND`
`static int`	`AGGR_AVG`
`static int`	`AGGR_COUNT`
`static int`	`AGGR_END`
`static int`	`AGGR_FIRST`
`static int`	`AGGR_JOIN`
`static int`	`AGGR_LAST`
`static int`	`AGGR_MAX`
`static int`	`AGGR_MERGE`
`static int`	`AGGR_MIN`
`static int`	`AGGR_NONE`
`static int`	`AGGR_STD`
`static int`	`AGGR_SUM`
`static int`	`AGGR_UNION`
`static int`	`AGGR_XUNION`

Constructor Summary

Constructors
Constructor and Description

Aggregator(java.lang.String name, java.util.List list)

Constructors
Constructor and Description
`Aggregator(java.lang.String name, java.util.List list)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`int`	`aggregate(long currentTime, java.util.Map report, java.util.Map rpt)` It aggregates the incoming data report with the aggregation report according to the aggregation options.
`Browser`	`browser()`
`void`	`clear()`
`boolean`	`containsKey(java.lang.String key)`
`protected void`	`finalize()`
`java.lang.String`	`getKey(int id)`
`java.lang.String`	`getName()`
`int`	`getSize()`
`int`	`initialize(long currentTime, java.util.Map report, java.util.Map rpt)` It initializes the aggregation report and aggregates the fisrt incoming report according to the aggregation operations.

Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - AGGR_NONE
```
public static final int AGGR_NONE
```
    See Also:
    
    Constant Field Values
  - AGGR_COUNT
```
public static final int AGGR_COUNT
```
    See Also:
    
    Constant Field Values
  - AGGR_SUM
```
public static final int AGGR_SUM
```
    See Also:
    
    Constant Field Values
  - AGGR_MIN
```
public static final int AGGR_MIN
```
    See Also:
    
    Constant Field Values
  - AGGR_MAX
```
public static final int AGGR_MAX
```
    See Also:
    
    Constant Field Values
  - AGGR_APPEND
```
public static final int AGGR_APPEND
```
    See Also:
    
    Constant Field Values
  - AGGR_FIRST
```
public static final int AGGR_FIRST
```
    See Also:
    
    Constant Field Values
  - AGGR_LAST
```
public static final int AGGR_LAST
```
    See Also:
    
    Constant Field Values
  - AGGR_AVG
```
public static final int AGGR_AVG
```
    See Also:
    
    Constant Field Values
  - AGGR_STD
```
public static final int AGGR_STD
```
    See Also:
    
    Constant Field Values
  - AGGR_MERGE
```
public static final int AGGR_MERGE
```
    See Also:
    
    Constant Field Values
  - AGGR_UNION
```
public static final int AGGR_UNION
```
    See Also:
    
    Constant Field Values
  - AGGR_XUNION
```
public static final int AGGR_XUNION
```
    See Also:
    
    Constant Field Values
  - AGGR_JOIN
```
public static final int AGGR_JOIN
```
    See Also:
    
    Constant Field Values
  - AGGR_END
```
public static final int AGGR_END
```
    See Also:
    
    Constant Field Values
- Constructor Detail
  - Aggregator
```
public Aggregator(java.lang.String name,
                  java.util.List list)
```
- Method Detail
  - initialize
```
public int initialize(long currentTime,
                      java.util.Map report,
                      java.util.Map rpt)
```
    It initializes the aggregation report and aggregates the fisrt incoming report according to the aggregation operations. Upon success, it returns 0. Otherwise, it returns -1 to indicate errors.
  - aggregate
```
public int aggregate(long currentTime,
                     java.util.Map report,
                     java.util.Map rpt)
```
    It aggregates the incoming data report with the aggregation report according to the aggregation options. It extracts data from the incoming report and aggregates the values into the cached report. Upon success, it returns 0. Otherwise, it returns -1 to indicate errors.
  - getName
```
public java.lang.String getName()
```
  - getSize
```
public int getSize()
```
  - containsKey
```
public boolean containsKey(java.lang.String key)
```
  - getKey
```
public java.lang.String getKey(int id)
```
  - browser
```
public Browser browser()
```
  - clear
```
public void clear()
```
  - finalize
```
protected void finalize()
```
    Overrides:
    
    finalize in class java.lang.Object

Class Aggregator

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

AGGR_NONE

AGGR_COUNT

AGGR_SUM

AGGR_MIN

AGGR_MAX

AGGR_APPEND

AGGR_FIRST

AGGR_LAST

AGGR_AVG

AGGR_STD

AGGR_MERGE

AGGR_UNION

AGGR_XUNION

AGGR_JOIN

AGGR_END

Constructor Detail

Aggregator

Method Detail

initialize

aggregate

getName

getSize

containsKey

getKey

browser

clear

finalize