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
.
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
: