数据结果表概述

更新时间：2022-09-14 18:27:39

实时计算 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'
);

本文转自实时计算——数据结果表概述

上一篇 : ：Python的环境变量设置下一篇 : AdoHelper使用MySQL存储过程示例

相关阅读

推荐文章