Uploaded image for project: 'Spark'
  1. Spark
  2. SPARK-5946

Add Python API for Kafka direct stream

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.3.0
    • Fix Version/s: 1.4.0
    • Component/s: DStreams, PySpark
    • Labels:
      None
    • Target Version/s:

      Description

      Add the Python API for Kafka direct stream. Currently only adds createDirectStream API, no createRDD API, since it needs some Python wraps of Java object, will improve this according to the comments.

        Issue Links

          Activity

          Hide
          apachespark Apache Spark added a comment -

          User 'jerryshao' has created a pull request for this issue:
          https://github.com/apache/spark/pull/4723

          Show
          apachespark Apache Spark added a comment - User 'jerryshao' has created a pull request for this issue: https://github.com/apache/spark/pull/4723

            People

            • Assignee:
              jerryshao Saisai Shao
              Reporter:
              jerryshao Saisai Shao
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Development