更新时间:2023-06-21 GMT+08:00
引用脚本模板和参数模板的使用介绍
使用场景
该功能适用于以下场景:
- Flink SQL脚本可以引用脚本模板。
- 在pipeline作业开发中,MRS Flink Job节点可以使用引入了脚本模板的Flink SQL脚本,同时在MRS Flink Job节点的“运行程序参数”里面可以引用参数模板。
- 在Flink SQL单任务作业中引用脚本模板。
- 在Flink Jar单任务作业中使用参数模板。
在脚本中引用脚本模板时,SQL语句的写法为@@{脚本模板}。
前提条件
已创建模板。如果模板还未创建,请参见配置模板进行创建。
引用模板案例
- Flink SQL脚本可以引用脚本模板。
- 在数据开发主界面的左侧导航栏,选择 。
- 右键单击脚本,选择“新建Flink SQL脚本”进入。
- 单击右侧的“模板”,选择刚才创建好的脚本模板,例如412_mobna,系统支持可以引用多个模板。
图1 引用脚本模板
- 脚本创建完成后,单击“保存”,脚本412_test创建完成。
- 在pipeline作业开发中,MRS Flink Job节点可以使用引入了脚本模板的Flink SQL脚本。
- 在pipeline作业开发中,在MRS Flink Job节点的“运行程序参数”里面引用参数模板。
- 选择MRS集群名。
- 运行程序参数会自动展示出来。单击“选择模板”进入后,选择已创建的参数模板,系统支持可以引用多个模板。
- 在Flink SQL单任务作业中引用脚本模板。
- 在数据开发主界面的左侧导航栏,选择 。
- 右键单击作业,创建一个单任务模式的实时处理作业Flink SQL,进入作业开发界面。
- 单击右侧的“模板”,选择刚才创建好的脚本模板,例如412_mobna,系统支持可以引用多个模板。
图4 单任务Flink sql引用脚本模板
- 在Flink Jar单任务作业中使用参数模板。
- 在数据开发主界面的左侧导航栏,选择 。
- 右键单击作业,创建一个单任务模式的实时处理作业Flink Jar,进入作业开发界面。
- 选择MRS集群名。
- 运行程序参数会自动展示出来。单击“选择模板”进入后,选择已创建的参数模板,系统支持可以引用多个模板。
父主题: 使用教程