[jira] [Created] (FLINK-2144) Implement count, average, and variance for windows

Gabor Gevay created FLINK-2144: -- Summary: Implement count, average, and variance for windows Key: FLINK-2144 URL: https://issues.apache.org/jira/browse/FLINK-2144 Project: Flink Issue Type:

[jira] [Updated] (FLINK-2142) GSoC project: Exact and Approximate Statistics for Data Streams and Windows

[ https://issues.apache.org/jira/browse/FLINK-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-2142: --- Description: The goal of this project is to implement basic statistics of data streams and windows

[jira] [Updated] (FLINK-2145) Median calculation for windows

[ https://issues.apache.org/jira/browse/FLINK-2145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-2145: --- Description: The PreReducer for this has the following algorithm: We maintain two multisets (as, for

[jira] [Created] (FLINK-2147) Approximate calculation of frequencies in data streams

Gabor Gevay created FLINK-2147: -- Summary: Approximate calculation of frequencies in data streams Key: FLINK-2147 URL: https://issues.apache.org/jira/browse/FLINK-2147 Project: Flink Issue Type:

[jira] [Updated] (FLINK-2144) Implement count, average, and variance for windows

[ https://issues.apache.org/jira/browse/FLINK-2144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay updated FLINK-2144: --- Description: By count I mean the number of elements in the window. These can be implemented very

[jira] [Resolved] (FLINK-2114) PunctuationPolicy.toString() throws NullPointerException if extractor is null

[ https://issues.apache.org/jira/browse/FLINK-2114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay resolved FLINK-2114. Resolution: Fixed PunctuationPolicy.toString() throws NullPointerException if extractor is null

[jira] [Created] (FLINK-2121) FileInputFormat.addFilesInDir miscalculates total size

Gabor Gevay created FLINK-2121: -- Summary: FileInputFormat.addFilesInDir miscalculates total size Key: FLINK-2121 URL: https://issues.apache.org/jira/browse/FLINK-2121 Project: Flink Issue Type:

[jira] [Created] (FLINK-2114) PunctuationPolicy.toString() throws NullPointerException if extractor is null

Gabor Gevay created FLINK-2114: -- Summary: PunctuationPolicy.toString() throws NullPointerException if extractor is null Key: FLINK-2114 URL: https://issues.apache.org/jira/browse/FLINK-2114 Project:

[jira] [Commented] (FLINK-2039) Streaming API's sum(String) does not work for Tuples

[ https://issues.apache.org/jira/browse/FLINK-2039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14548386#comment-14548386 ] Gabor Gevay commented on FLINK-2039: Since I am about to refactor the relevant code

[jira] [Assigned] (FLINK-1670) Collect method for streaming

[ https://issues.apache.org/jira/browse/FLINK-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay reassigned FLINK-1670: -- Assignee: Gabor Gevay Collect method for streaming

[jira] [Assigned] (FLINK-1797) Add jumping pre-reducer for Count and Time windows

[ https://issues.apache.org/jira/browse/FLINK-1797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay reassigned FLINK-1797: -- Assignee: Gabor Gevay Add jumping pre-reducer for Count and Time windows

[jira] [Commented] (FLINK-1797) Add jumping pre-reducer for Count and Time windows

[ https://issues.apache.org/jira/browse/FLINK-1797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14385396#comment-14385396 ] Gabor Gevay commented on FLINK-1797: May I have a go at this issue? By jumping window

[jira] [Assigned] (FLINK-1767) StreamExecutionEnvironment's execute should return JobExecutionResult

[ https://issues.apache.org/jira/browse/FLINK-1767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Gevay reassigned FLINK-1767: -- Assignee: Gabor Gevay StreamExecutionEnvironment's execute should return JobExecutionResult

[jira] [Commented] (FLINK-1617) GSoC project: Query optimisation layer for Flink Streaming

[ https://issues.apache.org/jira/browse/FLINK-1617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14355858#comment-14355858 ] Gabor Gevay commented on FLINK-1617: Hello! I am also interested in working on this

<    1   2   3