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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336921#comment-17336921 ] Flink Jira Bot commented on FLINK-2147: --- This issue was labeled "stale-major" 7 ago and has not

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17328984#comment-17328984 ] Flink Jira Bot commented on FLINK-2147: --- This major issue is unassigned and itself and all of its

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825067#comment-16825067 ] Felipe Oliveira Gutierrez commented on FLINK-2147: -- Hi [~aljoscha], [~till.rohrmann],

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981414#comment-15981414 ] Gábor Hermann commented on FLINK-2147: -- I would prefer emitting updates on a window basis, as a Flink

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15972600#comment-15972600 ] Aljoscha Krettek commented on FLINK-2147: - The problem is now: when do you emit results from this?

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15972596#comment-15972596 ] Aljoscha Krettek commented on FLINK-2147: - Yes, I think over partitioning according to the number

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955166#comment-15955166 ] Gabor Gevay commented on FLINK-2147: Maybe we could over-partition the sketch into maxParallelism

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955164#comment-15955164 ] Stavros Kontopoulos commented on FLINK-2147: You just pick one of the sketches merge it with

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955147#comment-15955147 ] Aljoscha Krettek commented on FLINK-2147: - Yes, but what I'm saying is that it is not easy to deal

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955103#comment-15955103 ] Stavros Kontopoulos commented on FLINK-2147: I think Count-min sketch can be implemented in

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15955036#comment-15955036 ] Aljoscha Krettek commented on FLINK-2147: - If I'm not mistaken, a count-min sketch or similar

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15953422#comment-15953422 ] Stavros Kontopoulos commented on FLINK-2147: [~aljoscha]What is your suggestion for this? >

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15291006#comment-15291006 ] Gabor Gevay commented on FLINK-2147: > From a first look, something like StreamGroupedFold would be

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15289498#comment-15289498 ] Stavros Kontopoulos commented on FLINK-2147: How do you want to move on? collaborate on a

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15288771#comment-15288771 ] Stavros Kontopoulos commented on FLINK-2147: >From a first look, something like

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284484#comment-15284484 ] Stavros Kontopoulos commented on FLINK-2147: ok i will have a look as well to get familiar

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284479#comment-15284479 ] Gabor Gevay commented on FLINK-2147: Yes. We should probably look in the direction of FoldFunction,

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284476#comment-15284476 ] Stavros Kontopoulos commented on FLINK-2147: Ok i agree then we calculate statistics per

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284468#comment-15284468 ] Gabor Gevay commented on FLINK-2147: (Note that the out-of-order problem that I mentioned for the

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284467#comment-15284467 ] Gabor Gevay commented on FLINK-2147: In my opinion, the semantics would be to calculate the statistic

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284446#comment-15284446 ] Stavros Kontopoulos commented on FLINK-2147: Ok so if there multiple windows evaluated at

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284440#comment-15284440 ] Stavros Kontopoulos commented on FLINK-2147: For sure if you apply it per window then you need

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284437#comment-15284437 ] Gabor Gevay commented on FLINK-2147: I'm actually now closing the incremental median and similar

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284431#comment-15284431 ] Stavros Kontopoulos commented on FLINK-2147: Ok... btw I was looking your old PR for median

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284427#comment-15284427 ] Gabor Gevay commented on FLINK-2147: OK, we can certainly think about it. It would probably make

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284410#comment-15284410 ] Stavros Kontopoulos commented on FLINK-2147: Yes i agree the api is the hard part, but we

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284406#comment-15284406 ] Gabor Gevay commented on FLINK-2147: Yes, I think it would be very good if you worked on this, and

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15284312#comment-15284312 ] Gabor Gevay commented on FLINK-2147: Unfortunately, no. > Approximate calculation of frequencies in

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

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15283961#comment-15283961 ] Stavros Kontopoulos commented on FLINK-2147: Anyone working on this? > Approximate