Repository: spark
Updated Branches:
  refs/heads/branch-1.2 8ecabf4b7 -> c4abb2eb4


[DOC][PySpark][Streaming] Fix docstring for sphinx

This commit should be merged for 1.2 release.
cc tdas

Author: Ken Takagiwa <ugw.gi.wo...@gmail.com>

Closes #3311 from giwa/patch-3 and squashes the following commits:

ab474a8 [Ken Takagiwa] [DOC][PySpark][Streaming] Fix docstring for sphinx

(cherry picked from commit 9b7bbcef8863ecd69e7511825ef9c93d8632dac2)
Signed-off-by: Tathagata Das <tathagata.das1...@gmail.com>


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/c4abb2eb
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/c4abb2eb
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/c4abb2eb

Branch: refs/heads/branch-1.2
Commit: c4abb2eb4f6a2875bbe22b12c246d8ae1773ece2
Parents: 8ecabf4
Author: Ken Takagiwa <ugw.gi.wo...@gmail.com>
Authored: Wed Nov 19 14:23:18 2014 -0800
Committer: Tathagata Das <tathagata.das1...@gmail.com>
Committed: Wed Nov 19 15:52:10 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/c4abb2eb/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-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org

Reply via email to