backtype.storm

Class LocalCluster

java.lang.Object

backtype.storm.LocalCluster

All Implemented Interfaces:

ILocalCluster

public class LocalCluster
extends java.lang.Object
implements ILocalCluster

Constructor Summary

Constructors

Constructor and Description
LocalCluster()

Method Summary

Modifier and Type	Method and Description
void	activate(java.lang.String topoName)
void	deactivate(java.lang.String topoName)
java.util.Map	getState()
StormTopology	getTopology(java.lang.String topoName)
java.lang.String	getTopologyConf(java.lang.String topoName)
void	killTopology(java.lang.String topoName)
void	shutdown()
void	submitTopology(java.lang.String topoName, java.util.Map config, StormTopology stormTopology)

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalCluster

public LocalCluster()

Method Detail

submitTopology

public void submitTopology(java.lang.String topoName,
                           java.util.Map config,
                           StormTopology stormTopology)
                    throws AlreadyAliveException,
                           InvalidTopologyException

Specified by:

submitTopology in interface ILocalCluster

Throws:

AlreadyAliveException

InvalidTopologyException

killTopology

public void killTopology(java.lang.String topoName)
                  throws NotAliveException

Specified by:

killTopology in interface ILocalCluster

Throws:

NotAliveException

activate

public void activate(java.lang.String topoName)
              throws NotAliveException

Specified by:

activate in interface ILocalCluster

Throws:

NotAliveException

deactivate

public void deactivate(java.lang.String topoName)
                throws NotAliveException

Specified by:

deactivate in interface ILocalCluster

Throws:

NotAliveException

shutdown

public void shutdown()

Specified by:

shutdown in interface ILocalCluster

getTopologyConf

public java.lang.String getTopologyConf(java.lang.String topoName)

Specified by:

getTopologyConf in interface ILocalCluster

getTopology

public StormTopology getTopology(java.lang.String topoName)

Specified by:

getTopology in interface ILocalCluster

getState

public java.util.Map getState()

Specified by:

getState in interface ILocalCluster