SQL 算子


智能任务流提供以下几种与数据库连接相关的算子:

  • Hive 算子

  • Mysql 算子

Hive 算子

Hive 算子用于处理 HIVE SQL,支持 Hive SQL 语法,可用于创建新表、执行 SQL 查询等 Hive 计算任务。


在当前 EnOS 的运行环境中,由于不同环境间的网络隔离,所以不能跨环境执行 Hive SQL。

输入参数说明

名称

必需/可选

类型

描述

data_source_name

必需

String

数据源名称,来自数据源连接配置。

sqls

必需

List

指定需要运行的 SQL 语句,list类型。每行输入一个list元素,参考以下list元素示例:

queue

可选

String

指定运行 HIVE SQL 时需要的大数据队列名称,通过 资源管理 申请的 批数据处理-大数据队列 名称。

list元素示例

如需要输入 ["a","b","c"],则输入如下:

"a"
"b"
"c"


如需输入 [1,2,3],则输入如下:

1
2
3

输出参数说明

名称

类型

描述

resultset

File

运行 HIVE SQL 后输出的结果集。

Mysql 算子

Mysql 算子用于处理 MySQL 的 SQL,支持 MySQL 语法,可用于创建新表、执行 SQL 的查询等任务。

输入参数说明

名称

必需/可选

类型

描述

data_source_name

必需

String

数据源名称,来自数据源连接配置。

sqls

必需

List

指定需要运行的 MySQL 语句。

输出参数说明

名称

类型

描述

resultset

File

运行 MySQL 后输出的结果集。