spark-reviews mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zsxwing <>
Subject [GitHub] spark pull request: [SPARK-5155] [PySpark] [Streaming] Mqtt stream...
Date Fri, 31 Jul 2015 16:27:50 GMT
GitHub user zsxwing opened a pull request:

    [SPARK-5155] [PySpark] [Streaming] Mqtt streaming support in Python

    This PR is based on #4229, thanks @prabeesh.
    Closes #4229

You can merge this pull request into a Git repository by running:

    $ git pull pr4229

Alternatively you can review and apply these changes as the patch at:

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #7833
commit b7d42ff3aef06b54b168bd8868b6012de3116aa2
Author: prabs <>
Date:   2015-02-03T19:47:38Z

    Mqtt streaming support in Python

commit 3aa7fffdd6ce15cc0b1c2625d7fa92f04543e8fb
Author: prabs <>
Date:   2015-02-03T19:48:17Z

    Added Python streaming mqtt word count example

commit b34c3c117fbec0d5cbdca32037c72ee4c8fb7110
Author: prabs <>
Date:   2015-02-05T20:12:28Z

    adress comments

commit 3f4df12d28ca8db7d010e5897591b1a553f2de43
Author: Prabeesh K <>
Date:   2015-03-29T16:54:05Z

    updated version

commit ee387ae4ab190d24ba8ad4d36eeeb7cf957b89ab
Author: Prabeesh K <>
Date:   2015-04-22T10:39:59Z

    Fix assembly jar location of mqtt-assembly

commit 795ec275b50894c25f10c11e5e37f4b96c35062d
Author: Prabeesh K <>
Date:   2015-06-23T19:20:32Z

    address comments

commit a11968b2277a18bc384d44ff17631463aa56eb13
Author: Prabeesh K <>
Date:   2015-06-29T16:31:45Z

    fixed python style

commit 9767d82b46037aeb9d8af8e825a1e6a237ca5673
Author: Prabeesh K <>
Date:   2015-07-06T15:40:03Z

    implemented Python-friendly class

commit a5a8f9f6e900a9efe683be50d25979ed4867e311
Author: Prabeesh K <>
Date:   2015-07-10T13:29:24Z

    added Python test

commit e1ee0163a7a09c5e64baea2c549126ca2b451f56
Author: Prabeesh K <>
Date:   2015-07-11T06:04:26Z

    scala style fix

commit 1f0cfe9617128cf091fdc4afefd7839c3acbaa47
Author: Prabeesh K <>
Date:   2015-07-11T06:26:40Z

    python style fix

commit 80474d1893e9296827be44879d7205b6c738ded4
Author: Prabeesh K <>
Date:   2015-07-11T08:51:50Z


commit 97244ec63937f6c23990f73b054af3d450344bb8
Author: zsxwing <>
Date:   2015-07-22T18:09:25Z

    Make sbt build the assembly test jar for streaming mqtt

commit 87fc6771586aaf025c2810b5fa3a160a9773c4d2
Author: Prabeesh K <>
Date:   2015-07-23T10:00:14Z

    address the comments:
    	keep the whole MQTTTestUtils in test and then link to test jar from python
    	fix issue under Maven build
    	return JavaDStream[String] directly.

commit a6747cb58f504bd681162bba67e0679b33b42915
Author: Prabeesh K <>
Date:   2015-07-24T12:20:46Z

    wait for starting the receiver before publishing data

commit d07f45490a9554c1e3ea9c76956f383a511a2e1f
Author: zsxwing <>
Date:   2015-07-26T08:07:04Z

    Register StreamingListerner before starting StreamingContext; Revert unncessary changes;
fix the python unit test

commit b90b709b90aa5066d69b2d5cb26332d1c32d4f4b
Author: Prabeesh K <>
Date:   2015-07-26T08:21:33Z

    Merge pull request #1 from zsxwing/pr4229
    Register StreamingListerner before starting StreamingContext; Revert …

commit 126608a02b55287684762811b0ade99dbce7d109
Author: Prabeesh K <>
Date:   2015-07-30T10:02:24Z

    address the comments

commit 734db994475e936388919fa9e623f4fb19b0b902
Author: zsxwing <>
Date:   2015-07-31T01:31:49Z

    Merge branch 'master' into pr4229

commit 5f8a1d435526a601d0c435359df2b42ccc4dbbb3
Author: zsxwing <>
Date:   2015-07-31T08:19:14Z

    Make the maven build generate the test jar for Python MQTT tests


If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at or file a JIRA ticket
with INFRA.

To unsubscribe, e-mail:
For additional commands, e-mail:

View raw message