apache storm并行如何工作?

niknxzdl  于 2021-06-24  发布在  Storm
关注(0)|答案(1)|浏览(318)

我对ApacheStorm还很陌生,想知道并行提示是如何工作的。
例如,我们有一个流包含两个元组<4>,<6>,一个喷口每个执行器只有一个任务,我们有一个螺栓来执行元组上的一些操作,并行提示为2,所以我们有两个螺栓的执行器,即a和b,关于这一点,我有3个问题。
考虑到上面的场景,我们包含值4的元组可能由a处理,而另一个包含值6的元组则由b处理。
如果以这种方式进行处理,即问题(1)中提到的处理,那么它不会影响顺序重要的操作。
如果处理不是以这种方式完成的,意味着两个元组都将进入同一个执行器,那么并行的好处是什么呢。

xxhby3vn

xxhby3vn1#

考虑到上面的场景,我们包含值4的元组可能由a处理,而另一个包含值6的元组则由b处理。
对。
如果以这种方式进行处理,即问题(1)中提到的处理,那么它不会影响顺序重要的操作。
视情况而定。你很可能控制着你的嘴里元组的顺序。如果顺序很重要,建议减少并行性或使用字段分组,以确保相互依赖的元组到达同一执行器。如果序列无关紧要,那么使用shufflegrouping或localorshufflegrouping从并行处理中获得好处。
如果处理不是以这种方式完成的,意味着两个元组都将进入同一个执行器,那么并行的好处是什么呢。
如果两个元组都属于同一个执行器,显然没有任何好处。

相关问题