backtype.storm.generated

Class Nimbus.AsyncClient

java.lang.Object

org.apache.thrift.async.TAsyncClient

backtype.storm.generated.Nimbus.AsyncClient

All Implemented Interfaces:

Nimbus.AsyncIface

Enclosing class:

Nimbus

public static class Nimbus.AsyncClient
extends org.apache.thrift.async.TAsyncClient
implements Nimbus.AsyncIface

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Nimbus.AsyncClient.activate_call
static class	Nimbus.AsyncClient.beginFileDownload_call
static class	Nimbus.AsyncClient.beginFileUpload_call
static class	Nimbus.AsyncClient.deactivate_call
static class	Nimbus.AsyncClient.downloadChunk_call
static class	Nimbus.AsyncClient.Factory
static class	Nimbus.AsyncClient.finishFileUpload_call
static class	Nimbus.AsyncClient.getClusterInfo_call
static class	Nimbus.AsyncClient.getNimbusConf_call
static class	Nimbus.AsyncClient.getTopology_call
static class	Nimbus.AsyncClient.getTopologyConf_call
static class	Nimbus.AsyncClient.getTopologyInfo_call
static class	Nimbus.AsyncClient.getTopologyInfoWithOpts_call
static class	Nimbus.AsyncClient.getUserTopology_call
static class	Nimbus.AsyncClient.killTopology_call
static class	Nimbus.AsyncClient.killTopologyWithOpts_call
static class	Nimbus.AsyncClient.rebalance_call
static class	Nimbus.AsyncClient.submitTopology_call
static class	Nimbus.AsyncClient.submitTopologyWithOpts_call
static class	Nimbus.AsyncClient.uploadChunk_call
static class	Nimbus.AsyncClient.uploadNewCredentials_call

Field Summary

Fields inherited from class org.apache.thrift.async.TAsyncClient

___currentMethod, ___manager, ___protocolFactory, ___transport

Constructor Summary

Constructors

Constructor and Description
Nimbus.AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport)

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)

Methods inherited from class org.apache.thrift.async.TAsyncClient

checkReady, getError, getProtocolFactory, getTimeout, hasError, hasTimeout, onComplete, onError, setTimeout

Methods inherited from class java.lang.Object

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

Constructor Detail

Nimbus.AsyncClient

public Nimbus.AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory,
                  org.apache.thrift.async.TAsyncClientManager clientManager,
                  org.apache.thrift.transport.TNonblockingTransport transport)

Method Detail

submitTopology

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

Specified by:

submitTopology in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

submitTopologyWithOpts

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

Specified by:

submitTopologyWithOpts in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

killTopology

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

Specified by:

killTopology in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

killTopologyWithOpts

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

Specified by:

killTopologyWithOpts in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

activate

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

Specified by:

activate in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

deactivate

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

Specified by:

deactivate in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

rebalance

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

Specified by:

rebalance in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

uploadNewCredentials

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

Specified by:

uploadNewCredentials in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

beginFileUpload

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

Specified by:

beginFileUpload in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

uploadChunk

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

Specified by:

uploadChunk in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

finishFileUpload

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

Specified by:

finishFileUpload in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

beginFileDownload

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

Specified by:

beginFileDownload in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

downloadChunk

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

Specified by:

downloadChunk in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

getNimbusConf

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

Specified by:

getNimbusConf in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

getClusterInfo

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

Specified by:

getClusterInfo in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

getTopologyInfo

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

Specified by:

getTopologyInfo in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

getTopologyInfoWithOpts

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

Specified by:

getTopologyInfoWithOpts in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

getTopologyConf

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

Specified by:

getTopologyConf in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

getTopology

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

Specified by:

getTopology in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

getUserTopology

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

Specified by:

getUserTopology in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException