在执行计划生成的最后阶段,以 EXCHANGE 节点为界,拆分成多个子计划,每个子计划被封装成为一个 DFO,在并行度大于 1 的场景下,会一次调度两个 DFO,依次完成 DFO 树的遍历执行;在并行度等于 1 的场景下,每个 DFO 会将产生的数据存入中间结果管理器,按照后序遍历的形式完成整个 DFO 树的遍历执行。

    如下图所示,DFO 树除 ROOT DFO 外,在垂直方向上被分别划分为 0、1、2 号 DFO, 从而后序遍历调度的顺序为 0->1->2,即可完成整个计划树的迭代。

    两 DFO 调度

    示例:对于并行度大于 1 的计划, 对于查询计划执行两 DFO 调度。

    1. =============================================================================
    2. |ID|OPERATOR |NAME |EST. ROWS|COST |
    3. -----------------------------------------------------------------------------
    4. |0 |PX COORDINATOR MERGE SORT | |9873917 |692436562|
    5. |1 | EXCHANGE OUT DISTR |:EX10002|9873917 |689632565|
    6. |2 | SORT | |9873917 |689632565|
    7. |4 | WINDOW FUNCTION | |29621749 |629924873|
    8. |6 | HASH JOIN | |31521003 |591048941|
    9. |7 | JOIN FILTER CREATE | |407573 |7476793 |
    10. |8 | EXCHANGE IN DISTR | |407573 |7476793 |
    11. |9 | EXCHANGE OUT DISTR (BROADCAST) |:EX10001|407573 |7303180 |
    12. |10| HASH JOIN | |407573 |7303180 |
    13. |11| JOIN FILTER CREATE | |1 |53 |
    14. |13| EXCHANGE OUT DISTR (BROADCAST)|:EX10000|1 |53 |
    15. |15| TABLE SCAN |NATION |1 |53 |
    16. |16| JOIN FILTER USE | |10189312 |3417602 |
    17. |17| PX BLOCK ITERATOR | |10189312 |3417602 |
    18. |18| TABLE SCAN |SUPPLIER|10189312 |3417602 |
    19. |19| JOIN FILTER USE | |803481600|276540086|
    20. |20| PX PARTITION ITERATOR | |803481600|276540086|
    21. =============================================================================