diff options
author | Jon Bratseth <bratseth@yahoo-inc.com> | 2016-11-23 14:08:35 +0100 |
---|---|---|
committer | Jon Bratseth <bratseth@yahoo-inc.com> | 2016-11-23 14:08:35 +0100 |
commit | f65c80a1fb5fdc285ce0db63b3b1f039f5201505 (patch) | |
tree | c767fe82963a3c29276078e0d8f588a126a7cca6 /vespajlib | |
parent | 015cedfb6dbd15dec60602ba3082198502d1c5d9 (diff) |
Parse join
Diffstat (limited to 'vespajlib')
-rw-r--r-- | vespajlib/src/main/java/com/yahoo/tensor/functions/ReduceFunction.java | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/vespajlib/src/main/java/com/yahoo/tensor/functions/ReduceFunction.java b/vespajlib/src/main/java/com/yahoo/tensor/functions/ReduceFunction.java index 146459b328f..6e339f91497 100644 --- a/vespajlib/src/main/java/com/yahoo/tensor/functions/ReduceFunction.java +++ b/vespajlib/src/main/java/com/yahoo/tensor/functions/ReduceFunction.java @@ -142,8 +142,8 @@ public class ReduceFunction extends PrimitiveTensorFunction { private static class AvgAggregator extends ValueAggregator { - private int valueCount; - private double valueSum; + private int valueCount = 0; + private double valueSum = 0.0; @Override public void aggregate(double value) { @@ -160,7 +160,7 @@ public class ReduceFunction extends PrimitiveTensorFunction { private static class CountAggregator extends ValueAggregator { - private int valueCount; + private int valueCount = 0; @Override public void aggregate(double value) { @@ -176,7 +176,7 @@ public class ReduceFunction extends PrimitiveTensorFunction { private static class ProdAggregator extends ValueAggregator { - private double valueProd; + private double valueProd = 1.0; @Override public void aggregate(double value) { @@ -192,7 +192,7 @@ public class ReduceFunction extends PrimitiveTensorFunction { private static class SumAggregator extends ValueAggregator { - private double valueSum; + private double valueSum = 0.0; @Override public void aggregate(double value) { @@ -229,7 +229,7 @@ public class ReduceFunction extends PrimitiveTensorFunction { @Override public void aggregate(double value) { - if (value > minValue) + if (value < minValue) minValue = value; } |