COUNT - Amazon Kinesis Data Analytics
语法参数示例使用说明相关主题
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅中国的 Amazon Web Services 服务入门。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

COUNT

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

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

  • 如果你不使用OVER子句，COUNT以聚合函数的形式计算。在这种情况下，聚合查询必须包含GROUP BY 子句在基于以下条件的单调表达式上ROWTIME它将流分组为有限的行。否则，该组是无限流，查询将永远不会完成，也不会发出任何行。有关更多信息，请参阅 聚合函数。

  • 使用 GROUP BY 子句的窗口式查询处理滚动窗口中的行。有关更多信息，请参阅滚动窗口（使用 GROUP BY 的聚合）。

  • 如果您将OVER子句，COUNT以分析函数的形式计算。有关更多信息，请参阅 分析函数。

  • 使用 OVER 子句的窗口式查询处理滑动窗口中的行。有关更多信息，请参阅滑动窗口

语法

滚动窗口式查询


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

滑动窗口式查询


COUNT(* | ALL number-expression) OVER window-specification

参数

*

对所有行进行计数。

ALL

计算所有行。ALL 是默认值。

number-expression

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

OVER window-specification

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

GROUP B单调表达式|time-based-expression

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

示例

示例数据集

以下示例基于样本股票数据集，该数据集是其中的一部分开始使用在里面Amazon Kinesis Analytics. 要运行每个示例，您需要一个具有示例股票行情输入流的 Amazon Kinesis Analytics 应用程序。要了解如何创建 Analytics 创建Analytics开始使用在里面Amazon Kinesis Analytics.

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


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

示例 1：使用 GROUP BY 子句返回值的数量

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

使用 STEP（推荐）


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

CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
  INSERT INTO "DESTINATION_SQL_STREAM" 
    SELECT STREAM 
        ticker_symbol,
        COUNT(Price) AS count_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), 
    count_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,
        COUNT(Price) AS count_price
    FROM "SOURCE_SQL_STREAM_001"
    GROUP BY ticker_symbol, FLOOR("SOURCE_SQL_STREAM_001".ROWTIME TO MINUTE);

结果

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

示例 2：使用 OVER 子句返回值的数量

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


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

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

使用说明

Amazon Kinesis Analytics 不支持FILTER子句COUNT函数或使用COUNT DISTINCT在聚合函数或分析函数中。有关聚合函数和分析函数的更多信息，请参阅聚合函数和分析函数. 此功能偏离了 SQL:2008 标准。

当用作分析函数时，COUNT如果被评估的窗口不包含任何行，则返回零。有关更多信息，请参阅 分析函数。COUNT 还会为 a 返回零PARTITION BY子句，窗口内与输入行匹配的分区不包含任何行。有关 PARTITION BY 的更多信息，请参阅 WINDOW 子句 (滑动窗口)。

COUNT忽略一组值或数值表达式中的空值。例如，以下各项返回值 3：

  • COUNT(1, 2, 3) = 3

  • COUNT(1,null, 2, null, 3, null) = 3

相关主题