0
点赞
收藏
分享

微信扫一扫

openGauss向量化Merge Join--inner join


openGauss VecMergeJoin状态机

VecMergeJoin状态机如下图所示:

openGauss向量化Merge Join--inner join_算法

下面我们以一个例子为例,解释各个join的执行情况。

表t30和t31的结构及数据如下:

postgres=# select * from t30
id1 | id2
----|----
1 | 1
2 | 3
2 | 3
(3 rows)

postgres=# select * from t31
id1 | id2
----|----
1 | 1
5 | 5
2 | 3
(3 rows)

t30作为外表,t31作为内表,join条件为t30.id1=t31.id1。

inner join

1)EXEC_MJ_INITIALIZE_OUTER

    取外表值1。进入EXEC_MJ_INITIALIZE_INNER状态

2)EXEC_MJ_INITIALIZE_INNER

    取内表值1。进入EXEC_MJ_SKIP_TEST状态

3)EXEC_MJ_SKIP_TEST

    1 = 1,进入EXEC_MJ_JOINTUPLES状态,并标记内表值1

4)EXEC_MJ_JOINTUPLES

    BatchFillInnerAndOuter将内外表值分别放到m_pInnerMatch和m_pOuterMatch中,进入EXEC_MJ_NEXTINNER状态

5)EXEC_MJ_NEXTINNER

    取内表的下一个值2,和外表值1比较。1 < 2,进入EXEC_MJ_NEXTOUTER状态

6)EXEC_MJ_NEXTOUTER

    外表值取下一个值2,进入EXEC_MJ_TESTOUTER状态

7)EXEC_MJ_TESTOUTER

    外表值2,和标记的内表值1比较。2 > 1,接着取内表当前值2,进入EXEC_MJ_SKIP_TEST状态。

8)EXEC_MJ_SKIP_TEST

    2 = 2,进入EXEC_MJ_JOINTUPLES状态,标记内表位置为2

9)EXEC_MJ_JOINTUPLES

    BatchFillInnerAndOuter将内外表值分别放到m_pInnerMatch和m_pOuterMatch中,进入EXEC_MJ_NEXTINNER状态。

10)EXEC_MJ_NEXTINNER

    取内表的下一个值5,和外表值2比较。2 < 5,进入EXEC_MJ_NEXTOUTER状态

11)EXEC_MJ_NEXTOUTER

    取外表的下一个值2,进入EXEC_MJ_TESTOUTER状态

12)EXEC_MJ_TESTOUTER

    外表值2,和标记的内表值2比较。2 = 2,进入EXEC_MJ_JOINTUPLES状态,调整内表当前扫描位置为标记位置,即2。

13)EXEC_MJ_JOINTUPLES

    BatchFillInnerAndOuter将内外表值分别放到m_pInnerMatch和m_pOuterMatch中,进入EXEC_MJ_NEXTINNER状态。

14)EXEC_MJ_NEXTINNER

    取内表的下一个值5,和外表值2比较。2 < 5,进入EXEC_MJ_NEXTOUTER状态

15)EXEC_MJ_NEXTOUTER

    外表值已取完,结束。

此时,m_pInnerMatch和m_pOuterMatch的值分别为:

m_pInnerMatch m_pOuterMatch
1 1
2 2
2 2

最终调用函数ProduceResultBatchT,将两个batch投影到一个batch中,输出最终join结果。

举报

相关推荐

0 条评论