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

创建表格存储结果表(Table Store)

更新时间:2017-12-20 18:37:46

什么是表格存储(TableStore)

表格存储(Table Store)是构建在阿里云飞天分布式系统之上的分布式NoSQL数据存储服务,根据99.99%的高可用以及11个9的数据可靠性的标准设计。表格存储通过数据分片和负载均衡技术,实现数据规模与访问并发上的无缝扩展,提供海量结构化数据的存储和实时访问。

DDL定义

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

  1. CREATE TABLE stream_test_hotline_agent (
  2. name varchar,
  3. age BIGINT,
  4. birthday BIGINT,
  5. primary key(name,age)
  6. ) WITH (
  7. type='ots',
  8. instanceName='bliXXXXst',
  9. tableName='users2',
  10. accessId='LTXXXXXXz48ke',
  11. accessKey='prc1bXXXXXXX6oPZd9gidXDY',
  12. endPoint='http://XXXXXXXXou.ots.aliyuncs.com',
  13. valueColumns='biXXXXay'
  14. );

WITH参数

参数 注释说明 备注
instanceName 实例名
tableName 表名
endPoint 实例访问地址
accessId 访问的id
accessKey 访问的键
valueColumns 普通字段,多个以逗号分割
bufferSize 去重的buffer大小 可选,默认值5000,表示输入的数据达到5000条就开始输出
batchWriteTimeoutMs 写超时时间 可选,单位毫秒,默认值5000,表示数据超过了5秒,还没有往ots写过,就会将缓存的数据都写一次
batchSize 每次写的批次大小 可选,默认值100
retryIntervalMs 重试间隔时间 可选,单位毫秒,默认值1000
maxRetryTimes 最大重试次数 可选,默认值100
ignoreDelete 是否忽略delete操作 默认为false

注意:

  • TableStore结果表须定义有PrimaryKey,输出数据以Update方式追加到现有TableStore表
本文导读目录