如何在Storm中实现此拓扑？
我刚来暴风，所以温柔点：-）
什么是实现这一目标的最佳方式？
共有1个答案
那不应该太复杂。只是在达到阈值之前不要发出单词，同时将它们存储在HashMap中。这只是一个if-else语句。
关于同步-我不认为你需要它，因为当你有这样的问题（与计数单词），你想要一个而且只有一个任务接收一个特定的单词。接收单词（例如“Nathan”）的任务将是唯一发出其频率的任务。为此，您应该使用字段分组。
-
我正在研究一个storm拓扑，需要为不同的客户端位置构建多个拓扑。 谢谢你的回复。
-
问题内容： 我们是新来的风暴。我们不知道如何创建拓扑，请帮助我们应对风暴。我们尝试了“ Windows上的狂风暴雨”一文中给出的示例wordcount c = topology。但是我们无法理解如何给出输入，以及风暴用户界面中输入存在的位置以及输出存在的位置。 问题答案： 输入和输出在Storm UI中不存在。在Storm UI中，您看不到发出的元组，处理时间，集群配置和集群的运行状况。要查看输出
-
现在我想在一个污点中使用Drools，它在LocalCluster中正常工作，但是当我把它放在生产集群中时，它有错误。污点是： 我使用官方文件创建了kiesession。误差为： 也许有些东西没有初始化。但当blot执行时，我创建了一个新的kieservice。有人能帮我吗 谢啦！
-
关于拓扑结构的说明： 喷口连续向读取螺栓发送元组。 读取bolt过程并将结果发送给下一个bolt等等。 在R bolt中处理tuple1之后还是在readbolt发送tuple1写入bolt之后？
-
我对storm使用Deubug是新手 我强制在 但是，当我完成了对拓扑的搜索时，找不到调试的结果在哪里 我注意到在，！ 为什么它看不懂我的变化？
-
我正在学习storm。我对Apache storm上一次可以运行的拓扑数有疑问。我在storm集群上提交了两个拓扑，但一次只能运行一个拓扑。我需要杀死或停用已经存在的拓扑才能运行任何新的拓扑。 我用的是Storm0.9.4 动物园管理员3.4.6 我在附上我的暴风UI的截图。