[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14709840#comment-14709840
]
Navina Ramesh commented on SAMZA-676:
-
Works for me! :)
> Implement Broadcast Stream
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14709405#comment-14709405
]
Yan Fang commented on SAMZA-676:
Thanks, [~navina]. Committed it. (Without the isBroadcast
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706255#comment-14706255
]
Navina Ramesh commented on SAMZA-676:
-
{quote}
1. the sspToString and stringToSsp metho
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706161#comment-14706161
]
Yan Fang commented on SAMZA-676:
Need to change at least the following two parts:
1. the s
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705753#comment-14705753
]
Navina Ramesh commented on SAMZA-676:
-
[~closeuris] Which code are you referring to tha
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705688#comment-14705688
]
Yan Fang commented on SAMZA-676:
[~navina], thanks for the review. Fixed all issues you men
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14682325#comment-14682325
]
Navina Ramesh commented on SAMZA-676:
-
[~closeuris] I tried the patch on my mac and it
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14648038#comment-14648038
]
Yi Pan (Data Infrastructure) commented on SAMZA-676:
OK. It seems that
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14647994#comment-14647994
]
Yan Fang commented on SAMZA-676:
[~navina], yes, have the same problem in Linux, with java
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14647298#comment-14647298
]
Navina Ramesh commented on SAMZA-676:
-
Thanks, [~closeuris] !
Apart from some javadoc
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14595411#comment-14595411
]
Yan Fang commented on SAMZA-676:
Updates the patch according to [~navina]'s comments in RB.
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14592669#comment-14592669
]
Navina Ramesh commented on SAMZA-676:
-
[~closeuris] Left you some comment in the RB. Th
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588911#comment-14588911
]
Yan Fang commented on SAMZA-676:
Cool. Thanks, Navina.
> Implement Broadcast Stream
>
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588909#comment-14588909
]
Yan Fang commented on SAMZA-676:
Yes, I think so. If we define customized groupers, there s
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588895#comment-14588895
]
Ben Kirwin commented on SAMZA-676:
--
Wow, very glad to see progress on this! I haven't look
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588890#comment-14588890
]
Navina Ramesh commented on SAMZA-676:
-
Thanks, [~closeuris] ! I will into your patch to
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14570127#comment-14570127
]
Yan Fang commented on SAMZA-676:
First attempt RB: https://reviews.apache.org/r/34974/
1.
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14548569#comment-14548569
]
Yi Pan (Data Infrastructure) commented on SAMZA-676:
{quote}
This does
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14548373#comment-14548373
]
Guozhang Wang commented on SAMZA-676:
-
Yup.
> Implement Broadcast Stream
> ---
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546545#comment-14546545
]
Yan Fang commented on SAMZA-676:
{quote}
What I meant to say is "allow the consumer to regi
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546542#comment-14546542
]
Yan Fang commented on SAMZA-676:
Is it in the 0.9.0 Consumer redesign?
> Implement Broadca
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546344#comment-14546344
]
Yi Pan (Data Infrastructure) commented on SAMZA-676:
{quote}
Yi Pan (Da
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546298#comment-14546298
]
Navina Ramesh commented on SAMZA-676:
-
bq. I did not put it in the design doc is becau
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546151#comment-14546151
]
Guozhang Wang commented on SAMZA-676:
-
[~closeuris] Yeah with the current simple consum
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546147#comment-14546147
]
Yan Fang commented on SAMZA-676:
{quote}
GroupByPartition now takes the Config as a constru
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14546002#comment-14546002
]
Yi Pan (Data Infrastructure) commented on SAMZA-676:
{quote}
Yet, there
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545987#comment-14545987
]
Navina Ramesh commented on SAMZA-676:
-
Thanks for pointing it out [~twbecker] ! I was l
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545970#comment-14545970
]
Yi Pan (Data Infrastructure) commented on SAMZA-676:
Hi, [~closeuris],
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545644#comment-14545644
]
Tommy Becker commented on SAMZA-676:
As noted above this is what I did. The SystemStre
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14545640#comment-14545640
]
Tommy Becker commented on SAMZA-676:
GroupByPartition now takes the Config as a constru
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14544919#comment-14544919
]
Navina Ramesh commented on SAMZA-676:
-
bq. So broad-stream-partition0 will only be proc
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14544900#comment-14544900
]
Navina Ramesh commented on SAMZA-676:
-
[~closeuris] : To add to what [~nsomasun] sugges
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14544800#comment-14544800
]
Naveen Somasundaram commented on SAMZA-676:
---
[~closeuris], Thanks for the design!
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14544567#comment-14544567
]
Yan Fang commented on SAMZA-676:
Thank you, Tommy.
{quote}
GroupByPartition grouper to exc
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14544268#comment-14544268
]
Tommy Becker commented on SAMZA-676:
bq. This assumption is not always true: If two ta
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14544188#comment-14544188
]
Yan Fang commented on SAMZA-676:
{quote}
When an envelope for an SSP comes in, it loops ove
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14544127#comment-14544127
]
Tommy Becker commented on SAMZA-676:
I had started to implement this same feature a whi
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14543413#comment-14543413
]
Yan Fang commented on SAMZA-676:
Thanks for reviewing, Navina.
{quote}
I think usecase #3
[
https://issues.apache.org/jira/browse/SAMZA-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14542925#comment-14542925
]
Navina Ramesh commented on SAMZA-676:
-
Hi Yan,
I went through your design document and
39 matches
Mail list logo
