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

创建作业

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

    您还可以在现有文件夹右侧,单击新建图标,新建子文件夹。

  5. 单击确定

引用数据存储

完成作业创建后,您可以通过注册数据存储的方式,关联已搭建的上下游存储。
  • 注册引用源表数据
    1. 注册您的DataHub Project,步骤参见注册数据总线DataHub
    2. 开发页面的数据存储页签,双击DataHub 数据存储
    3. 双击目标数据库名称。
    4. 双击datahub_ipplace
    5. 数据表详情区域,单击作为输入表引用
  • 注册引用维表数据
    1. 参考注册云数据库RDS版,完成RDS的注册。
    2. 开发页面的数据存储页签,双击RDS数据存储
    3. 双击目标数据库名称。
    4. 双击rds_dim
    5. 数据表详情区域,单击作为维表引用
  • 注册引用结果表数据
    1. 参考注册云数据库RDS版,完成RDS的注册。
    2. 开发页面的数据存储页签,双击RDS数据存储
    3. 双击目标数据库名称。
    4. 双击rds_ipplace
    5. 数据表详情区域,单击作为结果表引用

编写测试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;

作业调试

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