You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2017/03/22 11:10:12 UTC
spark git commit: [SPARK-20021][PYSPARK] Miss backslash in python code
Repository: spark
Updated Branches:
refs/heads/master 7343a0940 -> facfd6088
[SPARK-20021][PYSPARK] Miss backslash in python code
## What changes were proposed in this pull request?
Add backslash for line continuation in python code.
## How was this patch tested?
Jenkins.
Author: uncleGen <hu...@gmail.com>
Author: dylon <hu...@gmail.com>
Closes #17352 from uncleGen/python-example-doc.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/facfd608
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/facfd608
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/facfd608
Branch: refs/heads/master
Commit: facfd608865c385c0dabfe09cffe5874532a9cdf
Parents: 7343a09
Author: uncleGen <hu...@gmail.com>
Authored: Wed Mar 22 11:10:08 2017 +0000
Committer: Sean Owen <so...@cloudera.com>
Committed: Wed Mar 22 11:10:08 2017 +0000
----------------------------------------------------------------------
docs/structured-streaming-programming-guide.md | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/facfd608/docs/structured-streaming-programming-guide.md
----------------------------------------------------------------------
diff --git a/docs/structured-streaming-programming-guide.md b/docs/structured-streaming-programming-guide.md
index 7988472..ff07ad1 100644
--- a/docs/structured-streaming-programming-guide.md
+++ b/docs/structured-streaming-programming-guide.md
@@ -764,11 +764,11 @@ Dataset<Row> windowedCounts = words
words = ... # streaming DataFrame of schema { timestamp: Timestamp, word: String }
# Group the data by window and word and compute the count of each group
-windowedCounts = words
- .withWatermark("timestamp", "10 minutes")
+windowedCounts = words \
+ .withWatermark("timestamp", "10 minutes") \
.groupBy(
window(words.timestamp, "10 minutes", "5 minutes"),
- words.word)
+ words.word) \
.count()
{% endhighlight %}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org