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.

        Attachments

          Activity

            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: