Storm 中 Clojure 的 Prepare Bolt 实现

2014-08-05
阅读 2 分钟
3.1k
Storm 中的 Bolt 都是通过 Nimbus 这个服务将序列化好的 Bolt 断章取义地发到各个 worker 中。所以,任何在 bolt 之外你自认为加载期间初始化计算好的上下文环境并不会被打包上去,Java 我不懂也不知道,但是至少在 Clojure 这个类的概念被淡化的 LIST 方言中,你要做的就是把所有跟 bolt 初始化计算相关的代码放到其 pr...