本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。
WINDOW 子句 (滑动窗口)
滑动窗口查询的WINDOW子句指定了在一组行上计算与当前行相关的分析函数的行。这些聚合函数生成一个输出行，该输出行由每个输入行的一列或多列中的键汇总。查询中的WINDOW子句指定了按时间范围间隔或行数分区的流中的记录，以及该PARTITION BY子句指定的其他可选列集。您可以定义可用于分析函数和流式JOIN子句的命名或行内窗口规范。有关分析函数的更多信息，请参阅分析函数。
滑动窗口查询中的聚合函数是针对子OVER句中指定的每一列执行的。该OVER子句可以引用命名的窗口规范，也可以作为泵SELECT语句的一部分进行内联。以下示例说明如何使用 OVER 子句引用指定的窗口规范并在 SELECT 语句中内联使用。
语法
[WINDOW window_name AS ( {PARTITION BY partition_name RANGE INTERVAL 'interval' {SECOND | MINUTE | HOUR} PRECEDING | ROWS number PRECEDING , …} )
OVER 子句
以下示例说明如何使用 OVER 子句引用指定的窗口规范。
示例 1：引用指定的窗口规范的 OVER
以下示例显示了一个聚合函数，该函数引用了名为 W1 的窗口规范。在此示例中，平均价格是根据W1窗口规格指定的记录集计算得出的。要了解有关如何将 OVER 子句与窗口规范结合使用的更多信息，请参阅示例。
AVG(price) OVER W1 AS avg_price
示例 2：引用内联窗口规范的 OVER
以下示例显示了引用内联窗口规范的聚合函数。在此示例中，使用行内窗口规格计算每个输入行的平均价格。要了解有关如何将 OVER 子句与窗口规范结合使用的更多信息，请参阅示例。
AVG(price) OVER ( PARTITION BY ticker_symbol RANGE INTERVAL '1' HOUR PRECEDING) AS avg_price
有关聚合函数和 OVER 子句的更多信息，请参阅聚合函数。
参数
window-name
指定可以从 OVER 子句或后续窗口定义中引用的唯一名称。该名称用于分析函数和流式JOIN子句中。有关分析函数的更多信息，请参阅分析函数。
AS
为 WINDOW 子句定义指定的窗口规范。
PARTITION BY partition-name
将行组织到共享相同值的组中。在对行进行划分后，窗口函数将计算当前行所在划分中的所有行。
RANGE INTERVAL 'interval' {SECOND | MINUTE | HOUR} PRECEDING
指定时间范围间隔中的窗口边界。窗口函数将计算具有与当前行相同的时间间隔的所有行。
ROWS number PRECEDING
根据行数指定窗口边界。窗口函数将计算在相同行数内的所有行。
示例
示例数据集
以下示例基于样本库存数据集，该数据集是 Amazon Kinesis Analytics 开发人员指南入门的一部分。要运行每个示例，您需要一个包含样本股票行情输入流的 Amazon Kinesis Analytics 应用程序。要了解如何创建分析应用程序和配置示例股票行情输入流，请参阅 Amazon Kinesis Analytics 开发者指南中的入门指南。有关其他示例，请参阅滑动窗口。
具有以下架构的示例股票数据集。
(ticker_symbol VARCHAR(4), sector VARCHAR(16), change REAL, price REAL)
示例 1：引用了指定的窗口规范的基于时间的滑动窗口
此示例定义了一个命名的窗口规范，其分区边界为当前行前一分钟。数据泵的 OVER 语句的 SELECT 子句引用指定的窗口规范。
WINDOW W1 AS ( PARTITION BY ticker_symbol RANGE INTERVAL '1' MINUTE PRECEDING);
要运行此示例，请创建股票示例应用程序，并运行和保存以下 SQL 代码。
CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" ( ticker_symbol VARCHAR(4), min_price DOUBLE, max_price DOUBLE, avg_price DOUBLE); CREATE OR REPLACE PUMP "STREAM_PUMP" AS INSERT INTO "DESTINATION_SQL_STREAM" SELECT STREAM ticker_symbol, MIN(price) OVER W1 AS min_price, MAX(price) OVER W1 AS max_price, AVG(price) OVER W1 AS avg_price FROM "SOURCE_SQL_STREAM_001" WINDOW W1 AS ( PARTITION BY ticker_symbol RANGE INTERVAL '1' MINUTE PRECEDING);
上一示例输出的流与以下内容类似。
示例 2：引用了指定的窗口规范的基于行的滑动窗口
此示例定义了一个命名窗口规范，其分区边界为当前行前两行，当前行前十行。数据泵的 OVER 语句的 SELECT 子句引用指定的窗口规范。
WINDOW last2rows AS (PARTITION BY ticker_symbol ROWS 2 PRECEDING), last10rows AS (PARTITION BY ticker_symbol ROWS 10 PRECEDING);
要运行此示例，请创建股票示例应用程序，并运行和保存以下 SQL 代码。
CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" ( ticker_symbol VARCHAR(4), price DOUBLE, avg_last2rows DOUBLE, avg_Last10rows DOUBLE); CREATE OR REPLACE PUMP "myPump" AS INSERT INTO "DESTINATION_SQL_STREAM" SELECT STREAM ticker_symbol, price, AVG(price) OVER last2rows, AVG(price) OVER last10rows FROM SOURCE_SQL_STREAM_001 WINDOW last2rows AS (PARTITION BY ticker_symbol ROWS 2 PRECEDING), last10rows AS (PARTITION BY ticker_symbol ROWS 10 PRECEDING);
上一示例输出的流与以下内容类似。
示例 3：带内联窗口规范的基于时间的滑动窗口
此示例定义了行内窗口规范，其分区边界为当前行前一分钟。数据泵的 OVER 语句的 SELECT 子句使用内联窗口规范。
要运行此示例，请创建股票示例应用程序，并运行和保存以下 SQL 代码。
CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" ( ticker_symbol VARCHAR(4), price DOUBLE, avg_price DOUBLE); CREATE OR REPLACE PUMP "STREAM_PUMP" AS INSERT INTO "DESTINATION_SQL_STREAM" SELECT STREAM ticker_symbol, price, AVG(Price) OVER ( PARTITION BY ticker_symbol RANGE INTERVAL '1' HOUR PRECEDING) AS avg_price FROM "SOURCE_SQL_STREAM_001"
上一示例输出的流与以下内容类似。
使用说明
对于 WINDOW 子句和终端节点，Amazon Kinesis Analytics SQL 在某个范围内遵循窗口的 SQL-2008 标准。
要包括 1 小时的终端节点，您可以使用以下窗口语法。
WINDOW HOUR AS (RANGE INTERVAL '1' HOUR PRECEDING)
要排除上一个小时的终端节点，您可以使用以下窗口语法。
WINDOW HOUR AS (RANGE INTERVAL '59:59.999' MINUTE TO SECOND(3) PRECEDING);
有关更多信息，请参阅允许和不允许的窗口规格：