入口函数

第一个算子是 PhysicalOperatorType::RESULT_COLLECTOR

五种 event 存入 base_stack

base_stack 中的 event 之间依赖关系

// dependencies: initialize -> event -> prepare finish -> finish -> complete

以此类推// dependencies: initialize -> event -> prepare finish -> finish -> complete

event_map 的构建

• key → value : *base_pipeline → base_stack

调度的入口

while 循环一直看有没有 result 能收集

一个event Finish 的动作