并行执行算子

【问题描述】sql并行执行的时候,coord算子和exchange算子是什么关系,coord里面的receive和transmit跟exchange里的consumer和producer有对应关系吗?

1 个赞

exchange算子包括exchange in和exchange out。

exchange out = transmit = producer

exchange in = receive = consumer

px coord属于一个receive,可以接收下层transmit发送的数据,与普通receive算子不同的是,px coord还起到协调分布式计划执行的作用,包括调度dfo,向transmit和receive广播它们之间的channel信息等等。