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

创建流式源表

更新时间:2017-12-29 15:19:52

流计算的源表是指流式数据存储,流式数据存储驱动流计算的运行。因此,每个流计算子作业必须提供至少一个流式数据存储!目前流计算仅支持DataHub做流式数据输入,声明一个DataHub流式源表的语法如下:

  1. CREATE STREAM TABLE table_name
  2. [(col_name data_type, ...[, PRIMARY KEY(col_name, ...)])]
  3. [WITH (property_name=other_property_value,...)];
  4. data_type
  5. : primitive_type
  6. primitive_type
  7. : INT
  8. | BIGINT
  9. | DOUBLE
  10. | STRING

示例

下面我们定义了一个DataHub源表,并对该表进行SELECT操作。

  1. create stream table stream_source (
  2. name STRING,
  3. value STRING
  4. ) WITH (
  5. type='datahub',
  6. endpoint='http://dh-cn-hangzhou.aliyuncs.com',
  7. accessId='accessId',
  8. accessKey='accessKey',
  9. projectName='project',
  10. topic='topic'
  11. );
  12. INSERT INTO result_rds
  13. SELECT
  14. id,
  15. name
  16. FROM
  17. stream_source;
本文导读目录