storm.starter.util

Class StormRunner

java.lang.Object

storm.starter.util.StormRunner

public final class StormRunner
extends Object

Method Summary

Modifier and Type	Method and Description
static void	runTopologyLocally(StormTopology topology, String topologyName, Config conf, int runtimeInSeconds)
static void	runTopologyRemotely(StormTopology topology, String topologyName, Config conf)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

runTopologyLocally

public static void runTopologyLocally(StormTopology topology,
                                      String topologyName,
                                      Config conf,
                                      int runtimeInSeconds)
                               throws InterruptedException

Throws:

InterruptedException

runTopologyRemotely

public static void runTopologyRemotely(StormTopology topology,
                                       String topologyName,
                                       Config conf)
                                throws AlreadyAliveException,
                                       InvalidTopologyException

Throws:

AlreadyAliveException

InvalidTopologyException