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

Global Grouping全局分组:这个Tuple被分配到Storm中的一个Bolt的其中一个Task, 再具体一点就是分配给task_id值最低的那个Task PrintWriterToplogyOnGlobalGroupConfig 示例 运行结果:有且仅有1个WriterBolt文件(尽管 WriterBolt 8个Executors)
相关文章
相关标签/搜索