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 后输出的结果集。 |