backtype.storm
Interface ILocalCluster


public interface ILocalCluster


Method Summary
 void activate(java.lang.String topologyName)
           
 void deactivate(java.lang.String topologyName)
           
 ClusterSummary getClusterInfo()
           
 java.util.Map getState()
           
 StormTopology getTopology(java.lang.String id)
           
 java.lang.String getTopologyConf(java.lang.String id)
           
 TopologyInfo getTopologyInfo(java.lang.String id)
           
 void killTopology(java.lang.String topologyName)
           
 void killTopologyWithOpts(java.lang.String name, KillOptions options)
           
 void rebalance(java.lang.String name, RebalanceOptions options)
           
 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

killTopologyWithOpts

void killTopologyWithOpts(java.lang.String name,
                          KillOptions options)
                          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

rebalance

void rebalance(java.lang.String name,
               RebalanceOptions options)
               throws NotAliveException
Throws:
NotAliveException

shutdown

void shutdown()

getTopologyConf

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

getTopology

StormTopology getTopology(java.lang.String id)

getClusterInfo

ClusterSummary getClusterInfo()

getTopologyInfo

TopologyInfo getTopologyInfo(java.lang.String id)

getState

java.util.Map getState()