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 <785246...@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 <785246...@qq.com> 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 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-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org