本文介绍自定义SQL算子的使用方法和注意事项。
用途
当系统提供的内置算子无法满足需求时,用户可以通过编写SQL语句实现自己特定的业务逻辑。
适用场景
计算链路 | 计算引擎 | 是否支持 |
离线 | MaxCompute | 是 |
Hive | 是 | |
HiveStorage | 是 | |
RDS/MySQL | 是 |
使用说明
输入节点
上游节点的输出表信息,包括“表名标识符”和“字段名称”。
表名标识符
表名标识符在sql中作为占位符使用,在运行时此展位符会替换成上游节点输出表的实际表名。
说明
表名标识符使用${}方式在sql中使用,例如
Select date -- 日期 ,sales -- 销量 From ${table} Where sales >= 60
SQL脚本设置
编写具体的SQL脚本,示例如下:
说明
脚本仅支持select语句,select语句的查询结果将自动写入一张临时表。请勿使用create、alter、insert等语句,否则将运行失败。
示例中的${table}在运行时将会自动替换为上游输入表的真实表名。
输出字段
配置该算子的输出字段,可手动编辑也可通过解析sql语句自动生成。
自动解析的sql格式如图所示:
这两个行将解析出如下两个字段信息:
文档内容是否对您有帮助?