[ https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15477990#comment-15477990 ]
Daniel Blazevski edited comment on FLINK-2144 at 9/9/16 8:49 PM: ----------------------------------------------------------------- Hi, I am curious to know the status of this issue. I have worked on Flink-ML a bit, and recently contributed to Flink's documentation of its Window API. If possible, I would like to work on this. I looked into the code and saw how "sum" is implemented, and I assume average and variance should be implemented in similar ways (with 2 versions, one taking a string another an integer). Count, of course, is more simple in that it counts the number of data points (not two different inputs) [~aljoscha][~ggevay] was (Author: danielblazevski): Hi, I am curious to know the status of this issue. I have worked on Flink-ML a bit, and recently contributed to Flink's documentation of its Window API. If possible, I would like to work on this. I looked into the code and saw how "sum" is implemented, and I assume average and variance should be implemented in similar ways (with 2 versions, one taking a string another an integer). Count, of course, is more simple in that it counts the number of data points (not two different inputs) > Incremental count, average, and variance for windows > ---------------------------------------------------- > > Key: FLINK-2144 > URL: https://issues.apache.org/jira/browse/FLINK-2144 > Project: Flink > Issue Type: New Feature > Components: Streaming > Reporter: Gabor Gevay > Priority: Minor > Labels: statistics > > By count I mean the number of elements in the window. > These can be implemented very efficiently building on FLINK-2143: > Store: O(1) > Evict: O(1) > emitWindow: O(1) -- This message was sent by Atlassian JIRA (v6.3.4#6332)