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

表格存储

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

DDL定义

实时计算 Flink支持使用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. );

注意:

  • 推荐使用数据存储功能,参见表格存储
  • valueColumns的值不能是声明的主键,可以是主键之外的任意字段。

WITH参数

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

类型映射

OTS字段类型 实时计算字段类型
integer bigint
string varchar
boolean boolean
double double

注意:

  • TableStore结果表须定义有PrimaryKey,输出数据以Update方式追加到现有TableStore表。

本文转自实时计算——创建表格存储(Table Store)结果表
上一篇:离线数据同步神器:DataX,支持几乎所有异构数据源的离线同步到MaxCompute


下一篇:WCF RESTful服务的Google Protocol Buffers超媒体类型