文档

自定义SQL

更新时间:

本文介绍自定义SQL算子的使用方法和注意事项。

用途

当系统提供的内置算子无法满足需求时,用户可以通过编写SQL语句实现自己特定的业务逻辑。

适用场景

计算链路

计算引擎

是否支持

离线

MaxCompute

Hive

HiveStorage

RDS/MySQL

使用说明

输入节点

上游节点的输出表信息,包括“表名标识符”和“字段名称”。

表名标识符

表名标识符在sql中作为占位符使用,在运行时此展位符会替换成上游节点输出表的实际表名。

image

说明

表名标识符使用${}方式在sql中使用,例如

Select date -- 日期 ,sales -- 销量 From ${table} Where sales >= 60

SQL脚本设置

编写具体的SQL脚本,示例如下:

image

说明

脚本仅支持select语句,select语句的查询结果将自动写入一张临时表。请勿使用create、alter、insert等语句,否则将运行失败。

示例中的${table}在运行时将会自动替换为上游输入表的真实表名。

输出字段

配置该算子的输出字段,可手动编辑也可通过解析sql语句自动生成。

自动解析的sql格式如图所示:

image

这两个行将解析出如下两个字段信息:

image