org.apache.storm.generated

Class Nimbus.AsyncClient

java.lang.Object

org.apache.thrift.async.TAsyncClient

org.apache.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.beginBlobDownload_call
static class	Nimbus.AsyncClient.beginCreateBlob_call
static class	Nimbus.AsyncClient.beginFileDownload_call
static class	Nimbus.AsyncClient.beginFileUpload_call
static class	Nimbus.AsyncClient.beginUpdateBlob_call
static class	Nimbus.AsyncClient.cancelBlobUpload_call
static class	Nimbus.AsyncClient.createStateInZookeeper_call
static class	Nimbus.AsyncClient.deactivate_call
static class	Nimbus.AsyncClient.debug_call
static class	Nimbus.AsyncClient.deleteBlob_call
static class	Nimbus.AsyncClient.downloadBlobChunk_call
static class	Nimbus.AsyncClient.downloadChunk_call
static class	Nimbus.AsyncClient.Factory
static class	Nimbus.AsyncClient.finishBlobUpload_call
static class	Nimbus.AsyncClient.finishFileUpload_call
static class	Nimbus.AsyncClient.getBlobMeta_call
static class	Nimbus.AsyncClient.getBlobReplication_call
static class	Nimbus.AsyncClient.getClusterInfo_call
static class	Nimbus.AsyncClient.getComponentPageInfo_call
static class	Nimbus.AsyncClient.getComponentPendingProfileActions_call
static class	Nimbus.AsyncClient.getLeader_call
static class	Nimbus.AsyncClient.getLogConfig_call
static class	Nimbus.AsyncClient.getNimbusConf_call
static class	Nimbus.AsyncClient.getSupervisorPageInfo_call
static class	Nimbus.AsyncClient.getTopology_call
static class	Nimbus.AsyncClient.getTopologyConf_call
static class	Nimbus.AsyncClient.getTopologyHistory_call
static class	Nimbus.AsyncClient.getTopologyInfo_call
static class	Nimbus.AsyncClient.getTopologyInfoWithOpts_call
static class	Nimbus.AsyncClient.getTopologyPageInfo_call
static class	Nimbus.AsyncClient.getUserTopology_call
static class	Nimbus.AsyncClient.isTopologyNameAllowed_call
static class	Nimbus.AsyncClient.killTopology_call
static class	Nimbus.AsyncClient.killTopologyWithOpts_call
static class	Nimbus.AsyncClient.listBlobs_call
static class	Nimbus.AsyncClient.rebalance_call
static class	Nimbus.AsyncClient.setBlobMeta_call
static class	Nimbus.AsyncClient.setLogConfig_call
static class	Nimbus.AsyncClient.setWorkerProfiler_call
static class	Nimbus.AsyncClient.submitTopology_call
static class	Nimbus.AsyncClient.submitTopologyWithOpts_call
static class	Nimbus.AsyncClient.updateBlobReplication_call
static class	Nimbus.AsyncClient.uploadBlobChunk_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
AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport)

Method Summary

