Package org.apache.storm.generated

Class Nimbus.AsyncClient

    • Constructor Detail

      • AsyncClient

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

    • Method Detail

      • submitTopology

        public void submitTopology​(String name,
                           String uploadedJarLocation,
                           String jsonConf,
                           StormTopology topology,
                           org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                    throws org.apache.storm.thrift.TException
        Specified by:
        submitTopology in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • killTopology

        public void killTopology​(String name,
                         org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                  throws org.apache.storm.thrift.TException
        Specified by:
        killTopology in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • killTopologyWithOpts

        public void killTopologyWithOpts​(String name,
                                 KillOptions options,
                                 org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                          throws org.apache.storm.thrift.TException
        Specified by:
        killTopologyWithOpts in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • activate

        public void activate​(String name,
                     org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
              throws org.apache.storm.thrift.TException
        Specified by:
        activate in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • deactivate

        public void deactivate​(String name,
                       org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                throws org.apache.storm.thrift.TException
        Specified by:
        deactivate in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • rebalance

        public void rebalance​(String name,
                      RebalanceOptions options,
                      org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
               throws org.apache.storm.thrift.TException
        Specified by:
        rebalance in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • setLogConfig

        public void setLogConfig​(String name,
                         LogConfig config,
                         org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                  throws org.apache.storm.thrift.TException
        Specified by:
        setLogConfig in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • getLogConfig

        public void getLogConfig​(String name,
                         org.apache.storm.thrift.async.AsyncMethodCallback<LogConfig> resultHandler)
                  throws org.apache.storm.thrift.TException
        Specified by:
        getLogConfig in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • debug

        public void debug​(String name,
                  String component,
                  boolean enable,
                  double samplingPercentage,
                  org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
           throws org.apache.storm.thrift.TException
        Specified by:
        debug in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • setWorkerProfiler

        public void setWorkerProfiler​(String id,
                              ProfileRequest profileRequest,
                              org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                       throws org.apache.storm.thrift.TException
        Specified by:
        setWorkerProfiler in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • uploadNewCredentials

        public void uploadNewCredentials​(String name,
                                 Credentials creds,
                                 org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                          throws org.apache.storm.thrift.TException
        Specified by:
        uploadNewCredentials in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • beginCreateBlob

        public void beginCreateBlob​(String key,
                            SettableBlobMeta meta,
                            org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler)
                     throws org.apache.storm.thrift.TException
        Specified by:
        beginCreateBlob in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • beginUpdateBlob

        public void beginUpdateBlob​(String key,
                            org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler)
                     throws org.apache.storm.thrift.TException
        Specified by:
        beginUpdateBlob in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • uploadBlobChunk

        public void uploadBlobChunk​(String session,
                            ByteBuffer chunk,
                            org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                     throws org.apache.storm.thrift.TException
        Specified by:
        uploadBlobChunk in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • finishBlobUpload

        public void finishBlobUpload​(String session,
                             org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                      throws org.apache.storm.thrift.TException
        Specified by:
        finishBlobUpload in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • cancelBlobUpload

        public void cancelBlobUpload​(String session,
                             org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                      throws org.apache.storm.thrift.TException
        Specified by:
        cancelBlobUpload in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • getBlobMeta

        public void getBlobMeta​(String key,
                        org.apache.storm.thrift.async.AsyncMethodCallback<ReadableBlobMeta> resultHandler)
                 throws org.apache.storm.thrift.TException
        Specified by:
        getBlobMeta in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • setBlobMeta

        public void setBlobMeta​(String key,
                        SettableBlobMeta meta,
                        org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                 throws org.apache.storm.thrift.TException
        Specified by:
        setBlobMeta in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • beginBlobDownload

        public void beginBlobDownload​(String key,
                              org.apache.storm.thrift.async.AsyncMethodCallback<BeginDownloadResult> resultHandler)
                       throws org.apache.storm.thrift.TException
        Specified by:
        beginBlobDownload in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • downloadBlobChunk

        public void downloadBlobChunk​(String session,
                              org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler)
                       throws org.apache.storm.thrift.TException
        Specified by:
        downloadBlobChunk in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • deleteBlob

        public void deleteBlob​(String key,
                       org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                throws org.apache.storm.thrift.TException
        Specified by:
        deleteBlob in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • listBlobs

        public void listBlobs​(String session,
                      org.apache.storm.thrift.async.AsyncMethodCallback<ListBlobsResult> resultHandler)
               throws org.apache.storm.thrift.TException
        Specified by:
        listBlobs in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • getBlobReplication

        public void getBlobReplication​(String key,
                               org.apache.storm.thrift.async.AsyncMethodCallback<Integer> resultHandler)
                        throws org.apache.storm.thrift.TException
        Specified by:
        getBlobReplication in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • updateBlobReplication

        public void updateBlobReplication​(String key,
                                  int replication,
                                  org.apache.storm.thrift.async.AsyncMethodCallback<Integer> resultHandler)
                           throws org.apache.storm.thrift.TException
        Specified by:
        updateBlobReplication in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • createStateInZookeeper

        public void createStateInZookeeper​(String key,
                                   org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                            throws org.apache.storm.thrift.TException
        Specified by:
        createStateInZookeeper in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • beginFileUpload

        public void beginFileUpload​(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler)
                     throws org.apache.storm.thrift.TException
        Specified by:
        beginFileUpload in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • uploadChunk

        public void uploadChunk​(String location,
                        ByteBuffer chunk,
                        org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                 throws org.apache.storm.thrift.TException
        Specified by:
        uploadChunk in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • finishFileUpload

        public void finishFileUpload​(String location,
                             org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                      throws org.apache.storm.thrift.TException
        Specified by:
        finishFileUpload in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • downloadChunk

        public void downloadChunk​(String id,
                          org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler)
                   throws org.apache.storm.thrift.TException
        Specified by:
        downloadChunk in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • getNimbusConf

        public void getNimbusConf​(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler)
                   throws org.apache.storm.thrift.TException
        Specified by:
        getNimbusConf in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • getClusterInfo

        public void getClusterInfo​(org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary> resultHandler)
                    throws org.apache.storm.thrift.TException
        Specified by:
        getClusterInfo in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • getTopologySummaries

        public void getTopologySummaries​(org.apache.storm.thrift.async.AsyncMethodCallback<List<TopologySummary>> resultHandler)
                          throws org.apache.storm.thrift.TException
        Specified by:
        getTopologySummaries in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • getTopologySummaryByName

        public void getTopologySummaryByName​(String name,
                                     org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler)
                              throws org.apache.storm.thrift.TException
        Specified by:
        getTopologySummaryByName in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • getTopologySummary

        public void getTopologySummary​(String id,
                               org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler)
                        throws org.apache.storm.thrift.TException
        Specified by:
        getTopologySummary in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • getLeader

        public void getLeader​(org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler)
               throws org.apache.storm.thrift.TException
        Specified by:
        getLeader in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • isTopologyNameAllowed

        public void isTopologyNameAllowed​(String name,
                                  org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler)
                           throws org.apache.storm.thrift.TException
        Specified by:
        isTopologyNameAllowed in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • getTopologyInfoByName

        public void getTopologyInfoByName​(String name,
                                  org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler)
                           throws org.apache.storm.thrift.TException
        Specified by:
        getTopologyInfoByName in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • getTopologyInfo

        public void getTopologyInfo​(String id,
                            org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler)
                     throws org.apache.storm.thrift.TException
        Specified by:
        getTopologyInfo in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • getTopologyPageInfo

        public void getTopologyPageInfo​(String id,
                                String window,
                                boolean is_include_sys,
                                org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> resultHandler)
                         throws org.apache.storm.thrift.TException
        Specified by:
        getTopologyPageInfo in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • getSupervisorPageInfo

        public void getSupervisorPageInfo​(String id,
                                  String host,
                                  boolean is_include_sys,
                                  org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo> resultHandler)
                           throws org.apache.storm.thrift.TException
        Specified by:
        getSupervisorPageInfo in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • getComponentPageInfo

        public void getComponentPageInfo​(String topology_id,
                                 String component_id,
                                 String window,
                                 boolean is_include_sys,
                                 org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> resultHandler)
                          throws org.apache.storm.thrift.TException
        Specified by:
        getComponentPageInfo in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • getTopologyConf

        public void getTopologyConf​(String id,
                            org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler)
                     throws org.apache.storm.thrift.TException
        Specified by:
        getTopologyConf in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • getTopology

        public void getTopology​(String id,
                        org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler)
                 throws org.apache.storm.thrift.TException
        Specified by:
        getTopology in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • getUserTopology

        public void getUserTopology​(String id,
                            org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler)
                     throws org.apache.storm.thrift.TException
        Specified by:
        getUserTopology in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • getTopologyHistory

        public void getTopologyHistory​(String user,
                               org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler)
                        throws org.apache.storm.thrift.TException
        Specified by:
        getTopologyHistory in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • processWorkerMetrics

        public void processWorkerMetrics​(WorkerMetrics metrics,
                                 org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                          throws org.apache.storm.thrift.TException
        Specified by:
        processWorkerMetrics in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException

      • isRemoteBlobExists

        public void isRemoteBlobExists​(String blobKey,
                               org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler)
                        throws org.apache.storm.thrift.TException
        Specified by:
        isRemoteBlobExists in interface Nimbus.AsyncIface
        Throws:
        org.apache.storm.thrift.TException