单击任务模板名称,打开模板编辑器,您可在编辑器中输入通用的代码逻辑,或者选择通用的参数信息。以下为简单示例脚本:
说明
对已有任务模板做更新时,需确认是否对已引用的任务有影响,可以在右侧引用记录中,查看任务引用的模板版本,需谨慎更新任务模板。
输入通用代码逻辑,表名、字段名分别可以用@{type1}、@{tablename}表示,时间参数仍可用${}获取,以下为简单代码示例:
select @{type1}, @{type2} from @{tablename} WHERE date = '${date}';
参数设置
功能区按钮说明:
参数 | 说明 |
|---|---|
格式化 | 依据在个性化设置中的SQL格式化风格的设置,格式化书写的代码,使其语法结构看起来简洁明了。 |
表管理 | 快速建表:若数据需要存入的Hive表尚未创建,则编写完SQL语句后,可基于解析代码,跳转到数据地图上,可快速填充建表页面。 |
执行引擎 | 支持Spark执行引擎 |
在任务模板的代码开发编辑界面,通过DDL和DML编写通用SQL,表名、字段名分别可以用@{type1}、@{tablename}表示,以下以Flink Streaming SQL示例代码为例:
CREATE TABLE @{tablename1}( @{type1} VARCHAR, @{type2} INT, @{type3} VARCHAR, ts AS localtimestamp ) WITH ( 'connector' = 'datagen', 'rows-per-second' = '1' ); CREATE TABLE @{tablename2} (@{type1} STRING, @{type2} INT, @{type3} STRING) WITH ('connector' = 'print'); INSERT INTO @{tablename2} SELECT @{type1}, @{type2}, @{type3} FROM @{tablename1};
数据源格式
编辑完SQL逻辑后,您可选择是否开始数据源格式定义,开启数据源格式后,可继续完成以下操作:
数据源类型:支持json、pb的数据源类型。
Pb类定义:数据源类型为pb时,需指定Pb类定义文件,只支持一个Pb类定义,示例如下:
syntax = "proto2"; package abase_test; message AbaseTest { required int64 first_id = 1; required int64 latest_id = 2; }
Pb入口message:数据源类型为pb时,定义Pb入口的message信息,如:AbaseTest。
参数设置
单击任务模板名称,打开模板编辑器,您可在编辑器中输入通用的Shell脚本逻辑,或者选择通用的参数信息。以下为简单示例脚本:
#! /bin/bash function commonFunction() { ARGS=`getopt -a -o u:p: -l yarn_cluster:,yarn_queue:, -- "$@"` if [ $? != 0 ]; then echo "Terminating" exit 1 fi eval set -- "${ARGS}" while true; do case "$1" in -u|--yarn_cluster) yarn_cluster="$2" shift ;; -p|--yarn_queue) yarn_queue="$2" shift ;; --) shift break ;; esac shift done echo ${yarn_cluster} echo ${yarn_queue} } commonFunction
参数设置
您可在界面下方,单击新增参数组按钮,进行以下操作:

说明
Shell任务模板参数替换逻辑如下:
在Java Flink的任务模板编辑界面,您可以添加 Java Flink 作业需要使用到的 Flink 参数信息,同时您也可以设置更多的自定义参数在任务中使用: