TOP_K_K_K_Top_K_Top_K_Top_Top - Amazon Kinesis Data Analytics
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

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

TOP_K_K_K_Top_K_Top_K_Top_Top

在滚动窗口中返回在指定应用程序内部流列中出现的最常出现的值。这可用于查找指定列中的趋势(最常用)值。

例如,入门练习使用提供持续股票价格更新的演示流(ticker_symbol、价格、变化和其他列)。假设您希望在每个 1 分钟的翻滚窗口中找到三个最常交易的股票。您可以使用此函数来查找这些代码符号。

在使用 TOP_K_ITEMS_TUMBLING 时,请注意以下事项:

  • 计算流源上的每个传入记录并不高效,因此该函数接近最频繁出现的值。例如,在寻找交易量最多的三种股票时,该函数可能会返回五种交易量最大的股票中的三种。

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

有关分步指导的示例应用程序,请参阅最常出现的值

Syntax

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

Parameters

以下部分介绍参数。

应用程序内流指针

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

CURSOR(SELECT STREAM * FROM InputStream)

columnName

应用程序内部流中要用于计算 TopK 值的列名。请记下有关列名称的以下内容:

注意

列名称必须用单引号 (') 括起。例如:'column1'

K

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

windowSize

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

Examples

示例数据集

以下示例基于示例股票数据集,后者是开始使用中的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 ) );

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