storm 運行拓撲

Next, package the source into a jar, which is sent when you run the Storm Client commandide

to submit the topology. Because you used Maven, the only thing you need to dothis

is go to the source folder and run the following:spa

mvn packagecode

Once you have the generated jar, use the storm jar command to submit the topologyorm

(you should know how to install the Storm client into Appendix A). The syntax is get

storm jar allmycode.jar org.me.MyTopology arg1 arg2 arg3.it

In this example, from the topologies source project folder, run:class

storm jar target/Topologies-0.0.1-SNAPSHOT.jar countword.TopologyMain src/main/cli

resources/words.txtsed

With these commands, you have submitted the topology to the cluster.

To stop/kill it, run:

storm kill Count-Word-Topology-With-Refresh-Cache

相關文章
相關標籤/搜索