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

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

TOP_K_ITEMS_TUMBLING 函数

返回滚动窗口中指定的应用程序内流列中最常出现的值。这可用于在指定列中查找趋势（最受欢迎）值。

例如，入门练习使用演示流，提供持续的股价更新（ticker_symbol、价格、变动和其他列）。假设你想在每1分钟的暴跌窗口中找到三只最常交易的股票。您可以使用此功能来查找这些股票代码。

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

  • 计算流媒体源上的每条传入记录效率不高，因此该函数会近似最常出现的值。例如，在搜索交易量最大的三只股票时，该函数可能会返回五只交易量最大的股票中的三只。

此函数在一个滚动窗口内运行。您可以将窗口大小指定为参数。

对于示例应用程序，请使用 step-by-step 说明，请参阅最常出现的值.

语法

TOP_K_ITEMS_TUMBLING (
      in-application-streamPointer,
      'columnName',     
      K,
      windowSize,
   )

参数

以下各节介绍了这些参数。

in-application-stream指针

指向应用程序内部流的指针。您可以使用 CURSOR 函数设置指针。例如，以下语句将指针设置为 InputStream.

CURSOR(SELECT STREAM * FROM InputStream)

columnName

应用程序内流中要用来计算 TopK 值的列名。请注意有关Columnn的以下内容：

注意

列名必须用单引号 (') 出现。例如，'column1'。

K

使用此参数，您可以指定要返回特定列中最常出现的值的数量。值 K 必须大于或等于 1 且不能超过 100000。

窗口大小

翻滚窗口的大小，以秒为单位。大小必须大于或等于 1 秒，且不得超过 3600 秒 (1 小时)。

示例

示例数据集

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

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


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

示例 1：返回最常出现的值

以下示例在入门教程中创建的示例流中检索最常出现的值。

CREATE OR REPLACE STREAM DESTINATION_SQL_STREAM (
  "TICKER_SYMBOL" VARCHAR(4), 
  "MOST_FREQUENT_VALUES" BIGINT
);

CREATE OR REPLACE PUMP "STREAM_PUMP" AS 
    INSERT INTO "DESTINATION_SQL_STREAM"
    SELECT STREAM * 
        FROM TABLE (TOP_K_ITEMS_TUMBLING(
            CURSOR(SELECT STREAM * FROM "SOURCE_SQL_STREAM_001"),
            'TICKER_SYMBOL',         -- name of column in single quotes
            5,                       -- number of the most frequently occurring values
            60                       -- tumbling window size in seconds
            )
        );

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