diff options
| author | Ken Takagiwa <ugw.gi.world@gmail.com> | 2014-11-19 14:23:18 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2014-11-19 15:52:10 -0800 |
| commit | c4abb2eb4f6a2875bbe22b12c246d8ae1773ece2 (patch) | |
| tree | 0fa5b6916b4acee2071f1264460f0f7aad22d8d6 /python/pyspark | |
| parent | 8ecabf4b7678d788faba6a202e883855be0c9f99 (diff) | |
| download | spark-c4abb2eb4f6a2875bbe22b12c246d8ae1773ece2.tar.gz spark-c4abb2eb4f6a2875bbe22b12c246d8ae1773ece2.tar.bz2 spark-c4abb2eb4f6a2875bbe22b12c246d8ae1773ece2.zip | |
[DOC][PySpark][Streaming] Fix docstring for sphinx
This commit should be merged for 1.2 release.
cc tdas
Author: Ken Takagiwa <ugw.gi.world@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.das1565@gmail.com>
Diffstat (limited to 'python/pyspark')
| -rw-r--r-- | python/pyspark/streaming/context.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/python/pyspark/streaming/context.py b/python/pyspark/streaming/context.py index 2f53fbd27b..d48f3598e3 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): |