backtype.storm.generated

Interface Nimbus.Iface

All Known Implementing Classes:

Nimbus.Client

Enclosing class:

Nimbus

public static interface Nimbus.Iface

Method Summary

Methods

Modifier and Type	Method and Description
void	activate(String name)
String	beginFileDownload(String file)
String	beginFileUpload()
void	deactivate(String name)
ByteBuffer	downloadChunk(String id)
void	finishFileUpload(String location)
ClusterSummary	getClusterInfo()
String	getNimbusConf()
StormTopology	getTopology(String id) Returns the compiled topology that contains ackers and metrics consumsers.
String	getTopologyConf(String id)
TopologyInfo	getTopologyInfo(String id)
TopologyInfo	getTopologyInfoWithOpts(String id, GetInfoOptions options)
StormTopology	getUserTopology(String id) Returns the user specified topology as submitted originally.
void	killTopology(String name)
void	killTopologyWithOpts(String name, KillOptions options)
void	rebalance(String name, RebalanceOptions options)
void	submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology)
void	submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options)
void	uploadChunk(String location, ByteBuffer chunk)
void	uploadNewCredentials(String name, Credentials creds)

Method Detail

submitTopology

void submitTopology(String name,
                  String uploadedJarLocation,
                  String jsonConf,
                  StormTopology topology)
                    throws AlreadyAliveException,
                           InvalidTopologyException,
                           AuthorizationException,
                           org.apache.thrift.TException

Throws:

AlreadyAliveException

InvalidTopologyException

AuthorizationException

org.apache.thrift.TException

submitTopologyWithOpts

void submitTopologyWithOpts(String name,
                          String uploadedJarLocation,
                          String jsonConf,
                          StormTopology topology,
                          SubmitOptions options)
                            throws AlreadyAliveException,
                                   InvalidTopologyException,
                                   AuthorizationException,
                                   org.apache.thrift.TException

Throws:

AlreadyAliveException

InvalidTopologyException

AuthorizationException

org.apache.thrift.TException

killTopology

void killTopology(String name)
                  throws NotAliveException,
                         AuthorizationException,
                         org.apache.thrift.TException

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

killTopologyWithOpts

void killTopologyWithOpts(String name,
                        KillOptions options)
                          throws NotAliveException,
                                 AuthorizationException,
                                 org.apache.thrift.TException

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

activate

void activate(String name)
              throws NotAliveException,
                     AuthorizationException,
                     org.apache.thrift.TException

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

deactivate

void deactivate(String name)
                throws NotAliveException,
                       AuthorizationException,
                       org.apache.thrift.TException

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

rebalance

void rebalance(String name,
             RebalanceOptions options)
               throws NotAliveException,
                      InvalidTopologyException,
                      AuthorizationException,
                      org.apache.thrift.TException

Throws:

NotAliveException

InvalidTopologyException

AuthorizationException

org.apache.thrift.TException

uploadNewCredentials

void uploadNewCredentials(String name,
                        Credentials creds)
                          throws NotAliveException,
                                 InvalidTopologyException,
                                 AuthorizationException,
                                 org.apache.thrift.TException

Throws:

NotAliveException

InvalidTopologyException

AuthorizationException

org.apache.thrift.TException

beginFileUpload

String beginFileUpload()
                       throws AuthorizationException,
                              org.apache.thrift.TException

Throws:

AuthorizationException

org.apache.thrift.TException

uploadChunk

void uploadChunk(String location,
               ByteBuffer chunk)
                 throws AuthorizationException,
                        org.apache.thrift.TException

Throws:

AuthorizationException

org.apache.thrift.TException

finishFileUpload

void finishFileUpload(String location)
                      throws AuthorizationException,
                             org.apache.thrift.TException

Throws:

AuthorizationException

org.apache.thrift.TException

beginFileDownload

String beginFileDownload(String file)
                         throws AuthorizationException,
                                org.apache.thrift.TException

Throws:

AuthorizationException

org.apache.thrift.TException

downloadChunk

ByteBuffer downloadChunk(String id)
                         throws AuthorizationException,
                                org.apache.thrift.TException

Throws:

AuthorizationException

org.apache.thrift.TException

getNimbusConf

String getNimbusConf()
                     throws AuthorizationException,
                            org.apache.thrift.TException

Throws:

AuthorizationException

org.apache.thrift.TException

getClusterInfo

ClusterSummary getClusterInfo()
                              throws AuthorizationException,
                                     org.apache.thrift.TException

Throws:

AuthorizationException

org.apache.thrift.TException

getTopologyInfo

TopologyInfo getTopologyInfo(String id)
                             throws NotAliveException,
                                    AuthorizationException,
                                    org.apache.thrift.TException

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

getTopologyInfoWithOpts

TopologyInfo getTopologyInfoWithOpts(String id,
                                   GetInfoOptions options)
                                     throws NotAliveException,
                                            AuthorizationException,
                                            org.apache.thrift.TException

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

getTopologyConf

String getTopologyConf(String id)
                       throws NotAliveException,
                              AuthorizationException,
                              org.apache.thrift.TException

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

getTopology

StormTopology getTopology(String id)
                          throws NotAliveException,
                                 AuthorizationException,
                                 org.apache.thrift.TException

Returns the compiled topology that contains ackers and metrics consumsers. Compare getUserTopology(String id).

Parameters:

id -

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

getUserTopology

StormTopology getUserTopology(String id)
                              throws NotAliveException,
                                     AuthorizationException,
                                     org.apache.thrift.TException

Returns the user specified topology as submitted originally. Compare getTopology(String id).

Parameters:

id -

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException