backtype.storm
Interface ILocalCluster
- public interface ILocalCluster 
 
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()
-