实时计算使用CREATE TABLE作为输出结果数据的格式定义,同时定义数据如何写入到目的数据结果表。

实时计算结果表有Append类型和Update类型。

  • Append类型:如果输出存储是日志系统、消息系统、或未定义主键的RDS数据库,数据流的输出结果会以追加的方式写入到存储中,不会修改存储中原有的数据。
  • Update类型:如果输出存储是声明了主键(primary key)的数据库(例如,RDS和HBase),数据流的输出结果有以下2种情况。
    • 如果根据主键查询的数据在数据库中不存在,则会将该数据插入数据库。
    • 如果根据主键查询的数据在数据库中存在,则会根据主键更新数据。

结果表语法

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='yourDatabaseURL',
tableName='yourTableName',
userName='yourDatabaseUserName',
password='yourDatabasePassword'
);