如何在杀死Storm拓扑之前调用特定方法
在storm Framework中是否有任何预定义的、重写的或任何可用的方法来实现这一点。
提前致谢：）
共有1个答案
没有这种事...
作为一种解决办法，您可以在杀死拓扑之前停用。这样可以确保调用spout.deactivate()。
如果需要调用bolts上的方法，可以使用spout.deactivate()通过整个拓扑发送一个“通知元组”（不包含要处理的数据）。在每个螺栓中，如果收到“通知元组”，请调用您的特殊方法。
-
我们有一个不想连续运行storm拓扑的用例。相反，有一组输入(10K+)应该在指定的时间被处理，Spout连续发射这些输入，并得到拓扑中其余螺栓的处理。处理完所有输入后，在我的喷注中就没有任何东西可以从nextTuple发出。 此时，我们希望拓扑进入Hibernate状态，并在每天晚上12:00重新启动进程。 在storm配置中是否有任何属性可以设置为每天运行一次拓扑并在处理完成后Hibernat
-
问题内容： 在终止风暴拓扑之前如何调用特定方法。 我已经在风暴中创建了一个拓扑，我想在拓扑被杀死之前调用特定的方法。 在Storm框架中是否有任何预定义的覆盖或任何可用的方法来做到这一点。 提前致谢：） 问题答案： 哪有这回事… 解决方法是，可以先删除拓扑，然后再取消拓扑。这样可以确保被调用。 如果需要使用螺栓调用方法，请使用来通过整个拓扑发送“通知元组”（不包含要处理的数据）。并且在每个螺栓中，
-
我创建了一个带有Spout的Storm拓扑，该Spout会发出许多元组用于基准测试。一旦所有的元组都从spout发出或者拓扑中不再有任何元组流动，我就想停止/终止我的拓扑。
-
问题内容： 我正在使用Java类向拓扑集群提交拓扑，并且我还计划使用Java类取消拓扑。但是根据storm 文档，以下命令用于终止拓扑，并且没有Java方法（这有正当的理由） 那么从Java类中调用Shell脚本杀死拓扑就可以了吗？还有其他杀死拓扑的方法吗？ 另外，如何获取风暴群集中正在运行的拓扑的状态？ 问题答案： 要杀死拓扑，您可以尝试以下方法 获取拓扑运行状态
-
现在我想在一个污点中使用Drools，它在LocalCluster中正常工作，但是当我把它放在生产集群中时，它有错误。污点是： 我使用官方文件创建了kiesession。误差为： 也许有些东西没有初始化。但当blot执行时，我创建了一个新的kieservice。有人能帮我吗 谢啦！
-
问题内容： 我们是新来的风暴。我们不知道如何创建拓扑，请帮助我们应对风暴。我们尝试了“ Windows上的狂风暴雨”一文中给出的示例wordcount c = topology。但是我们无法理解如何给出输入，以及风暴用户界面中输入存在的位置以及输出存在的位置。 问题答案： 输入和输出在Storm UI中不存在。在Storm UI中，您看不到发出的元组，处理时间，集群配置和集群的运行状况。要查看输出