diff options
| author | uncleGen <hustyugm@gmail.com> | 2017-03-22 11:10:08 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2017-03-22 11:10:08 +0000 |
| commit | facfd608865c385c0dabfe09cffe5874532a9cdf (patch) | |
| tree | 1c3ae0b1e5765b16d059ed5ca0c9947caa06d49a /docs/structured-streaming-programming-guide.md | |
| parent | 7343a09401e7d6636634968b1cd8bc403a1f77b6 (diff) | |
| download | spark-facfd608865c385c0dabfe09cffe5874532a9cdf.tar.gz spark-facfd608865c385c0dabfe09cffe5874532a9cdf.tar.bz2 spark-facfd608865c385c0dabfe09cffe5874532a9cdf.zip | |
[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 <hustyugm@gmail.com>
Author: dylon <hustyugm@gmail.com>
Closes #17352 from uncleGen/python-example-doc.
Diffstat (limited to 'docs/structured-streaming-programming-guide.md')
| -rw-r--r-- | docs/structured-streaming-programming-guide.md | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/docs/structured-streaming-programming-guide.md b/docs/structured-streaming-programming-guide.md index 7988472378..ff07ad1194 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 %} |