This is an automated email from the ASF dual-hosted git repository. gurwls223 pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/branch-3.0 by this push: new d67f67b [MINOR][SQL][DOCS] Fix the comments in the example at window function d67f67b is described below commit d67f67bd52dbfe1fa163352a7d1dcd49137b9302 Author: yzjg <785246...@qq.com> AuthorDate: Fri Feb 19 10:45:21 2021 +0900 [MINOR][SQL][DOCS] Fix the comments in the example at window function `functions.scala` window function has an comment error in the field name. The column should be `time` per `timestamp:TimestampType`. To deliver the correct documentation and examples. Yes, it fixes the user-facing docs. CI builds in this PR should test the documentation build. Closes #31582 from yzjg/yzjg-patch-1. Authored-by: yzjg <785246...@qq.com> Signed-off-by: HyukjinKwon <gurwls...@apache.org> (cherry picked from commit 26548edfa2445b009f63bbdbe810cdb6c289c18d) Signed-off-by: HyukjinKwon <gurwls...@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 ff8ee25..bb77c7e 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 @@ -3208,7 +3208,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")) * }}} * @@ -3264,7 +3264,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")) * }}} * @@ -3309,7 +3309,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-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org