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

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



PrintWriterToplogyOnGlobalGroupConfig 示例

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

运行结果:有且仅有1个WriterBolt文件(尽管 WriterBolt 8个Executors)

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


相关文章:

  • 2021-06-24
  • 2021-09-26
  • 2021-05-27
  • 2022-01-19
  • 2022-01-13
  • 2021-09-27
  • 2021-08-22
猜你喜欢
  • 2021-06-18
  • 2021-11-08
  • 2021-07-01
  • 2018-10-14
  • 2022-12-23
  • 2021-10-27
  • 2021-09-19
相关资源
相似解决方案