💡
原文英文,约1000词,阅读约需4分钟。
📝
内容提要
Dolphinscheduler中的DAG(有向无环图)用于管理离线任务的生命周期,包括停止、暂停和重启。DAG包含节点信息和边关联,确保任务关系无循环。通过DAG类和DagHelper工具类构建任务定义及其关系,生成工作流图。
🎯
关键要点
- Dolphinscheduler中的DAG用于管理离线任务的生命周期,包括停止、暂停、重启等。
- DAG包含节点信息和边关联,确保任务关系无循环。
- DAG的三个重要数据结构包括节点信息、边关联信息和反向边关联信息。
- DAG类和DagHelper工具类用于构建任务定义及其关系,生成工作流图。
- DAG的addEdge方法用于添加边,并检查是否会形成循环。
- DagHelper类用于将任务定义和任务关系组装成DAG。
- 生成DAG的过程包括获取任务关系、任务定义日志和构建ProcessDag对象。
- buildDagGraph方法用于添加DAG的节点和边,生成最终的DAG图。
➡️