GI 算子用于并行执行中,用于按照分区或者按照数据块迭代整张表。

按照迭代数据的粒度划分,GI 算子包括 PX PARTITION ITERATOR 和 PX BLOCK ITERATOR。

PX PARTITION ITERATOR

PX PARTITION ITERATOR 算子用于按照分区粒度迭代数据。

如下示例中,2 号算子按分区粒度迭代出数据。

  1. obclient>CREATE TABLE t (c1 INT, c2 INT) PARTITION BY HASH(c1) PARTITIONS 4;
  2. Query OK, 0 rows affected (0.12 sec)
  3. obclient>CREATE INDEX idx ON t (c1);
  4. Query OK, 0 rows affected (0.12 sec)
  5. obclient>EXPLAIN SELECT /*+FULL(t)*/ c1 FROM t\G;
  6. *************************** 1. row ***************************
  7. Query Plan:
  8. ======================================================
  9. |ID|OPERATOR |NAME |EST. ROWS|COST |
  10. ------------------------------------------------------
  11. |0 |PX COORDINATOR | |400000 |427257|
  12. |1 | EXCHANGE OUT DISTR |:EX10000|400000 |247403|
  13. |2 | PX PARTITION ITERATOR| |400000 |247403|
  14. |3 | TABLE SCAN |T |400000 |247403|
  15. ======================================================
  16. Outputs & filters:
  17. -------------------------------------
  18. 0 - output([T.C1], [T.C2]), filter(nil)
  19. 1 - output([T.C1], [T.C2]), filter(nil), dop=1
  20. 2 - output([T.C1], [T.C2]), filter(nil)
  21. 3 - output([T.C1], [T.C2]), filter(nil),
  22. access([T.C1], [T.C2]), partitions(p[0-3])

上述示例的执行计划展示中的 outputs & filters 详细列出了 PX PARTITION ITERATOR 算子的输出信息如下:

信息名称

含义

output

该算子输出的表达式。

filter

该算子上的过滤条件。

由于示例中 PX PARTITION ITERATOR 算子没有设置 filter,所以为 nil。

PX BLOCK ITERATOR

PX BLOCK ITERATOR 算子用于按照数据块粒度迭代数据。

相对于 PX PARTITION ITERATOR,PX BLOCK ITERATOR 算子按照数据块迭代的方式粒度更小,能够切分出更多的任务,支持更高的并行度。

  1. obclient>EXPLAIN SELECT /*+PARALLEL(4)*/ c1 FROM t\G;
  2. *************************** 1. row ***************************
  3. Query Plan:
  4. ==================================================
  5. |ID|OPERATOR |NAME |EST. ROWS|COST |
  6. --------------------------------------------------
  7. |0 |PX COORDINATOR | |400000 |279171|
  8. |1 | EXCHANGE OUT DISTR|:EX10000|400000 |189244|
  9. |2 | PX BLOCK ITERATOR| |400000 |189244|
  10. |3 | TABLE SCAN |T(IDX) |400000 |189244|
  11. ==================================================
  12. Outputs & filters:
  13. -------------------------------------
  14. 0 - output([T.C1]), filter(nil)
  15. 1 - output([T.C1]), filter(nil), dop=4
  16. 2 - output([T.C1]), filter(nil)
  17. 3 - output([T.C1]), filter(nil),
  18. access([T.C1]), partitions(p[0-3])

上述示例的执行计划展示中的 outputs & filters 详细列出了 PX BLOCK ITERATOR 算子的输出信息,字段的含义与 PX PARTITION ITERATOR 算子相同。