CREATE STREAM
CREATE STREAM 语句创建一个(本地)流。 此流的名称必须与同一架构中的任何其他流的名称不同。好的做法是包含流的描述。
与表类似,流也具有列,并且您可以在 CREATE STREAM 语句中指定这些列的数据类型。这些列应映射到您为其创建流的数据源。对于 column_name,可使用任何有效的非预留 SQL 名称。列值不能为 null。
-
指定 OR REPLACE 会重新创建流 (如果流已存在),启用对现有对象的定义更改,隐式删除它,而无需首先使用 DRP 命令。在具有正在传送的数据的流上使用 CREATE OR REPLACE 将终止流并丢失所有历史记录。
-
只有在指定 OR REPLACE 后才能指定 RENAME。
-
有关采用 type_specification 的类型和值的完整列表(如 TIMESTAMP、INTEGER 或 varchar(2)),请参阅《Amazon Kinesis Data Analytics SQL 参考指南》中的主题“Amazon Kinesis Data Analytics 数据类型”。
-
对于 option_value,可使用任何字符串。
未分析的日志数据的简单流
CREATE OR REPLACE STREAM logStream ( source VARCHAR(20), message VARCHAR(3072)) DESCRIPTION 'Head of webwatcher stream processing';
从 Intelligent Travel System 管道捕获传感器数据的流
CREATE OR REPLACE STREAM "LaneData" ( -- ROWTIME is time at which sensor data collected LDS_ID INTEGER, -- loop-detector ID LNAME VARCHAR(12), LNUM VARCHAR(4), OCC SMALLINT, VOL SMALLINT, SPEED DECIMAL(4,2) ) DESCRIPTION 'Conditioned LaneData for analysis queries';
从电子商务管道捕获订单数据的流
CREATE OR REPLACE STREAM "OrderData" ( "key_order" BIGINT NOT NULL, "key_user" BIGINT, "country" SMALLINT, "key_product" INTEGER, "quantity" SMALLINT, "eur" DECIMAL(19,5), "usd" DECIMAL(19,5) ) DESCRIPTION 'conditioned order data, ready for analysis';