[ https://issues.apache.org/jira/browse/FLINK-2626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14732182#comment-14732182 ]
ASF GitHub Bot commented on FLINK-2626: --------------------------------------- GitHub user HuangWHWHW opened a pull request: https://github.com/apache/flink/pull/1096 [FLINK-2626][CORE]add averageaccumulator Add class averageaccumulator for FLINK-accumulator. And test for it. You can merge this pull request into a Git repository by running: $ git pull https://github.com/HuangWHWHW/flink FLINK-2626 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/1096.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #1096 ---- commit 7064b080e991999ed6d599b4d2c630bbc50720c7 Author: HuangWHWHW <404823...@qq.com> Date: 2015-09-06T04:15:12Z [FLINK-2626][CORE]add averageaccumulator ---- > Add a AverageAccumulator for FLINK-Accumulator > ---------------------------------------------- > > Key: FLINK-2626 > URL: https://issues.apache.org/jira/browse/FLINK-2626 > Project: Flink > Issue Type: New Feature > Components: Core > Affects Versions: 0.10 > Reporter: Huang Wei > Fix For: 0.10 > > Original Estimate: 168h > Remaining Estimate: 168h > > Add a AverageAccumulator for Flink-Accumulator to calculate the average of > values. > The feature is like Storm-MultiReducedMetric. > Feature in detail: > 1.This class is named AverageAccumulator(any suggestion? I`m not good at > English name) and implements SimpleAccumulator. > 2.This class support long, integer and double input. > 3.This class will return a double value as the average when the method > getLocalValue() called. > 4.Member method description: > * add(): > A variety of add() method to support different inputs(e.g. Double, double, > Long, long, Integer, int). > It will add the input value and make the count + 1 each time. > * public Double getLocalValue(): > To return the sum of value dividing count as average and the result will be > "double". > * public void resetLocal(): > To reset the value and count. > It won`t be called automatically and it will be better to call this every > time the getLocalValue() method called. > * public void merge(Accumulator<Double, Double> other): > To merge another accumulator(only support AverageAccumulator). > * public AverageAccumulator clone(): > To return the whole current AverageAccumulator class. -- This message was sent by Atlassian JIRA (v6.3.4#6332)