backtype.storm
Class StormSubmitter
java.lang.Object
backtype.storm.StormSubmitter
public class StormSubmitter
- extends java.lang.Object
Use this class to submit topologies to run on the Storm cluster. You should run your program
with the "storm jar" command from the command-line, and then use this class to
submit your topologies.
Field Summary |
static Logger |
LOG
|
Method Summary |
static void |
setLocalNimbus(Nimbus.Iface localNimbusHandler)
|
static java.lang.String |
submitJar(java.util.Map conf,
java.lang.String localJar)
|
static void |
submitTopology(java.lang.String name,
java.util.Map stormConf,
StormTopology topology)
Submits a topology to run on the cluster. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
LOG
public static Logger LOG
StormSubmitter
public StormSubmitter()
setLocalNimbus
public static void setLocalNimbus(Nimbus.Iface localNimbusHandler)
submitTopology
public static void submitTopology(java.lang.String name,
java.util.Map stormConf,
StormTopology topology)
throws AlreadyAliveException,
InvalidTopologyException
- Submits a topology to run on the cluster. A topology runs forever or until
explicitly killed.
- Parameters:
name
- the name of the storm.stormConf
- the topology-specific configuration. See Config
.topology
- the processing to execute.
- Throws:
AlreadyAliveException
- if a topology with this name is already running
InvalidTopologyException
- if an invalid topology was submitted
submitJar
public static java.lang.String submitJar(java.util.Map conf,
java.lang.String localJar)