数据湖工厂 DLF
数据湖工厂 DLF
- 最新动态
- 产品介绍
-
用户指南
- 环境准备
- IAM权限管理
- 数据管理
- 数据集成
- 数据开发
- 解决方案
- 运维调度
- 配置管理
- 配置
- 使用教程
-
参考
-
节点
- 节点概述
- CDM Job
- DIS Stream
- DIS Dump
- DIS Client
- Rest Client
- Import GES
- MRS Kafka
- Kafka Client
- CS Job
- DLI SQL
- DLI Spark
- DWS SQL
- MRS SparkSQL
- MRS Hive SQL
- MRS Presto SQL
- MRS Spark
- MRS Spark Python
- MRS Flink Job
- MRS MapReduce
- CSS
- Shell
- RDS SQL
- ETL Job
- OCR
- Create OBS
- Delete OBS
- OBS Manager
- Open/Close Resource
- Data Quality Monitor
- Sub Job
- SMN
- Dummy
- For Each
- 表达式
-
节点
- 修订记录
- API参考
- 常见问题
- 产品术语
- 通用参考
链接复制成功!
For Each
功能
该节点可以指定一个子作业循环执行,并支持用一个数据集对子作业中的变量进行循环替换。
参数
用户可参考表1配置For Each节点的参数。
参数 |
是否必选 |
说明 |
---|---|---|
节点名称 |
是 |
节点名称,可以包含中文、英文字母、数字、“_”、“-”、“/”、“<”、“>”等各类特殊字符,长度为1~128个字符。 |
循环执行的子作业 |
是 |
选择需要循环执行的子作业。 |
数据集 |
是 |
For循环算子需要定义一个数据集,这个数据集用来循环替换子作业中的变量。数据集的来源:
select语句,或者Shell节点的echo等。当前只支持Hive SQL、Spark SQL 和DLI SQL的select语句
|
子作业并发数 |
是 |
循环产生的子作业可以并发执行,您可设置并发数。 |
子作业后缀 |
否 |
For循环生成的子任务名称:For循环节点名称 + 下划线 + 后缀。 后缀可配置,如果不配置,则按照数字顺序依次递增。 |
作业运行参数 |
否 |
|
参数 |
是否必选 |
说明 |
---|---|---|
节点执行的最长时间 |
是 |
设置节点执行的超时时间,如果节点配置了重试,在超时时间内未执行完成,该节点将不会再重试,直接置为失败状态。 |
失败重试 |
是 |
节点执行失败后,是否重新执行节点。
如果作业节点配置了重试,并且配置了超时时间,该节点执行超时后将不会再重试,直接置为失败状态。 |
失败策略 |
是 |
节点执行失败后的操作:
|
父主题: 节点