backtype.storm.generated

Class Nimbus.Client

java.lang.Object

org.apache.thrift.TServiceClient

backtype.storm.generated.Nimbus.Client

All Implemented Interfaces:

Nimbus.Iface

Enclosing class:

Nimbus

public static class Nimbus.Client
extends org.apache.thrift.TServiceClient
implements Nimbus.Iface

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Nimbus.Client.Factory

Field Summary

Fields inherited from class org.apache.thrift.TServiceClient

iprot_, oprot_, seqid_

Constructor Summary

Constructors

Constructor and Description
Nimbus.Client(org.apache.thrift.protocol.TProtocol prot)
Nimbus.Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot)

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	recv_activate()
String	recv_beginFileDownload()
String	recv_beginFileUpload()
void	recv_deactivate()
ByteBuffer	recv_downloadChunk()
void	recv_finishFileUpload()
ClusterSummary	recv_getClusterInfo()
String	recv_getNimbusConf()
StormTopology	recv_getTopology()
String	recv_getTopologyConf()
TopologyInfo	recv_getTopologyInfo()
TopologyInfo	recv_getTopologyInfoWithOpts()
StormTopology	recv_getUserTopology()
void	recv_killTopology()
void	recv_killTopologyWithOpts()
void	recv_rebalance()
void	recv_submitTopology()
void	recv_submitTopologyWithOpts()
void	recv_uploadChunk()
void	recv_uploadNewCredentials()
void	send_activate(String name)
void	send_beginFileDownload(String file)
void	send_beginFileUpload()
void	send_deactivate(String name)
void	send_downloadChunk(String id)
void	send_finishFileUpload(String location)
void	send_getClusterInfo()
void	send_getNimbusConf()
void	send_getTopology(String id)
void	send_getTopologyConf(String id)
void	send_getTopologyInfo(String id)
void	send_getTopologyInfoWithOpts(String id, GetInfoOptions options)
void	send_getUserTopology(String id)
void	send_killTopology(String name)
void	send_killTopologyWithOpts(String name, KillOptions options)
void	send_rebalance(String name, RebalanceOptions options)
void	send_submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology)
void	send_submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options)
void	send_uploadChunk(String location, ByteBuffer chunk)
void	send_uploadNewCredentials(String name, Credentials creds)
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)

Methods inherited from class org.apache.thrift.TServiceClient

getInputProtocol, getOutputProtocol, receiveBase, sendBase

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Nimbus.Client

public Nimbus.Client(org.apache.thrift.protocol.TProtocol prot)

Nimbus.Client

public Nimbus.Client(org.apache.thrift.protocol.TProtocol iprot,
             org.apache.thrift.protocol.TProtocol oprot)

Method Detail

submitTopology

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

Specified by:

submitTopology in interface Nimbus.Iface

Throws:

AlreadyAliveException

InvalidTopologyException

AuthorizationException

org.apache.thrift.TException

send_submitTopology

public void send_submitTopology(String name,
                       String uploadedJarLocation,
                       String jsonConf,
                       StormTopology topology)
                         throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_submitTopology

public void recv_submitTopology()
                         throws AlreadyAliveException,
                                InvalidTopologyException,
                                AuthorizationException,
                                org.apache.thrift.TException

Throws:

AlreadyAliveException

InvalidTopologyException

AuthorizationException

org.apache.thrift.TException

submitTopologyWithOpts

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

Specified by:

submitTopologyWithOpts in interface Nimbus.Iface

Throws:

AlreadyAliveException

InvalidTopologyException

AuthorizationException

org.apache.thrift.TException

send_submitTopologyWithOpts

public void send_submitTopologyWithOpts(String name,
                               String uploadedJarLocation,
                               String jsonConf,
                               StormTopology topology,
                               SubmitOptions options)
                                 throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_submitTopologyWithOpts

public void recv_submitTopologyWithOpts()
                                 throws AlreadyAliveException,
                                        InvalidTopologyException,
                                        AuthorizationException,
                                        org.apache.thrift.TException

Throws:

AlreadyAliveException

InvalidTopologyException

AuthorizationException

org.apache.thrift.TException

killTopology

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

Specified by:

killTopology in interface Nimbus.Iface

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

send_killTopology

public void send_killTopology(String name)
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_killTopology

public void recv_killTopology()
                       throws NotAliveException,
                              AuthorizationException,
                              org.apache.thrift.TException

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

killTopologyWithOpts

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

Specified by:

killTopologyWithOpts in interface Nimbus.Iface

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

send_killTopologyWithOpts

public void send_killTopologyWithOpts(String name,
                             KillOptions options)
                               throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_killTopologyWithOpts

public void recv_killTopologyWithOpts()
                               throws NotAliveException,
                                      AuthorizationException,
                                      org.apache.thrift.TException

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

activate

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

Specified by:

activate in interface Nimbus.Iface

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

send_activate

public void send_activate(String name)
                   throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_activate

public void recv_activate()
                   throws NotAliveException,
                          AuthorizationException,
                          org.apache.thrift.TException

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

deactivate

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

Specified by:

deactivate in interface Nimbus.Iface

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

send_deactivate

public void send_deactivate(String name)
                     throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_deactivate

public void recv_deactivate()
                     throws NotAliveException,
                            AuthorizationException,
                            org.apache.thrift.TException

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

rebalance

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

Specified by:

rebalance in interface Nimbus.Iface

Throws:

NotAliveException

InvalidTopologyException

AuthorizationException

org.apache.thrift.TException

send_rebalance

public void send_rebalance(String name,
                  RebalanceOptions options)
                    throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_rebalance

public void recv_rebalance()
                    throws NotAliveException,
                           InvalidTopologyException,
                           AuthorizationException,
                           org.apache.thrift.TException

