[
https://issues.apache.org/jira/browse/SPARK-10320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15004052#comment-15004052
]
Cody Koeninger commented on SPARK-10320:
This is for practical purposes blocked on SPARK-10963
>
[
https://issues.apache.org/jira/browse/SPARK-10320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14790804#comment-14790804
]
Sudarshan Kadambi commented on SPARK-10320:
---
Sure, a function as proposed that allows for the
[
https://issues.apache.org/jira/browse/SPARK-10320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14790843#comment-14790843
]
Cody Koeninger commented on SPARK-10320:
I don't think there's much benefit to multiple dstreams
[
https://issues.apache.org/jira/browse/SPARK-10320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14725687#comment-14725687
]
Sudarshan Kadambi commented on SPARK-10320:
---
"That's not the way checkpoints work. ..."
Sure,
[
https://issues.apache.org/jira/browse/SPARK-10320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14725951#comment-14725951
]
Sudarshan Kadambi commented on SPARK-10320:
---
"it's almost certainly not the same thread".
Yes,
[
https://issues.apache.org/jira/browse/SPARK-10320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14726076#comment-14726076
]
Cody Koeninger commented on SPARK-10320:
You would supply a function, similar to the way
[
https://issues.apache.org/jira/browse/SPARK-10320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14725719#comment-14725719
]
Cody Koeninger commented on SPARK-10320:
So if you're changing topics in an event handler, it's
[
https://issues.apache.org/jira/browse/SPARK-10320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14724113#comment-14724113
]
Cody Koeninger commented on SPARK-10320:
It's possible this might be solvable with a
