This project has retired. For details please refer to its
Attic page.
TestDoubleAggregators xref
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.giraph.aggregators;
19
20 import static org.junit.Assert.assertEquals;
21 import static org.junit.Assert.assertNotNull;
22
23 import org.apache.hadoop.io.DoubleWritable;
24 import org.junit.Test;
25
26 public class TestDoubleAggregators {
27
28 @Test
29 public void testMaxAggregator() {
30 DoubleMaxAggregator max = new DoubleMaxAggregator();
31 max.aggregate(new DoubleWritable(2.0));
32 max.aggregate(new DoubleWritable(3.0));
33 assertEquals(3.0, max.getAggregatedValue().get(), 0d);
34 max.setAggregatedValue(new DoubleWritable(1.0));
35 assertEquals(1.0, max.getAggregatedValue().get(), 0d);
36 DoubleWritable dw = max.createInitialValue();
37 assertNotNull(dw);
38 }
39
40 @Test
41 public void testMinAggregator() {
42 DoubleMinAggregator min = new DoubleMinAggregator();
43 min.aggregate(new DoubleWritable(3.0));
44 min.aggregate(new DoubleWritable(2.0));
45 assertEquals(2.0, min.getAggregatedValue().get(), 0d);
46 min.setAggregatedValue(new DoubleWritable(3.0));
47 assertEquals(3.0, min.getAggregatedValue().get(), 0d);
48 DoubleWritable dw = min.createInitialValue();
49 assertNotNull(dw);
50 }
51
52 @Test
53 public void testOverwriteAggregator() {
54 DoubleOverwriteAggregator overwrite = new DoubleOverwriteAggregator();
55 overwrite.aggregate(new DoubleWritable(1.0));
56 assertEquals(1.0, overwrite.getAggregatedValue().get(), 0d);
57 overwrite.aggregate(new DoubleWritable(2.0));
58 assertEquals(2.0, overwrite.getAggregatedValue().get(), 0d);
59 overwrite.setAggregatedValue(new DoubleWritable(3.0));
60 assertEquals(3.0, overwrite.getAggregatedValue().get(), 0d);
61 DoubleWritable dw = overwrite.createInitialValue();
62 assertNotNull(dw);
63 }
64
65 @Test
66 public void testProductAggregator() {
67 DoubleProductAggregator product = new DoubleProductAggregator();
68 product.aggregate(new DoubleWritable(6.0));
69 product.aggregate(new DoubleWritable(7.0));
70 assertEquals(42.0, product.getAggregatedValue().get(), 0d);
71 product.setAggregatedValue(new DoubleWritable(1.0));
72 assertEquals(1.0, product.getAggregatedValue().get(), 0d);
73 DoubleWritable dw = product.createInitialValue();
74 assertNotNull(dw);
75 }
76
77 @Test
78 public void testSumAggregator() {
79 DoubleSumAggregator sum = new DoubleSumAggregator();
80 sum.aggregate(new DoubleWritable(1.0));
81 sum.aggregate(new DoubleWritable(2.0));
82 assertEquals(3.0, sum.getAggregatedValue().get(), 0d);
83 sum.setAggregatedValue(new DoubleWritable(4.0));
84 assertEquals(4.0, sum.getAggregatedValue().get(), 0d);
85 DoubleWritable dw = sum.createInitialValue();
86 assertNotNull(dw);
87 }
88
89 }