[jira] [Commented] (SPARK-8389) Expose KafkaRDDs offsetRange in Java and Python

[ https://issues.apache.org/jira/browse/SPARK-8389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14594196#comment-14594196 ] Cody Koeninger commented on SPARK-8389: --- Have you guys been looking at SPARK-8337 ,

[jira] [Commented] (SPARK-8389) Expose KafkaRDDs offsetRange in Java and Python

[ https://issues.apache.org/jira/browse/SPARK-8389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14594186#comment-14594186 ] Tathagata Das commented on SPARK-8389: -- Yeah, that is harder to do. Let at least get

[jira] [Commented] (SPARK-8389) Expose KafkaRDDs offsetRange in Java and Python

[ https://issues.apache.org/jira/browse/SPARK-8389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14592879#comment-14592879 ] Saisai Shao commented on SPARK-8389: OK, let me think a bit on this, but this can only

[jira] [Commented] (SPARK-8389) Expose KafkaRDDs offsetRange in Java and Python

[ https://issues.apache.org/jira/browse/SPARK-8389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14592314#comment-14592314 ] Tathagata Das commented on SPARK-8389: -- I think the way it works is that the Java/Pyt

[jira] [Commented] (SPARK-8389) Expose KafkaRDDs offsetRange in Java and Python

[ https://issues.apache.org/jira/browse/SPARK-8389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14591211#comment-14591211 ] Saisai Shao commented on SPARK-8389: I'm not saying its impossible to do it, from my u

[jira] [Commented] (SPARK-8389) Expose KafkaRDDs offsetRange in Java and Python

[ https://issues.apache.org/jira/browse/SPARK-8389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14591170#comment-14591170 ] Cody Koeninger commented on SPARK-8389: --- Static type doesn't really matter since it'

[jira] [Commented] (SPARK-8389) Expose KafkaRDDs offsetRange in Java and Python

[ https://issues.apache.org/jira/browse/SPARK-8389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14591152#comment-14591152 ] Saisai Shao commented on SPARK-8389: I think for python API, it is not easy to add equ

[jira] [Commented] (SPARK-8389) Expose KafkaRDDs offsetRange in Java and Python

[ https://issues.apache.org/jira/browse/SPARK-8389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588451#comment-14588451 ] Tathagata Das commented on SPARK-8389: -- Then lets atleast add it to the examples and

[jira] [Commented] (SPARK-8389) Expose KafkaRDDs offsetRange in Java and Python

[ https://issues.apache.org/jira/browse/SPARK-8389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588404#comment-14588404 ] Cody Koeninger commented on SPARK-8389: --- So on the java side, just so I'm clear, are

[jira] [Commented] (SPARK-8389) Expose KafkaRDDs offsetRange in Java and Python

[ https://issues.apache.org/jira/browse/SPARK-8389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588397#comment-14588397 ] Apache Spark commented on SPARK-8389: - User 'koeninger' has created a pull request for

[jira] [Commented] (SPARK-8389) Expose KafkaRDDs offsetRange in Java and Python

[ https://issues.apache.org/jira/browse/SPARK-8389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588202#comment-14588202 ] Cody Koeninger commented on SPARK-8389: --- There's already a ticket for the Python sid