org.apache.storm.generated

Interface Nimbus.AsyncIface

All Known Implementing Classes:

Nimbus.AsyncClient

Enclosing class:

Nimbus

public static interface Nimbus.AsyncIface

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)

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

setLogConfig

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

Throws:

org.apache.thrift.TException

getLogConfig

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

Throws:

org.apache.thrift.TException

debug

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

Throws:

org.apache.thrift.TException

setWorkerProfiler

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

Throws:

org.apache.thrift.TException

getComponentPendingProfileActions

void getComponentPendingProfileActions(String id,
                                       String component_id,
                                       ProfileAction action,
                                       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

beginCreateBlob

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

Throws:

org.apache.thrift.TException

beginUpdateBlob

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

Throws:

org.apache.thrift.TException

uploadBlobChunk

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

Throws:

org.apache.thrift.TException

finishBlobUpload

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

Throws:

org.apache.thrift.TException

cancelBlobUpload

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

Throws:

org.apache.thrift.TException

getBlobMeta

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

Throws:

org.apache.thrift.TException

setBlobMeta

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

Throws:

org.apache.thrift.TException

beginBlobDownload

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

Throws:

org.apache.thrift.TException

downloadBlobChunk

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

Throws:

org.apache.thrift.TException

deleteBlob

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

Throws:

org.apache.thrift.TException

listBlobs

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

Throws:

org.apache.thrift.TException

getBlobReplication

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

Throws:

org.apache.thrift.TException

updateBlobReplication

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

Throws:

org.apache.thrift.TException

createStateInZookeeper

void createStateInZookeeper(String key,
                            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

getLeader

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

Throws:

org.apache.thrift.TException

isTopologyNameAllowed

void isTopologyNameAllowed(String name,
                           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

getTopologyPageInfo

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

Throws:

org.apache.thrift.TException

getSupervisorPageInfo

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

Throws:

org.apache.thrift.TException

getComponentPageInfo

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

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

getTopologyHistory

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

Throws:

org.apache.thrift.TException