[jira] [Commented] (FLINK-4029) Multi-field "sum" function just like "keyBy"
[ https://issues.apache.org/jira/browse/FLINK-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15410705#comment-15410705 ] Ivan Mushketyk commented on FLINK-4029: --- Hi, Can anyone give an advice about how this should be implemented? > Multi-field "sum" function just like "keyBy" > > > Key: FLINK-4029 > URL: https://issues.apache.org/jira/browse/FLINK-4029 > Project: Flink > Issue Type: Improvement > Components: DataStream API >Reporter: Rami >Assignee: Ivan Mushketyk >Priority: Minor > > I can use keyBy as follows: > stream.keyBy(“pojo.field1”,”pojo.field2”,…) > Would make sense that I can use sum for example, to do its job for more than > one field: > stream.sum(“pojo.field1”,”pojo.field2”,…) -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4029) Multi-field "sum" function just like "keyBy"
[ https://issues.apache.org/jira/browse/FLINK-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15390679#comment-15390679 ] Ivan Mushketyk commented on FLINK-4029: --- I am new to Flink, so I am a little bit confused about what would be the best way to implement this features. Should I implement it on top of existing operators/streams or should I add a new operator/stream? Should I add the "sum" method to DataStream class or to one of the specialized streams? > Multi-field "sum" function just like "keyBy" > > > Key: FLINK-4029 > URL: https://issues.apache.org/jira/browse/FLINK-4029 > Project: Flink > Issue Type: Improvement > Components: DataStream API >Reporter: Rami >Assignee: Ivan Mushketyk >Priority: Minor > > I can use keyBy as follows: > stream.keyBy(“pojo.field1”,”pojo.field2”,…) > Would make sense that I can use sum for example, to do its job for more than > one field: > stream.sum(“pojo.field1”,”pojo.field2”,…) -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4029) Multi-field "sum" function just like "keyBy"
[ https://issues.apache.org/jira/browse/FLINK-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15378271#comment-15378271 ] Ivan Mushketyk commented on FLINK-4029: --- Gabor, This should be very helpful! Thank you for your suggestion. > Multi-field "sum" function just like "keyBy" > > > Key: FLINK-4029 > URL: https://issues.apache.org/jira/browse/FLINK-4029 > Project: Flink > Issue Type: Improvement > Components: DataStream API >Reporter: Rami >Assignee: Ivan Mushketyk >Priority: Minor > > I can use keyBy as follows: > stream.keyBy(“pojo.field1”,”pojo.field2”,…) > Would make sense that I can use sum for example, to do its job for more than > one field: > stream.sum(“pojo.field1”,”pojo.field2”,…) -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4029) Multi-field "sum" function just like "keyBy"
[ https://issues.apache.org/jira/browse/FLINK-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15378269#comment-15378269 ] Ivan Mushketyk commented on FLINK-4029: --- Rami, Thank you for your reply, it is clear now. > Multi-field "sum" function just like "keyBy" > > > Key: FLINK-4029 > URL: https://issues.apache.org/jira/browse/FLINK-4029 > Project: Flink > Issue Type: Improvement > Components: DataStream API >Reporter: Rami >Assignee: Ivan Mushketyk >Priority: Minor > > I can use keyBy as follows: > stream.keyBy(“pojo.field1”,”pojo.field2”,…) > Would make sense that I can use sum for example, to do its job for more than > one field: > stream.sum(“pojo.field1”,”pojo.field2”,…) -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4029) Multi-field "sum" function just like "keyBy"
[ https://issues.apache.org/jira/browse/FLINK-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15367631#comment-15367631 ] Gabor Gevay commented on FLINK-4029: You might want to reuse the FieldAccessor infrastructure that is in this PR: https://github.com/apache/flink/pull/2094 > Multi-field "sum" function just like "keyBy" > > > Key: FLINK-4029 > URL: https://issues.apache.org/jira/browse/FLINK-4029 > Project: Flink > Issue Type: Improvement > Components: DataStream API >Reporter: Rami >Assignee: Ivan Mushketyk >Priority: Minor > > I can use keyBy as follows: > stream.keyBy(“pojo.field1”,”pojo.field2”,…) > Would make sense that I can use sum for example, to do its job for more than > one field: > stream.sum(“pojo.field1”,”pojo.field2”,…) -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4029) Multi-field "sum" function just like "keyBy"
[
https://issues.apache.org/jira/browse/FLINK-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15364203#comment-15364203
]
Rami commented on FLINK-4029:
-
Sure, thanks for working on this:
So if we have pojo for example with those fields:
int count=1;
int bytesConsumed=32898;
Now I have a stream of those pojos. I want to be able to do:
.sum ("count","bytesConsumed")
which will sum all count values together and all bytesConsumed together. and I
end up with the count of all and the sum of all the bytes consumed ( of course
within the defined window)
> Multi-field "sum" function just like "keyBy"
>
>
> Key: FLINK-4029
> URL: https://issues.apache.org/jira/browse/FLINK-4029
> Project: Flink
> Issue Type: Improvement
> Components: DataStream API
>Reporter: Rami
>Assignee: Ivan Mushketyk
>Priority: Minor
>
> I can use keyBy as follows:
> stream.keyBy(“pojo.field1”,”pojo.field2”,…)
> Would make sense that I can use sum for example, to do its job for more than
> one field:
> stream.sum(“pojo.field1”,”pojo.field2”,…)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Commented] (FLINK-4029) Multi-field "sum" function just like "keyBy"
[ https://issues.apache.org/jira/browse/FLINK-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15355830#comment-15355830 ] Ivan Mushketyk commented on FLINK-4029: --- Could you please provide an example of how this would look like, just to make sure that we are on the same page? > Multi-field "sum" function just like "keyBy" > > > Key: FLINK-4029 > URL: https://issues.apache.org/jira/browse/FLINK-4029 > Project: Flink > Issue Type: Improvement > Components: DataStream API >Reporter: Rami >Assignee: Ivan Mushketyk >Priority: Minor > > I can use keyBy as follows: > stream.keyBy(“pojo.field1”,”pojo.field2”,…) > Would make sense that I can use sum for example, to do its job for more than > one field: > stream.sum(“pojo.field1”,”pojo.field2”,…) -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-4029) Multi-field "sum" function just like "keyBy"
[ https://issues.apache.org/jira/browse/FLINK-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15351815#comment-15351815 ] Ivan Mushketyk commented on FLINK-4029: --- I will work on this. > Multi-field "sum" function just like "keyBy" > > > Key: FLINK-4029 > URL: https://issues.apache.org/jira/browse/FLINK-4029 > Project: Flink > Issue Type: Improvement > Components: DataStream API >Reporter: Rami >Priority: Minor > > I can use keyBy as follows: > stream.keyBy(“pojo.field1”,”pojo.field2”,…) > Would make sense that I can use sum for example, to do its job for more than > one field: > stream.sum(“pojo.field1”,”pojo.field2”,…) -- This message was sent by Atlassian JIRA (v6.3.4#6332)
