连线规则
2018-11-19 15:17:19 0 举报连线规则
作者其他创作
大纲/内容
从节点信息中拿到node_typestream
否
开始
找到对应的连线规则config
遍历valid_child_types
不允许超过max_parent_num个节点连接至节点B
节点A仅支持连线至rules[\"all\"]+rules[storages[rt_id][i]]
dest_node_type in rules[\"all\"]ORdest_node_type in rules[storages[rt_id][i]]
匹配获取子节点最大数量
遍历完毕
节点A只允许连接max_child_num个dest_node_type
结果表rt_id为591_etl_pizza_van得到存储列表为[\"kafka\"]
遍历storages字典
概念节点类型：node_type 如 stream结果表：result_table_id 如 591_etl_pizza_van存储：storage 如 kafka关系：一个节点有一种节点类型，N个结果表，一个结果表中有N个存储描述规则：一个stream节点的结果表591_etl_pizza_van中拥有kafka存储可以连线至
父节点的存储和节点类型是否满足
节点A是最终节点，后续不能连线至其他节点
[parent_node].length =max_parent_num
子节点数量是否满足
成功连线
父节点数量是否满足
找到已有的子节点[child_node] 并遍历
找到目标节点的父节点[parent_node]
连线规则：{ \"stream\": { \"max_parent_num\
节点信息：\"name\": \"节点A\"\"node_type\": \"stream\
为空
api:1. graph2.link_rule
起始节点 节点A目标节点 节点B
rules不为空?
是
0 条评论
下一页
