Build Hash Table流程

• 1、初始化row buffer
• 2、从build input table中读一行
• 3、若读完build input table所有row，返回状态READING_ROW_FROM_PROBE_item
• 4、否则，向hash map中写入一条row
• 5、如果hash map 写入成功，返回2，继续执行
• 6、若hash map满了，则写chunk file
  • 1、初始化chunk file
  • 2、将剩余的row写入chunk file
  • 3、返回状态READING_ROW_FROM_PROBE_item
    流程图如下：
    

Write Rows to chunks流程

• 1、从input表(build 或者 probe)读row
• 2、写入chunk file
  • 1、构造join key
  • 2、计算hash key并选择chunk file
  • 3、写入相应的chunk file中
    流程图如下：
    

单线程hash join 步骤

step1：初始化

• build table init
• memory buffer init
• create hash map
• probe table init
• state 设为 Reading_Row_From_Probe_Iterator

step2：HashJoinIteratorRead，根据state做调整

• (1)、state为Reading Row from probe iterator

  • 1、从probe table read一行row
  • 2、如果所有probe input row都读完了
    • 如果非spill to disk，对build input剩余的row构造hash map,重新对probe表做init，回到1继续
    • 如果为spill to disk，goto(2)
  • 3、如果build input有chunk file，将probe input表写入chunk file
  • 4、从hash map里查找probe inputrow的查询结果
  • 5、goto(4)

• (2)、state为Loading next chunk pair

  • 找到下一对chunk pair做hash join

• (3)、state为Reading row from probe input file,读一个probe chunk的row做hash join

  • 1、从probe chunk读一行row
  • 2、在hash table里查询匹配
  • 3、goto(4)

• (4)、state为Reading from hash table，读取hash table中匹配记录

  • 1、将查到的row buffer写入build input表的record[0]中
  • 2、若读取完hash table中记录，goto(1)或者(3)

状态流程图：