全部产品
存储与CDN 数据库 安全 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 开发者工具 解决方案 物联网 钉钉智能硬件
流计算

数据结果表概念

更新时间:2017-11-23 18:23:51

流计算使用CREATE TABLE作为输出结果数据的格式定义,同时定义数据如何写出到目的数据存储。流计算有Append类型和Update类型.

  • Append类型。如果输出存储是日志系统,或消息系统,或者未定义主键的RDS,那么流的输出结果都会以追加的方式写入存储中,而不会修改存储钟原有的数据。

  • Update类型。输出存储是声明了主键(使用PRIMARY KEY)的数据库,比如带主键的RDS,HBase 等。那么流的输出结果,如果根据主键查询数据在数据库中不存在,则会将该数据插入到数据库;如果根据主键查询数据在数据库中存在,则会根据主键更新数据。

语法:

  1. CREATE TABLE tableName
  2. (columnName dataType [, columnName dataType ]*)
  3. [ WITH (propertyName=propertyValue [, propertyName=propertyValue ]*) ];

示例:

  1. create table rds_output(
  2. id int,
  3. len int,
  4. content VARCHAR,
  5. primary key(id)
  6. ) with (
  7. type='rds',
  8. url='jdbc:mysql:XXXXXXXXXX',
  9. tableName='test4',
  10. userName='test',
  11. password='XXXXXX'
  12. );
本文导读目录