FlinkFlink BinaryExternalSorter 完全成熟的二进制格式排序器多路归并排序排序溢出合并

Posted 2022-12-28 九师兄

文章目录

• 1.概述
• • 2.1 BinaryExternalSorter构造函数
  • 2.2 启动方法
• 3.三个线程
• • 3.1 排序线程
  • • 3.1.1 go方法
  • 3.2 溢出线程
  • • 3.2.1 go函数
    • 3.2.2 In-Memory Merge
    • 3.2.3 Spilling Phase
  • 3.3 合并线程
  • • 3.3.1 构造方法
    • 3.3.2 开始合并
    • • 3.3.2.1 执行合并
    • 3.3.3 最终合并