INSERT - Amazon Kinesis Data Analytics

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

INSERT

INSERT 用于在流中插入行。它也可以在泵中使用,将一个流的输出插入另一个流。

语法

<insert statement> :=   INSERT [ EXPEDITED ]   INTO  <table-name > [ ( insert-column-specification ) ]   <  query  > <insert-column-specification> := < simple-identifier-list > <simple-identifier-list> :=    <simple-identifier> [ , < simple-identifier-list > ]

有关价值观的讨论,请参见SELECT

抽像管插入到表中

也可以将 INSERT 指定为创建泵语句的一部分。

CREATE PUMP "HighBidsPump" AS INSERT INTO "highBids" ( "ticker", "shares", "price") SELECT  "ticker", "shares", "price" FROM SALES.bids WHERE "shares"*"price">100000

在这里,要插入到 “HighBids” 流中的结果应来自计算结果为数据流的 UNION ALL 表达式。这将创建一个持续运行的直播插页。插入的行的行时将继承自 select 或 UNION ALL 输出的行的行数。同样,如果其他插入器在此插入器之前插入的行时间晚于该插入器最初准备的行,则最初可能会删除行,因为这样后者就会超出时间顺序。请参阅本指南创建泵中的主题。