全部产品
存储与CDN 数据库 安全 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 开发者工具 解决方案 物联网 钉钉智能硬件
流计算

创建分析型数据库(AnalyticDB)结果表

更新时间:2017-12-29 15:20:00

DDL定义

流计算支持使用AnalyticDB作为结果输出,示例代码如下:

  1. CREATE RESULT TABLE user (
  2. id bigint,
  3. name string,
  4. age bigint,
  5. PRIMARY KEY (id)
  6. ) WITH (
  7. type='ads',
  8. url='jdbc:mysql://localhost:3306/javademo',
  9. username='username',
  10. password='password',
  11. tableName='table'
  12. );

WITH参数

字段名称 说明
type 类型,这里必须是ads
username 能够读写该AnalyticDB的用户名
password 能够读写该AnalyticDB的密码
url 该AnalyticDB库的jdbc连接串信息,采用jdbc格式填写
tableName 该AnalyticDB的数据表名称

注意:

  • AnalyticDB结果表须定义有PrimaryKey,输出数据以Update方式追加到现有AnalyticDB表,即必须搭配使用REPLACE INTO进行写入。

类型映射

ADS字段类型 建议流计算字段类型
float/double Double
varchar String
tinyint/smallint/int/bigint Bigint
timestamp String

注意:

  • 目前流计算暂不支持timestamp类型,建议用户使用String类型的’YYYY-mm-dd hh:mi:ss’向AnalyticDB写入。
本文导读目录