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()