backtype.storm

Interface ILocalCluster

All Known Implementing Classes:

LocalCluster

public interface ILocalCluster

Method Summary

Modifier and Type	Method and Description
void	activate(java.lang.String topologyName)
void	deactivate(java.lang.String topologyName)
java.util.Map	getState()
StormTopology	getTopology(java.lang.String id)
java.lang.String	getTopologyConf(java.lang.String id)
void	killTopology(java.lang.String topologyName)
void	shutdown()
void	submitTopology(java.lang.String topologyName, java.util.Map conf, StormTopology topology)

Method Detail

submitTopology

void submitTopology(java.lang.String topologyName,
                    java.util.Map conf,
                    StormTopology topology)
             throws AlreadyAliveException,
                    InvalidTopologyException

Throws:

AlreadyAliveException

InvalidTopologyException

killTopology

void killTopology(java.lang.String topologyName)
           throws NotAliveException

Throws:

NotAliveException

activate

void activate(java.lang.String topologyName)
       throws NotAliveException

Throws:

NotAliveException

deactivate

void deactivate(java.lang.String topologyName)
         throws NotAliveException

Throws:

NotAliveException

shutdown

void shutdown()

getTopologyConf

java.lang.String getTopologyConf(java.lang.String id)

getTopology

StormTopology getTopology(java.lang.String id)

getState

java.util.Map getState()