You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by td...@apache.org on 2014/11/19 23:26:33 UTC
spark git commit: [DOC][PySpark][Streaming] Fix docstring for sphinx
Repository: spark
Updated Branches:
refs/heads/master 1c938413b -> 9b7bbcef8
[DOC][PySpark][Streaming] Fix docstring for sphinx
This commit should be merged for 1.2 release.
cc tdas
Author: Ken Takagiwa <ug...@gmail.com>
Closes #3311 from giwa/patch-3 and squashes the following commits:
ab474a8 [Ken Takagiwa] [DOC][PySpark][Streaming] Fix docstring for sphinx
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/9b7bbcef
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/9b7bbcef
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/9b7bbcef
Branch: refs/heads/master
Commit: 9b7bbcef8863ecd69e7511825ef9c93d8632dac2
Parents: 1c93841
Author: Ken Takagiwa <ug...@gmail.com>
Authored: Wed Nov 19 14:23:18 2014 -0800
Committer: Tathagata Das <ta...@gmail.com>
Committed: Wed Nov 19 14:23:18 2014 -0800
----------------------------------------------------------------------
python/pyspark/streaming/context.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/9b7bbcef/python/pyspark/streaming/context.py
----------------------------------------------------------------------
diff --git a/python/pyspark/streaming/context.py b/python/pyspark/streaming/context.py
index 2f53fbd..d48f359 100644
--- a/python/pyspark/streaming/context.py
+++ b/python/pyspark/streaming/context.py
@@ -142,8 +142,8 @@ class StreamingContext(object):
recreated from the checkpoint data. If the data does not exist, then the provided setupFunc
will be used to create a JavaStreamingContext.
- @param checkpointPath Checkpoint directory used in an earlier JavaStreamingContext program
- @param setupFunc Function to create a new JavaStreamingContext and setup DStreams
+ @param checkpointPath: Checkpoint directory used in an earlier JavaStreamingContext program
+ @param setupFunc: Function to create a new JavaStreamingContext and setup DStreams
"""
# TODO: support checkpoint in HDFS
if not os.path.exists(checkpointPath) or not os.listdir(checkpointPath):
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org