完成准备工作后,您可以进行实时计算数据开发。

创建作业

  1. 登录实时计算控制台
  2. 单击页面顶部的开发
  3. 开发界面,页面顶部的新建作业
  4. 新建作业界面,输入作业配置信息。
    作业参数 说明
    文件名称 作业的名称。
    说明 作业名称在当前项目中需保持唯一。
    作业类型
    • 共享模式:仅支持FLINK_STREAM/SQL作业类型。
    • 独享模式:支持FLINK_STREAM/DATASTREAMFLINK_STREAM/SQL作业类型。
    存储位置 在文件夹目录中,指定该作业的代码文件所属的文件夹。您还可以单击现有文件夹右侧的图标,新建子文件夹。
  5. 单击确认

注册数据存储

完成作业创建后,您可以通过注册数据存储的方式,关联准备工作中搭建的数据存储。
  • 注册源表数据存储
    1. 注册您的DataHub Project,步骤参见注册数据总线 DataHub
    2. 数据存储 > DataHub 数据存储中,双击已注册的datahub_ipplace
    3. 数据表详情区域,单击作为输入表引用
  • 注册维表数据存储
    1. 参考注册云数据库RDS版,完成RDS的注册。
    2. 数据存储 > RDS 数据存储中,双击已注册的rds_dim
    3. 数据表详情区域,单击作为维表引用
  • 注册结果表数据存储
    1. 参考注册云数据库RDS版,完成RDS的注册。
    2. 数据存储 > RDS 数据存储中,双击已注册的rds_ipplace
    3. 数据表详情区域,单击作为结果表引用

编写测试SQL

完成数据存储引用后,在作业编辑页面输入如下SQL代码,完成作业的开发。
insert into rds_ipplace
select t.`name`, w.place
from datahub_ipplace as t
join rds_dim for system_time as of proctime() as w
on t.place = w.place;

作业调试

完成作业开发后,可进行本地调试。作业调试详情,参见本地调试。本地调试结果示例图如下。 源表和维表的测试数据如下: