THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- tryToSubmitCrossSpaceCompactionTask (顺序文件链表, 乱序文件链表,…)
- tryToSubmitInnerSpaceCompactionTask(顺序文件链表,isSeq=true,…)
- tryToSubmitInnerSpaceCompactionTask (乱序文件链表,isSeq=false,…)
- tryToSubmitInnerSpaceCompactionTask (文件链表, isSeq, …): 返回是否选中文件做合并
- if ((无需执行顺序合并: isSeq && !enable_seq_space_compaction) || (无需执行乱序合并: !isSeq && !enable_unseq_space_compaction))
- return false
- 获取空间内合并的文件选择器AbstractInnerSpaceCompactionSelector
- return innerSpaceCompactionSelector.selectAndSubmit()
- tryToSubmitCorssSpaceCompactionTask (顺序文件链表, 乱序文件链表, …): 返回是否选中文件做合并
- if (无需跨空间合并:!enable_cross_space_compaction)
- return false
- 获取跨空间合并的文件选择器AbstractCrossSpaceCompactionSelector
- return crossSpaceCompactionSelector.selectAndSubmit()
...
合并任务的文件选择器AbstractCompactionSelector
根据一定的策略选择待被合并的一批批TsFile文件,并为每批TsFile文件创建一个合并任务放入合并任务管理器CompactionTaskManager的任务等待队列里。
...