GitHub user djalova opened a pull request:
https://github.com/apache/spark/pull/9186
[SPARK-6328] [pyspark]
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/djalova/spark SPARK-6328
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/spark/pull/9186.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #9186
----
commit a63ef33188c14796dc0ca662448443ca2f8bb423
Author: Daniel Jalova <[email protected]>
Date: 2015-10-06T00:12:31Z
Added skeleton classes for listener.py
commit 5b3da813b5fb4d71de335db8de756a0f52f3bcf7
Author: Daniel Jalova <[email protected]>
Date: 2015-10-12T17:35:18Z
Merge remote-tracking branch 'upstream/master' into SPARK-6328
commit f6c91e9b06e238b3d8e8671705124e1f42a44b73
Author: Daniel Jalova <[email protected]>
Date: 2015-10-12T17:37:16Z
Added skeleton class for Python API streamingListener
commit 1e6a87e6adf940e72c0e9048130b349067c16b73
Author: Daniel Jalova <[email protected]>
Date: 2015-10-13T17:07:48Z
Added listener.py to __init__.py
commit 2579f644bafc231a50f14ab814b14e2253bc991a
Author: Daniel Jalova <[email protected]>
Date: 2015-10-13T23:15:20Z
Working implementation of StreamingListener for Python API. Need to
implement StreamingListenerEvent
commit afad086208676578d586c2a4b8450cfb17d0eec2
Author: Daniel Jalova <[email protected]>
Date: 2015-10-14T19:19:37Z
Modified signature for addStreamingListener to match Scala API, added
comment.
commit 3523e1fd406c8f8ef0c65ef044ad5beaa14cf2e2
Author: Daniel Jalova <[email protected]>
Date: 2015-10-14T21:29:34Z
Merge remote-tracking branch 'upstream/master' into SPARK-6328
commit 7d50848f19a2f000f5fb7c6f63ece799d39ddada
Author: Daniel Jalova <[email protected]>
Date: 2015-10-16T19:06:27Z
Refactored StreamingListener methods and added getEventInfo.
commit 9d66e81211bd600bc5ff8940a1cb9abb3c624b16
Author: Daniel Jalova <[email protected]>
Date: 2015-10-20T19:39:16Z
Added test_batch_info_reports() to streaming/tests.py
commit aa87c40aedb3cbaf3b3dce93ddd224dd01a1dd7c
Author: Daniel Jalova <[email protected]>
Date: 2015-10-20T21:31:15Z
Fixed merge conflicts
----
---
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 [email protected] or file a JIRA ticket
with INFRA.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
