MAX

返回窗口查询中一组值的最大值。窗口查询是按时间或行数定义的。有关窗口查询的信息，请参阅窗口式查询。

在使用 MAX 时，请注意以下事项：

如果您不使用该OVER子句，MAX则按聚合函数计算。在这种情况下，聚合查询必须包含GROUP BY 子句基于ROWTIME将流分组为有限行的单调表达式。否则，该组是无限流，查询将永远不会完成，也不会发出任何行。有关更多信息，请参阅聚合函数：
使用 GROUP BY 子句的窗口查询在翻滚窗口中处理行。有关更多信息，请参阅滚动窗口（使用 GROUP BY 的聚合）。
如果您使用该OVER子句，MAX则计算为分析函数。有关更多信息，请参阅分析函数：
使用 OVER 子句的窗口查询在滑动窗口中处理行。有关更多信息，请参阅滑动窗口

语法

滚动窗口式查询



MAX(number-expression) ... GROUP BY monotonic-expression | time-based-expression

滑动窗口式查询



MAX(number-expression) OVER window-specification

参数

number-expression

指定针对聚合中的每一行计算的值表达式。

OVER window-specification

将数据流中的记录除以时间范围间隔或行数。窗口规范定义流中记录的划分方式 (按时间范围间隔或行数)。

按单调表达分组 | time-based-expression

基于分组表达式的值为记录分组，从而针对在所有列中具有相同值的每组行返回一个摘要行。

示例

示例数据集

以下示例基于样本库存数据集，该数据集是 Amazon Kinesis Analytics 开发人员指南入门的一部分。要运行每个示例，您需要一个包含样本股票行情输入流的 Amazon Kinesis Analytics 应用程序。要了解如何创建分析应用程序和配置示例股票行情输入流，请参阅 Amazon Kinesis Analytics 开发者指南中的入门指南。

具有以下架构的示例股票数据集。



(ticker_symbol  VARCHAR(4),
sector          VARCHAR(16),
change          REAL,
price           REAL)

示例 1：使用 GROUP BY 子句返回最大值

在此示例中，聚合查询有一个GROUP BY子句ROWTIME，该子句将流分组为有限的行。随后，从 MAX 子句返回的行计算 GROUP BY 函数。

使用 STEP（推荐）



CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (
    ticker_symbol VARCHAR(4), 
    max_price     DOUBLE);

CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
  INSERT INTO "DESTINATION_SQL_STREAM" 
    SELECT STREAM 
        ticker_symbol,
        MAX(Price) AS max_price
    FROM "SOURCE_SQL_STREAM_001"
    GROUP BY ticker_symbol, STEP("SOURCE_SQL_STREAM_001".ROWTIME BY INTERVAL '60' SECOND);

使用 FLOOR



CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (
    ticker_symbol VARCHAR(4), 
    max_price     DOUBLE);
-- CREATE OR REPLACE PUMP to insert into output
CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
  INSERT INTO "DESTINATION_SQL_STREAM" 
    SELECT STREAM 
        ticker_symbol,
        MAX(Price) AS max_price
    FROM "SOURCE_SQL_STREAM_001"
    GROUP BY ticker_symbol, FLOOR("SOURCE_SQL_STREAM_001".ROWTIME TO MINUTE);

结果

上一示例输出的流与以下内容类似。

Table showing ROWTIME, TICKER_SYMBOL, and MAX_PRICE columns with sample data entries.

示例 2：使用 OVER 子句返回最大值

在此示例中，该OVER子句将分区流中的记录除以前 '1' 小时的时间范围间隔。随后，从 MAX 子句返回的行计算 OVER 函数。



CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (
    ticker_symbol VARCHAR(4),
    max_price     DOUBLE);
CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
    INSERT INTO "DESTINATION_SQL_STREAM"
    SELECT STREAM ticker_symbol, 
        MAX(price) OVER (
            PARTITION BY ticker_symbol
            RANGE INTERVAL '1' HOUR PRECEDING) AS max_price
    FROM "SOURCE_SQL_STREAM_001"

上一示例输出的流与以下内容类似。

Table showing stock ticker symbols QAZ, QXZ, MJN, WSB with corresponding timestamps and maximum prices.

使用说明

对于字符串值，MAX 通过排序序列中的最后一个字符串来确定。

如果 MAX 用作分析函数并且正在评估的窗口不包含任何行，则 MAX 返回空值。有关更多信息，请参阅分析函数：

MAX

语法