要编写一个提交到风暴群的程序，它需要以特定的格式，还是我可以提交任何基本程序？我试着写一个尽可能简单的程序，看看集群是否正常工作，并确保我理解软件。
epfja78i1#
最基本的程序必须实现一个喷口（即， IRichSpout 接口或 BaseRichSpout 类）。此外，您必须使用 TopologyBuilder 创建 StormTopology . 请参见此处以获取简单示例：https://github.com/apache/storm/blob/master/examples/storm-starter/src/jvm/storm/starter/wordcounttopology.java有关教程，请参见此处：https://storm.apache.org/documentation/tutorial.html此外，必须将代码打包到 jar 通过提交文件 StormSubmitter :https://storm.apache.org/documentation/running-topologies-on-a-production-cluster.html
IRichSpout
BaseRichSpout
TopologyBuilder
StormTopology
jar
StormSubmitter
brjng4g32#
为了测试集群，已经编写了许多程序。这些程序是storm tar文件的一部分。直接使用它们。
2条答案
按热度按时间epfja78i1#
最基本的程序必须实现一个喷口（即，
IRichSpout接口或BaseRichSpout类）。此外，您必须使用TopologyBuilder创建StormTopology. 请参见此处以获取简单示例：https://github.com/apache/storm/blob/master/examples/storm-starter/src/jvm/storm/starter/wordcounttopology.java
有关教程，请参见此处：
https://storm.apache.org/documentation/tutorial.html
此外，必须将代码打包到
jar通过提交文件StormSubmitter:https://storm.apache.org/documentation/running-topologies-on-a-production-cluster.html
brjng4g32#
为了测试集群，已经编写了许多程序。这些程序是storm tar文件的一部分。直接使用它们。