使用CREATE STREAM创建Lindorm流表_云原生多模数据库 Lindorm(Lindorm)-阿里云帮助中心

创建一张数据流表，表示一个无界的事件集合。数据流表仅支持新增数据，不支持更新数据和删除数据。数据流表中的最小单元为Record，Record有预定义的Schema。数据流表的物理数据存储在流存储的某个指定的Topic上，具体的存储格式可以在With语句中指定。

语法

CREATE STREAM (IF NOT EXISTS) table_name
                   ('(' tableElement (',' tableElement)* ')')
                   (WITH tableProperties)

tableElement
    : columnDefinition
    ;

columnDefinition
    : identifier type (NOT NULL) (COMMENT string) (WITH properties)
    ;

tableProperties
    : '(' tableProperty (',' tableProperty)* ')'
    ;

tableProperty
    : identifier EQ expression
    ;

参数说明

参数	是否必选	说明
table_name	是	数据流表的名称。
tableElement	是	定义数据流表的列，格式为：`列名列的数据类型`。
tableProperties	是	指定数据流表的属性，包括以下配置项： VALUE_FORMAT：必选项，指定数据源写入Lindorm流引擎的数据格式，包括CSV、Avro、JSON等格式。 KEY_VALUE：必选项，指定数据流表的主键列。 STREAM_TOPIC：必选项，指定数据流表的物理数据存储在流存储的某个Topic上。 TIMESTAMP：可选项，指定时间戳列。

示例

CREATE STREAM users_original (
  registertime bigint,
  gender varchar,
  regionid varchar,
  userid varchar)
WITH (
    stream_topic='users',
    value_format='JSON',
    key_value = 'userid'
);