本文为您介绍如何创建实时计算表格存储(Table Store)结果表以及表格存储和实时计算字段类型之间的映射关系。

什么是表格存储 TableStore

表格存储 TableStore,简称OTS,是基于阿里云飞天分布式系统的分布式NoSQL数据存储服务。表格存储通过数据分片和负载均衡技术,实现数据规模与访问并发上的无缝扩展,提供海量结构化数据的存储和实时访问服务。

DDL定义

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

CREATE TABLE stream_test_hotline_agent (
 name VARCHAR,
 age BIGINT,
 birthday BIGINT,
 PRIMARY KEY (name,age)
) WITH (
 type='ots',
 instanceName='<yourInstanceName>',
 tableName='<yourTableName>',
 accessId='<yourAccessId>',
 accessKey='<yourAccessSecret>',
 endPoint='<yourEndpoint>',
 valueColumns='birthday'
);        
说明
  • 推荐使用数据存储注册功能,参见表格存储注册表格存储(TableStore)
  • valueColumns的值不能是声明的主键,可以是主键之外的任意字段。
  • OTS结果表声明中,除主键列外,至少包含一个属性列。

WITH参数

参数 说明 备注
instanceName 实例名
tableName 表名
endPoint 实例访问地址 参见 服务地址
accessId 访问的id
accessKey 访问的键
valueColumns 指定插入的字段列名 插入多个字段以,分割。如'ID,NAME'
bufferSize 流入多少条数据后开始去重 可选,默认值5000,表示输入的数据达到5000条就开始输出。
batchWriteTimeoutMs 写入超时的时间 可选,单位为毫秒,默认值为5000。表示如果缓存中的数据在等待5秒后,依然没有达到输出条件,系统会自动输出缓存中的所有数据。
batchSize 一次批量写入的条数 可选,默认值100。
retryIntervalMs 重试间隔时间 可选,单位毫秒,默认值1000。
maxRetryTimes 最大重试次数 可选,默认值100。
ignoreDelete 是否忽略delete操作 默认为false。

类型映射

OTS字段类型 实时计算字段类型
INTEGER BIGINT
STRING VARCHAR
BOOLEAN BOOLEAN
DOUBLE DOUBLE
说明 TableStore结果表须定义有primary key,输出数据以update方式写入到现有TableStore表。update方式说明请参见数据结果表概述Update类型