完成准备工作后,您可以进行实时计算数据开发。
创建作业
- 登录实时计算控制台。
- 在页面顶部,单击开发。
- 单击新建作业。
- 在新建作业页面,输入作业配置信息。
作业参数 说明 文件名称 作业的名称。 说明 作业名称在当前项目中需保持唯一。作业类型 - 共享模式:仅支持FLINK_STREAM/SQL作业类型。
- 独享模式:支持FLINK_STREAM/DATASTREAM和FLINK_STREAM/SQL作业类型。
存储位置 指定该作业的代码文件所属的文件夹。 您还可以在现有文件夹右侧,单击
图标,新建子文件夹。
- 单击确定。
引用数据存储
完成作业创建后,您可以通过注册数据存储的方式,关联已搭建的上下游存储。
- 注册引用源表数据
- 注册您的DataHub Project,步骤参见注册数据总线DataHub。
- 在开发页面的数据存储页签,双击DataHub 数据存储。
- 双击目标数据库名称。
- 双击datahub_ipplace 。
- 在数据表详情区域,单击作为输入表引用。
- 注册引用维表数据
- 参考注册云数据库RDS版,完成RDS的注册。
- 在开发页面的数据存储页签,双击RDS数据存储。
- 双击目标数据库名称。
- 双击rds_dim 。
- 在数据表详情区域,单击作为维表引用。
- 注册引用结果表数据
- 参考注册云数据库RDS版,完成RDS的注册。
- 在开发页面的数据存储页签,双击RDS数据存储。
- 双击目标数据库名称。
- 双击rds_ipplace 。
- 在数据表详情区域,单击作为结果表引用。
编写测试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;
在文档使用中是否遇到以下问题
更多建议
匿名提交