Page History

...

• hasSelect = false
• 候选文件列表 Flist=[]
• 倒序遍历文件列表
  • 如果  (任务已经足够多：currentTaskNum >= compaction_concurrent_thread)
          || (无需执行顺序合并： isSeq && !enable_seq_space_compaction)
          || (无需执行乱序合并： !isSeq && !enable_unseq_space_compaction)
    • return hasSelected
  • 如果（当前文件大小 > target_tsfile_size || 当前文件正在合并 || 当前文件未关闭）
    • 清空 FList；
    • continue；
  • 将当前文件加入 FList
  • 如果 FList 内所有文件总大小大于 compaction_target_tsfile_size || FList 内文件数达到 compaction_candidate_file_num
    • 将 FList 拷贝提交异步任务（空间内合并执行流程）， FList=[]，++currentTaskNum, hasSelected=true
    • 如果 compaction_priority=balance
      • break;
• return hasSelected

选出来的顺序文件：已关闭、未正在合并、至少与一个选出的乱序文件重叠

选出来的乱序文件：已关闭、未正在合并、所有与此乱序文件重叠的顺序文件（至少一个）都被选中

selectAndSubmitCrossSpaceFiles(顺序文件链表 S, 乱序文件链表 U): 返回是否选中文件做合并

• hasSelected = false
• 如果 currentTaskNum >= compaction_concurrent_thread
         || !enable_cross_space_compaction
  • return hasSelected;
• 候选乱序文件 UF = []
• 候选顺序文件 SF = []
• hasSelected = false
• for 乱序文件 u in  乱序文件链表 U
  • if (u 未关闭 || u 正在合并)
    • if submitIfNotEmpty(SF, UF): 
      • 如果 compaction_priority=balance, break;
      • if ( 线程池满 ) break;
    • continue;
  • 临时选中顺序文件 TmpSF = [] 
  • continueToNextUnseqFile = false
  • for 顺序文件 s in 顺序文件链表 S
    
    • if isOverlap(u, s)
      TmpSF.add( s)
      • if
    not (u 未关闭 || u 正在合并 ||
    • • s
    in TmpSF
    • • 未关闭 || s
    in TmpSF 正在合并)
    • • 正在合并
        • if submitIfNotEmpty(SF, UF): 
          
          • 如果 compaction_priority=balance, return hasSelected;
        • continueToNextUnseqFile = true;  break
      • else
        • TmpSF
    • UF
      • • .add(
      u);
      • • s)
  • if continueToNextUnseqFile
    • continue
  • SF.addAll(TmpSF);tmpSF), UF.add(u)
  • if UF.size() < compaction>= compaction_cross_space_max_select_unseq_file_num
    continue
    • if
    UF.size()>0
    • submitIfNotEmpty(SF, UF)
      • if
    • 将 UF 和 SF 提交异步任务（跨空间合并执行流程）, UF=[],SF=[], ++currentTaskNum, hasSelected=true
    • 如果
      • compaction_priority=balance, break
      • if ( 线程池满 ) break;
• submitIfNotEmpty(SF, UF)
• return hasSelected

合并执行任务

空间内合并执行流程

...