Storm动态拓扑 [英] Storm dynamic topology

问题描述

Storm 是否支持动态拓扑?我想要的功能是在 Storm 拓扑运行时根据用户要求动态更改拓扑.例如，当用户想知道流的前 10 个单词时，我使用前 10 个 bolt 来处理它，当用户想知道其他东西时，我使用另一个 bolt 来处理流并拔出"前 10 名螺栓.

Does Storm support dynamic topology? The functionality I want from this is to dynamically change the topology according to the user requirement while the Storm topology is running. For example, when user want to know the top-10 words of a stream, I use the top-10 bolt to process it, when user want to know something else, I use the other bolt to process the stream and 'unplug' the top-10 bolt.

我知道这可以通过对流进行分区或复制流并始终运行每个功能并仅演示我们想要的数据来完成，或者我们可以关闭流并更新另一个拓扑，但是是否有热插拔-怎么做?

I know it could be done by partition the stream or duplicate the stream and alway running every functionalities and only demo the data we want, or we could shut down the stream and update another topology, but is there a 'hot plug-in' way to do that?

推荐答案

已于 15 年 6 月 3 日在 STORM-561 上添加:

It was added on STORM-561, on 03/Jun/15:

https://issues.apache.org/jira/browse/STORM-561

这篇关于Storm动态拓扑的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！