Database Reference
In-Depth Information
Similarly, the Storm supervisor should be started on all of the worker
machines:
storm-0.9.0.1$ ./bin/storm supervisor &
If all has gone well, the Storm UI should reflect the correct number of
supervisors. For example, a cluster running on a development machine
should look something like Figure 5.2 .
Figure 5.2
Controlling Topologies
Submitting a topology to a Storm cluster is similar to submitting a Hadoop
job. The commands are even similar: storm jar instead of hadoop jar .
Topologies themselves are actually submitted in their main class using the
StormSubmitter class:
Config conf = new Config();
StormSubmitter. submitTopology ("my-topology", conf,
topology);
The Config object can be used as is or overridden to set topology-specific
configuration parameters. A main class implementing this call can be
executed in the proper configuration context using storm jar :
 
 
Search WWH ::




Custom Search