我想并行触发多个web请求,然后在storm拓扑中聚合数据?以下哪种方式是首选
1) 在螺栓内创建多个螺纹
2) 创建多个螺栓并创建一个合并螺栓以聚合数据。
我想在一个螺栓中创建多个线程,因为在另一个螺栓中合并数据不是一个简单的过程。但我看到我在网上发现了一些问题https://mail-archives.apache.org/mod_mbox/storm-user/201311.mbox/%3ccaaylz+puz44gnsnnj9o5hjtr2rzlw=ckm=fgvcfwbnw613r1qq@mail.gmail.com%3e 但是没有弄清楚为什么不创建多个线程。任何提示都会有帮助。
另一方面,这是否意味着我不应该使用java8中提到的并行流功能https://docs.oracle.com/javase/tutorial/collections/streams/parallelism.html?
1条答案
按热度按时间aydmsdu91#
增加
tasks
对于螺栓来说,它就像是产生了同一个螺栓的多个示例。同时也增加了executors (threads)
均匀地处理它们。确保
#executors <= #tasks
. 风暴会帮你解决剩下的事。