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

LAG

LAG 为记录返回表达式的计算结果 (例如列名),它是给定窗口中的当前记录之前的 N 条记录。根据当前记录计算偏移量和默认值。如果没有此类记录,LAG 将改为返回指定的默认表达式。LAG 返回与表达式的类型相同的值。

语法

LAG(expr [ , N [ , defaultExpr]]) [ IGNORE NULLS | RESPECT NULLS ] OVER [ window-definition ]

参数

expr

根据记录计算的表达式。

N

要查询的当前记录之前的记录的数目。默认为 1

defaultExpr

在查询的记录(当前记录之前的 n 条)位于窗口外部的情况下返回的与 expr 类型相同的表达式。如果未指定,则为位于窗口外部的值返回 null

注意

defaultExpr 表达式不会替换从源流返回的实际 null 值。

IGNORE NULLS

一个指定在确定偏移量时不计入 null 值的子句。例如,假设查询 LAG(expr, 1),并且上一条记录具有为 null 的 expr 值。随后,将查询之前的第二条记录,依此类推。

RESPECT NULLS

一个指定在确定偏移量时计入 null 值的子句。此行为是默认行为。

OVER window-specification

一个分割流中按时间范围间隔或记录数划分的记录的子句。窗口规范定义流中记录的划分方式 (按时间范围间隔或记录数)。

示例

示例数据集

以下示例基于示例股票数据集,后者是《Amazon Kinesis Analytics 开发人员指南》 中的入门练习的一部分。要运行每个示例,您需要具有示例股票代码输入流的 Amazon Kinesis Analytics 应用程序。要了解如何创建 Analytics 应用程序和配置示例股票代码输入流,请参阅《Amazon Kinesis Analytics 开发人员指南》 中的入门练习

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

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

示例 1:在 OVER 子句中返回前面的记录中的值

在此示例中,OVER 子句分割流中前面的按 1 分钟的时间范围间隔划分的记录。随后,LAG 函数从包含给定股票代码的前 2 条记录中检索价格值,如果 price 为 null,则跳过记录。

CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" ( ticker_symbol VARCHAR(4), price DOUBLE, previous_price DOUBLE, previous_price_2 DOUBLE); CREATE OR REPLACE PUMP "STREAM_PUMP" AS INSERT INTO "DESTINATION_SQL_STREAM" SELECT STREAM ticker_symbol, price, LAG(price, 1, 0) IGNORE NULLS OVER ( PARTITION BY ticker_symbol RANGE INTERVAL '1' MINUTE PRECEDING), LAG(price, 2, 0) IGNORE NULLS OVER ( PARTITION BY ticker_symbol RANGE INTERVAL '1' MINUTE PRECEDING) FROM "SOURCE_SQL_STREAM_001"

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

备注

LAG 不是 SQL:2008 标准的一部分。它是一个 Amazon Kinesis Data Analytics 流式 SQL 扩展。