实时计算 Flink使用CREATE TABLE作为输出结果数据的格式定义，同时定义数据如何写入到目的数据存储。实时计算有Append类型和Update类型。
-
Append类型：如果输出存储是日志系统或消息系统，或未定义主键的RDS，则流的输出结果都会以追加的方式写入存储中，而不会修改存储中原有的数据。
-
Update类型：如果输出存储是声明了主键（PRIMARY KEY）的数据库（例如RDS、HBase），流的输出结果会发生以下两种情况。
- 如果根据主键查询数据在数据库中不存在，则会将该数据插入到数据库。
- 如果根据主键查询数据在数据库中存在，则会根据主键更新数据。
语法
CREATE TABLE tableName(columnName dataType [, columnName dataType ]*)[ WITH (propertyName=propertyValue [, propertyName=propertyValue ]*) ];
示例
create table rds_output(id int,len int,content VARCHAR,primary key(id)) with (type='rds',url='jdbc:mysql:XXXXXXXXXX',tableName='test4',userName='test',password='XXXXXX');
本文转自实时计算——
数据结果表概述
