Execution plan optimization for cases where a graph computation or graph traversal operator is followed directly by a sink #364
Description
【需求描述】
- 特定图计算/图遍历case执行计划优化：
当前存在如下场景，图遍历/图计算Node之后仅有Sink(或Map)节点Node时，执行时需要将遍历或计算的结果通过网络shuffle到下游节点。这里实际上可以进行优化，针对上述场景只需要local shuffle直接forward到本地下游节点输出即可。
【期望产出】
- 针对特定场景优化执行计划和执行流程，以实现性能的优化。同时补充plan优化case以及e2e用例并跑通。
如有疑问请联系： @cbqiao @Loognqiang