backtype.storm

Interface ILocalCluster

public interface ILocalCluster

Method Summary

Methods

Modifier and Type	Method and Description
void	activate(String topologyName)
void	deactivate(String topologyName)
ClusterSummary	getClusterInfo()
Map	getState()
StormTopology	getTopology(String id)
String	getTopologyConf(String id)
TopologyInfo	getTopologyInfo(String id)
void	killTopology(String topologyName)
void	killTopologyWithOpts(String name, KillOptions options)
void	rebalance(String name, RebalanceOptions options)
void	shutdown()
void	submitTopology(String topologyName, Map conf, StormTopology topology)
void	submitTopologyWithOpts(String topologyName, Map conf, StormTopology topology, SubmitOptions submitOpts)
void	uploadNewCredentials(String topologyName, Credentials creds)

Method Detail

submitTopology

void submitTopology(String topologyName,
                  Map conf,
                  StormTopology topology)
                    throws AlreadyAliveException,
                           InvalidTopologyException

Throws:

AlreadyAliveException

InvalidTopologyException

submitTopologyWithOpts

void submitTopologyWithOpts(String topologyName,
                          Map conf,
                          StormTopology topology,
                          SubmitOptions submitOpts)
                            throws AlreadyAliveException,
                                   InvalidTopologyException

Throws:

AlreadyAliveException

InvalidTopologyException

uploadNewCredentials

void uploadNewCredentials(String topologyName,
                        Credentials creds)

killTopology

void killTopology(String topologyName)
                  throws NotAliveException

Throws:

NotAliveException

killTopologyWithOpts

void killTopologyWithOpts(String name,
                        KillOptions options)
                          throws NotAliveException

Throws:

NotAliveException

activate

void activate(String topologyName)
              throws NotAliveException

Throws:

NotAliveException

deactivate

void deactivate(String topologyName)
                throws NotAliveException

Throws:

NotAliveException

rebalance

void rebalance(String name,
             RebalanceOptions options)
               throws NotAliveException

Throws:

NotAliveException

shutdown

void shutdown()

getTopologyConf

String getTopologyConf(String id)

getTopology

StormTopology getTopology(String id)

getClusterInfo

ClusterSummary getClusterInfo()

getTopologyInfo

TopologyInfo getTopologyInfo(String id)

getState

Map getState()