1 package org.apache.helix.monitoring;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 import org.testng.AssertJUnit;
23 import org.testng.annotations.Test;
24
25
26 public class TestStatCollector
27 {
28 @Test(groups={ "unitTest" })
29 public void TestCollectData()
30 {
31 StatCollector collector = new StatCollector();
32
33 int nPoints = 100;
34 for (int i = 0; i< nPoints; i++)
35 {
36 collector.addData(i*1000);
37 }
38 AssertJUnit.assertEquals(collector.getNumDataPoints(), nPoints);
39 AssertJUnit.assertEquals((long)collector.getMax(), 99000);
40 AssertJUnit.assertEquals((long)collector.getTotalSum(), 4950000);
41 AssertJUnit.assertEquals((long)collector.getPercentile(40), 39400);
42 AssertJUnit.assertEquals((long)collector.getMean(), 49500);
43 AssertJUnit.assertEquals((long)collector.getMin(), 0);
44
45 collector.reset();
46
47 AssertJUnit.assertEquals(collector.getNumDataPoints(), 0);
48 AssertJUnit.assertEquals((long)collector.getMax(), 0);
49 AssertJUnit.assertEquals((long)collector.getTotalSum(), 0);
50 AssertJUnit.assertEquals((long)collector.getPercentile(40), 0);
51 AssertJUnit.assertEquals((long)collector.getMean(), 0);
52 AssertJUnit.assertEquals((long)collector.getMin(), 0);
53
54 }
55 }