backtype.storm.generated

Interface Nimbus.AsyncIface

All Known Implementing Classes:

Nimbus.AsyncClient

Enclosing class:

Nimbus

public static interface Nimbus.AsyncIface

Method Summary

Methods

Modifier and Type	Method and Description
void	activate(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	beginFileDownload(String file, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	beginFileUpload(org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	deactivate(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	downloadChunk(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	finishFileUpload(String location, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getClusterInfo(org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getNimbusConf(org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getTopology(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getTopologyConf(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getTopologyInfo(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getTopologyInfoWithOpts(String id, GetInfoOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getUserTopology(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	killTopology(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	killTopologyWithOpts(String name, KillOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	rebalance(String name, RebalanceOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	uploadChunk(String location, ByteBuffer chunk, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	uploadNewCredentials(String name, Credentials creds, org.apache.thrift.async.AsyncMethodCallback resultHandler)

Method Detail

submitTopology

void submitTopology(String name,
                  String uploadedJarLocation,
                  String jsonConf,
                  StormTopology topology,
                  org.apache.thrift.async.AsyncMethodCallback resultHandler)
                    throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

submitTopologyWithOpts

void submitTopologyWithOpts(String name,
                          String uploadedJarLocation,
                          String jsonConf,
                          StormTopology topology,
                          SubmitOptions options,
                          org.apache.thrift.async.AsyncMethodCallback resultHandler)
                            throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

killTopology

void killTopology(String name,
                org.apache.thrift.async.AsyncMethodCallback resultHandler)
                  throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

killTopologyWithOpts

void killTopologyWithOpts(String name,
                        KillOptions options,
                        org.apache.thrift.async.AsyncMethodCallback resultHandler)
                          throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

activate

void activate(String name,
            org.apache.thrift.async.AsyncMethodCallback resultHandler)
              throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

deactivate

void deactivate(String name,
              org.apache.thrift.async.AsyncMethodCallback resultHandler)
                throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

rebalance

void rebalance(String name,
             RebalanceOptions options,
             org.apache.thrift.async.AsyncMethodCallback resultHandler)
               throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

uploadNewCredentials

void uploadNewCredentials(String name,
                        Credentials creds,
                        org.apache.thrift.async.AsyncMethodCallback resultHandler)
                          throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

beginFileUpload

void beginFileUpload(org.apache.thrift.async.AsyncMethodCallback resultHandler)
                     throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

uploadChunk

void uploadChunk(String location,
               ByteBuffer chunk,
               org.apache.thrift.async.AsyncMethodCallback resultHandler)
                 throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

finishFileUpload

void finishFileUpload(String location,
                    org.apache.thrift.async.AsyncMethodCallback resultHandler)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

beginFileDownload

void beginFileDownload(String file,
                     org.apache.thrift.async.AsyncMethodCallback resultHandler)
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

downloadChunk

void downloadChunk(String id,
                 org.apache.thrift.async.AsyncMethodCallback resultHandler)
                   throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

getNimbusConf

void getNimbusConf(org.apache.thrift.async.AsyncMethodCallback resultHandler)
                   throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

getClusterInfo

void getClusterInfo(org.apache.thrift.async.AsyncMethodCallback resultHandler)
                    throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

getTopologyInfo

void getTopologyInfo(String id,
                   org.apache.thrift.async.AsyncMethodCallback resultHandler)
                     throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

getTopologyInfoWithOpts

void getTopologyInfoWithOpts(String id,
                           GetInfoOptions options,
                           org.apache.thrift.async.AsyncMethodCallback resultHandler)
                             throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

getTopologyConf

void getTopologyConf(String id,
                   org.apache.thrift.async.AsyncMethodCallback resultHandler)
                     throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

getTopology

void getTopology(String id,
               org.apache.thrift.async.AsyncMethodCallback resultHandler)
                 throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

getUserTopology

void getUserTopology(String id,
                   org.apache.thrift.async.AsyncMethodCallback resultHandler)
                     throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException