backtype.storm

Class StormSubmitter

java.lang.Object

backtype.storm.StormSubmitter

public final 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.

Method Summary

Modifier and Type	Method and Description
static void	submitTopology(java.lang.String name, java.util.Map<java.lang.String,java.lang.Object> stormConfig, 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

Method Detail

submitTopology

public static void submitTopology(java.lang.String name,
                                  java.util.Map<java.lang.String,java.lang.Object> stormConfig,
                                  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.

stormConfig - 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