資料結果表概述

實時計算 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. );

本文轉自實時計算——

資料結果表概述