Modifier and Type	Method and Description
void	activate(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	beginBlobDownload(String key, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	beginCreateBlob(String key, SettableBlobMeta meta, 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	beginUpdateBlob(String key, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	cancelBlobUpload(String session, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	createStateInZookeeper(String key, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	deactivate(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	debug(String name, String component, boolean enable, double samplingPercentage, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	deleteBlob(String key, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	downloadBlobChunk(String session, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	downloadChunk(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	finishBlobUpload(String session, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	finishFileUpload(String location, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getBlobMeta(String key, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getBlobReplication(String key, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getClusterInfo(org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getComponentPendingProfileActions(String id, String component_id, ProfileAction action, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getLeader(org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getLogConfig(String name, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getNimbusConf(org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getSupervisorPageInfo(String id, String host, boolean is_include_sys, 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	getTopologyHistory(String user, 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	getTopologyPageInfo(String id, String window, boolean is_include_sys, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getUserTopology(String id, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	isTopologyNameAllowed(String name, 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	listBlobs(String session, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	rebalance(String name, RebalanceOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	setBlobMeta(String key, SettableBlobMeta meta, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	setLogConfig(String name, LogConfig config, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	setWorkerProfiler(String id, ProfileRequest profileRequest, 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	updateBlobReplication(String key, int replication, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	uploadBlobChunk(String session, ByteBuffer chunk, 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

AsyncClient

public 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

setLogConfig

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

Specified by:

setLogConfig in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

getLogConfig

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

Specified by:

getLogConfig in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

debug

public void debug(String name,
                  String component,
                  boolean enable,
                  double samplingPercentage,
                  org.apache.thrift.async.AsyncMethodCallback resultHandler)
           throws org.apache.thrift.TException

Specified by:

debug in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

setWorkerProfiler

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

Specified by:

setWorkerProfiler in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

getComponentPendingProfileActions

public void getComponentPendingProfileActions(String id,
                                              String component_id,
                                              ProfileAction action,
                                              org.apache.thrift.async.AsyncMethodCallback resultHandler)
                                       throws org.apache.thrift.TException

Specified by:

getComponentPendingProfileActions 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

beginCreateBlob

public void beginCreateBlob(String key,
                            SettableBlobMeta meta,
                            org.apache.thrift.async.AsyncMethodCallback resultHandler)
                     throws org.apache.thrift.TException

Specified by:

beginCreateBlob in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

beginUpdateBlob

public void beginUpdateBlob(String key,
                            org.apache.thrift.async.AsyncMethodCallback resultHandler)
                     throws org.apache.thrift.TException

Specified by:

beginUpdateBlob in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

uploadBlobChunk

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

Specified by:

uploadBlobChunk in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

finishBlobUpload

public void finishBlobUpload(String session,
                             org.apache.thrift.async.AsyncMethodCallback resultHandler)
                      throws org.apache.thrift.TException

Specified by:

finishBlobUpload in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

cancelBlobUpload

public void cancelBlobUpload(String session,
                             org.apache.thrift.async.AsyncMethodCallback resultHandler)
                      throws org.apache.thrift.TException

Specified by:

cancelBlobUpload in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

getBlobMeta

public void getBlobMeta(String key,
                        org.apache.thrift.async.AsyncMethodCallback resultHandler)
                 throws org.apache.thrift.TException

Specified by:

getBlobMeta in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

setBlobMeta

public void setBlobMeta(String key,
                        SettableBlobMeta meta,
                        org.apache.thrift.async.AsyncMethodCallback resultHandler)
                 throws org.apache.thrift.TException

Specified by:

setBlobMeta in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

beginBlobDownload

public void beginBlobDownload(String key,
                              org.apache.thrift.async.AsyncMethodCallback resultHandler)
                       throws org.apache.thrift.TException

Specified by:

beginBlobDownload in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

downloadBlobChunk

public void downloadBlobChunk(String session,
                              org.apache.thrift.async.AsyncMethodCallback resultHandler)
                       throws org.apache.thrift.TException

Specified by:

downloadBlobChunk in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

deleteBlob

public void deleteBlob(String key,
                       org.apache.thrift.async.AsyncMethodCallback resultHandler)
                throws org.apache.thrift.TException

Specified by:

deleteBlob in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

listBlobs

public void listBlobs(String session,
                      org.apache.thrift.async.AsyncMethodCallback resultHandler)
               throws org.apache.thrift.TException

Specified by:

listBlobs in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

getBlobReplication

public void getBlobReplication(String key,
                               org.apache.thrift.async.AsyncMethodCallback resultHandler)
                        throws org.apache.thrift.TException

Specified by:

getBlobReplication in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

updateBlobReplication

public void updateBlobReplication(String key,
                                  int replication,
                                  org.apache.thrift.async.AsyncMethodCallback resultHandler)
                           throws org.apache.thrift.TException

Specified by:

updateBlobReplication in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

createStateInZookeeper

public void createStateInZookeeper(String key,
                                   org.apache.thrift.async.AsyncMethodCallback resultHandler)
                            throws org.apache.thrift.TException

Specified by:

createStateInZookeeper 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

getLeader

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

Specified by:

getLeader in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

isTopologyNameAllowed

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

Specified by:

isTopologyNameAllowed 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

getTopologyPageInfo

public void getTopologyPageInfo(String id,
                                String window,
                                boolean is_include_sys,
                                org.apache.thrift.async.AsyncMethodCallback resultHandler)
                         throws org.apache.thrift.TException

Specified by:

getTopologyPageInfo in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

getSupervisorPageInfo

public void getSupervisorPageInfo(String id,
                                  String host,
                                  boolean is_include_sys,
                                  org.apache.thrift.async.AsyncMethodCallback resultHandler)
                           throws org.apache.thrift.TException

Specified by:

getSupervisorPageInfo in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException

getComponentPageInfo

public void getComponentPageInfo(String topology_id,
                                 String component_id,
                                 String window,
                                 boolean is_include_sys,
                                 org.apache.thrift.async.AsyncMethodCallback resultHandler)
                          throws org.apache.thrift.TException

Specified by:

getComponentPageInfo 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

getTopologyHistory

public void getTopologyHistory(String user,
                               org.apache.thrift.async.AsyncMethodCallback resultHandler)
                        throws org.apache.thrift.TException

Specified by:

getTopologyHistory in interface Nimbus.AsyncIface

Throws:

org.apache.thrift.TException