两个operator chain在一起的的条件:
-
上下游的并行度一致
-
下游节点的入度为1 (也就是说下游节点没有来自其他节点的输入)
-
上下游节点都在同一个 slot group 中(下面会解释 slot group)
-
下游节点的 chain 策略为 ALWAYS(可以与上下游链接,map、flatmap、filter等默认是ALWAYS)
-
上游节点的 chain 策略为 ALWAYS 或 HEAD(只能与下游链接,不能与上游链接,Source默认是HEAD)
-
两个节点间数据分区方式是 forward(参考理解数据流的分区)
-
用户没有禁用 chain
标签: chain、下游、上下游、slot、operator、面试