1. 将 aggregation 操作下压,获得部分的聚合结果。
  2. 进行汇总的方式获得最终结果。
  1. *************************** 1. row ***************************
  2. Query Plan:
  3. =============================================
  4. ---------------------------------------------
  5. |0 |HASH GROUP BY | |1000 |3395|
  6. |2 | EXCHANGE OUT DISTR| |1000 |2740|
  7. |3 | HASH GROUP BY | |1000 |2740|
  8. |4 | TABLE SCAN |t2 |4000 |499 |
  9. =============================================
  10. 0 - output([T_FUN_SUM(T_FUN_SUM(t2.c1))]), filter(nil),
  11. group([t2.c2]), agg_func([T_FUN_SUM(T_FUN_SUM(t2.c1))])
  12. 1 - output([T_FUN_SUM(t2.c1)], [t2.c2]), filter(nil)
  13. 2 - output([T_FUN_SUM(t2.c1)], [t2.c2]), filter(nil)
  14. 3 - output([T_FUN_SUM(t2.c1)], [t2.c2]), filter(nil),
  15. group([t2.c2]), agg_func([T_FUN_SUM(t2.c1)])