Storm 从入门到精通第十一讲 Stream Grouping - Global Grouping

分类: 文章 • 2025-04-19 13:51:46

Global Grouping全局分组:这个Tuple被分配到Storm中的一个Bolt的其中一个Task, 再具体一点就是分配给task_id值最低的那个Task

PrintWriterToplogyOnGlobalGroupConfig 示例

Storm 从入门到精通第十一讲 Stream Grouping - Global Grouping

运行结果：有且仅有1个WriterBolt文件（尽管 WriterBolt 8个Executors）

Storm 从入门到精通第十一讲 Stream Grouping - Global Grouping

Storm 从入门到精通 第十一讲 Stream Grouping - Global Grouping