Jagger
 All Classes Namespaces Files Functions Variables Enumerator Groups Pages
SumMetricAggregatorProvider.java
Go to the documentation of this file.
1 /*
2  * Copyright (c) 2010-2012 Grid Dynamics Consulting Services, Inc, All Rights Reserved
3  * http://www.griddynamics.com
4  *
5  * This library is free software; you can redistribute it and/or modify it under the terms of
6  * the Apache License; either
7  * version 2.0 of the License, or any later version.
8  *
9  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
10  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
11  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
12  * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE
13  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
14  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
15  * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
16  * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
17  * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
18  * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
19  */
20 
21 package com.griddynamics.jagger.engine.e1.collector;
22 
23 import org.slf4j.Logger;
24 import org.slf4j.LoggerFactory;
25 
26 import static com.griddynamics.jagger.util.StandardMetricsNamesUtil.SUM_AGGREGATOR_ID;
27 
32 public class SumMetricAggregatorProvider implements MetricAggregatorProvider {
33 
35  @Override
37  return new SumMetricAggregator();
38  }
39 
40  private static class SumMetricAggregator implements MetricAggregator<Number> {
41 
42  Logger log = LoggerFactory.getLogger(SumMetricAggregator.class);
43 
44  Double sum = null;
45 
46  @Override
47  public void append(Number calculated) {
48  log.debug("append({})", calculated);
49  if (sum == null)
50  sum = new Double(0);
51 
52  sum += calculated.doubleValue();
53  }
54 
55  @Override
56  public Number getAggregated() {
57  if (sum == null)
58  return null;
59 
60  return sum.doubleValue();
61  }
62 
63  @Override
64  public void reset() {
65  log.debug("Reset aggregator");
66  sum = null;
67  }
68 
69  @Override
70  public String getName() {
71  return SUM_AGGREGATOR_ID;
72  }
73 
74  @Override
75  public String toString() {
76  return "SumMetricAggregator{" +
77  "log=" + log +
78  ", sum=" + sum +
79  '}';
80  }
81  }
82 }