client
2017-12-28 10:31:26 2 举报
dfffs
作者其他创作
大纲/内容
获取执行节点列表中各节点配置信息(父节点列表,子节点列表,对应算法,算法配置)
从当前节点运行
遍历检查节点参数是否完成
组装执行节点列表
图拓扑排序得到DAG有序节点列表
获取当前节点以及所有后继节点
与DAG有序节点列表相交,取交集得到子图
得到具有完整配置的执行节点列表
全部运行
获取子图所有节点相关配置信息
开始
判断运行类型
失败
运行至当前节点
检查节点配置以及对应算法配置
获取当前节点以及所有前驱节点
非单点执行
成功
获取图所有节点相关配置信息
完成
未完成
异步启用sparkcontext环境,传入具有完整配置的执行节点列表,执行任务
获取单个节点相关配置信息
单点执行
0 条评论
下一页