全部产品
阿里云办公

数据结果表概述

更新时间:2018-09-29 14:47:14

实时计算 Flink使用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. );