You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by gu...@apache.org on 2021/02/19 01:45:55 UTC
[spark] branch master updated: [MINOR][SQL][DOCS] Fix the comments
in the example at window function
This is an automated email from the ASF dual-hosted git repository.
gurwls223 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new 26548ed [MINOR][SQL][DOCS] Fix the comments in the example at window function
26548ed is described below
commit 26548edfa2445b009f63bbdbe810cdb6c289c18d
Author: yzjg <78...@qq.com>
AuthorDate: Fri Feb 19 10:45:21 2021 +0900
[MINOR][SQL][DOCS] Fix the comments in the example at window function
### What changes were proposed in this pull request?
`functions.scala` window function has an comment error in the field name. The column should be `time` per `timestamp:TimestampType`.
### Why are the changes needed?
To deliver the correct documentation and examples.
### Does this PR introduce _any_ user-facing change?
Yes, it fixes the user-facing docs.
### How was this patch tested?
CI builds in this PR should test the documentation build.
Closes #31582 from yzjg/yzjg-patch-1.
Authored-by: yzjg <78...@qq.com>
Signed-off-by: HyukjinKwon <gu...@apache.org>
---
sql/core/src/main/scala/org/apache/spark/sql/functions.scala | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/functions.scala b/sql/core/src/main/scala/org/apache/spark/sql/functions.scala
index 0f81693..2e1f0e5 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/functions.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/functions.scala
@@ -3487,7 +3487,7 @@ object functions {
*
* {{{
* val df = ... // schema => timestamp: TimestampType, stockId: StringType, price: DoubleType
- * df.groupBy(window($"time", "1 minute", "10 seconds", "5 seconds"), $"stockId")
+ * df.groupBy(window($"timestamp", "1 minute", "10 seconds", "5 seconds"), $"stockId")
* .agg(mean("price"))
* }}}
*
@@ -3543,7 +3543,7 @@ object functions {
*
* {{{
* val df = ... // schema => timestamp: TimestampType, stockId: StringType, price: DoubleType
- * df.groupBy(window($"time", "1 minute", "10 seconds"), $"stockId")
+ * df.groupBy(window($"timestamp", "1 minute", "10 seconds"), $"stockId")
* .agg(mean("price"))
* }}}
*
@@ -3588,7 +3588,7 @@ object functions {
*
* {{{
* val df = ... // schema => timestamp: TimestampType, stockId: StringType, price: DoubleType
- * df.groupBy(window($"time", "1 minute"), $"stockId")
+ * df.groupBy(window($"timestamp", "1 minute"), $"stockId")
* .agg(mean("price"))
* }}}
*
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org