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

创建表格存储结果表(TableStore)

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

DDL定义

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

  1. CREATE RESULT TABLE user (
  2. id bigint,
  3. name string,
  4. age bigint
  5. PRIMARY KEY (id)
  6. ) WITH (
  7. type='ots',
  8. endpoint='http://ots-cn-hangzhou.aliyuncs.com',
  9. accessId='accessId',
  10. accessKey='accessKey',
  11. instance='instance',
  12. tableName='table'
  13. );

WITH参数

字段名称 说明
type 数据存储类型
accessId 能够读写该TableStore的accessId
accessKey 能够读写该TableStore的accessKey
endpoint TableStore的Endpoint,例如http://cn-hangzhou.ots.aliyuncs.com
instance TableStore的Instance名称
tableName TableStore的Table名称

注意:

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

  • TableStore作为结果表仅支持BIGINT、STRING两种类型,即所有的TableStore类型均在声明表创建时必须转换为BIGINT、STRING。

类型映射

TableStore字段类型 建议流计算字段类型
INTEGER Bigint
String String
Double Double

注意:

  • TableStore本身也不支持时间类型,因此在流计算场景,建议用户在TableStore使用的类型对应流计算类型即可。
本文导读目录