拓扑是指在storm运行的计算[storm jar app.jar com.XXX.main] 则main函数包含了一个拓扑的定义,拓扑指定了一个计算的配置,spout,bolt以及每个组件之间的stream grouping[也就是订阅者如何订阅被订阅者的规则:流分组]

storm初级教程 005 storm核心之拓扑

       拓扑由上述拓扑构建者构建,number为并行度/执行器数量,不指定默认为1;

流分组有8种自定义策略以及用户自定义策略

常用有shuffleGroup/fieldsgroup 还有no group[类似于随机分组,不同的是订阅者与被订阅者会被放置于同一个线程执行]

storm初级教程 005 storm核心之拓扑

拓扑的hook功能

hook功能类似余事件订阅,hook通过继承BaseTaskHook定义,由TopologyContext.addBaseTask()实现

相关文章:

  • 2022-01-13
  • 2021-09-29
  • 2021-06-16
  • 2021-07-24
  • 2018-09-17
  • 2021-04-09
猜你喜欢
  • 2021-05-24
  • 2021-06-23
  • 2022-12-23
  • 2022-01-04
  • 2022-12-23
  • 2021-09-13
  • 2022-12-23
相关资源
相似解决方案