Throws:

NotAliveException

InvalidTopologyException

AuthorizationException

org.apache.thrift.TException

uploadNewCredentials

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

Specified by:

uploadNewCredentials in interface Nimbus.Iface

Throws:

NotAliveException

InvalidTopologyException

AuthorizationException

org.apache.thrift.TException

send_uploadNewCredentials

public void send_uploadNewCredentials(String name,
                             Credentials creds)
                               throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_uploadNewCredentials

public void recv_uploadNewCredentials()
                               throws NotAliveException,
                                      InvalidTopologyException,
                                      AuthorizationException,
                                      org.apache.thrift.TException

Throws:

NotAliveException

InvalidTopologyException

AuthorizationException

org.apache.thrift.TException

beginFileUpload

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

Specified by:

beginFileUpload in interface Nimbus.Iface

Throws:

AuthorizationException

org.apache.thrift.TException

send_beginFileUpload

public void send_beginFileUpload()
                          throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_beginFileUpload

public String recv_beginFileUpload()
                            throws AuthorizationException,
                                   org.apache.thrift.TException

Throws:

AuthorizationException

org.apache.thrift.TException

uploadChunk

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

Specified by:

uploadChunk in interface Nimbus.Iface

Throws:

AuthorizationException

org.apache.thrift.TException

send_uploadChunk

public void send_uploadChunk(String location,
                    ByteBuffer chunk)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_uploadChunk

public void recv_uploadChunk()
                      throws AuthorizationException,
                             org.apache.thrift.TException

Throws:

AuthorizationException

org.apache.thrift.TException

finishFileUpload

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

Specified by:

finishFileUpload in interface Nimbus.Iface

Throws:

AuthorizationException

org.apache.thrift.TException

send_finishFileUpload

public void send_finishFileUpload(String location)
                           throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_finishFileUpload

public void recv_finishFileUpload()
                           throws AuthorizationException,
                                  org.apache.thrift.TException

Throws:

AuthorizationException

org.apache.thrift.TException

beginFileDownload

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

Specified by:

beginFileDownload in interface Nimbus.Iface

Throws:

AuthorizationException

org.apache.thrift.TException

send_beginFileDownload

public void send_beginFileDownload(String file)
                            throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_beginFileDownload

public String recv_beginFileDownload()
                              throws AuthorizationException,
                                     org.apache.thrift.TException

Throws:

AuthorizationException

org.apache.thrift.TException

downloadChunk

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

Specified by:

downloadChunk in interface Nimbus.Iface

Throws:

AuthorizationException

org.apache.thrift.TException

send_downloadChunk

public void send_downloadChunk(String id)
                        throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_downloadChunk

public ByteBuffer recv_downloadChunk()
                              throws AuthorizationException,
                                     org.apache.thrift.TException

Throws:

AuthorizationException

org.apache.thrift.TException

getNimbusConf

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

Specified by:

getNimbusConf in interface Nimbus.Iface

Throws:

AuthorizationException

org.apache.thrift.TException

send_getNimbusConf

public void send_getNimbusConf()
                        throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getNimbusConf

public String recv_getNimbusConf()
                          throws AuthorizationException,
                                 org.apache.thrift.TException

Throws:

AuthorizationException

org.apache.thrift.TException

getClusterInfo

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

Specified by:

getClusterInfo in interface Nimbus.Iface

Throws:

AuthorizationException

org.apache.thrift.TException

send_getClusterInfo

public void send_getClusterInfo()
                         throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getClusterInfo

public ClusterSummary recv_getClusterInfo()
                                   throws AuthorizationException,
                                          org.apache.thrift.TException

Throws:

AuthorizationException

org.apache.thrift.TException

getTopologyInfo

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

Specified by:

getTopologyInfo in interface Nimbus.Iface

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

send_getTopologyInfo

public void send_getTopologyInfo(String id)
                          throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getTopologyInfo

public TopologyInfo recv_getTopologyInfo()
                                  throws NotAliveException,
                                         AuthorizationException,
                                         org.apache.thrift.TException

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

getTopologyInfoWithOpts

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

Specified by:

getTopologyInfoWithOpts in interface Nimbus.Iface

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

send_getTopologyInfoWithOpts

public void send_getTopologyInfoWithOpts(String id,
                                GetInfoOptions options)
                                  throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getTopologyInfoWithOpts

public TopologyInfo recv_getTopologyInfoWithOpts()
                                          throws NotAliveException,
                                                 AuthorizationException,
                                                 org.apache.thrift.TException

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

getTopologyConf

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

Specified by:

getTopologyConf in interface Nimbus.Iface

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

send_getTopologyConf

public void send_getTopologyConf(String id)
                          throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getTopologyConf

public String recv_getTopologyConf()
                            throws NotAliveException,
                                   AuthorizationException,
                                   org.apache.thrift.TException

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

getTopology

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

Description copied from interface: Nimbus.Iface

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

Specified by:

getTopology in interface Nimbus.Iface

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

send_getTopology

public void send_getTopology(String id)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getTopology

public StormTopology recv_getTopology()
                               throws NotAliveException,
                                      AuthorizationException,
                                      org.apache.thrift.TException

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

getUserTopology

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

Description copied from interface: Nimbus.Iface

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

Specified by:

getUserTopology in interface Nimbus.Iface

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException

send_getUserTopology

public void send_getUserTopology(String id)
                          throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getUserTopology

public StormTopology recv_getUserTopology()
                                   throws NotAliveException,
                                          AuthorizationException,
                                          org.apache.thrift.TException

Throws:

NotAliveException

AuthorizationException

org.apache.thrift.TException