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

Constructor Summary

StormSubmitter()

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

Field Detail

LOG

public static Logger LOG

Constructor Detail

StormSubmitter

public StormSubmitter()

Method Detail

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)