storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [2/6] storm git commit: STORM-2947: Remove deprecated field and method from Thrift
Date Mon, 30 Jul 2018 18:22:50 GMT
http://git-wip-us.apache.org/repos/asf/storm/blob/1768062f/storm-client/src/jvm/org/apache/storm/generated/Nimbus.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/generated/Nimbus.java b/storm-client/src/jvm/org/apache/storm/generated/Nimbus.java
index de9a3b3..47bc7fc 100644
--- a/storm-client/src/jvm/org/apache/storm/generated/Nimbus.java
+++ b/storm-client/src/jvm/org/apache/storm/generated/Nimbus.java
@@ -101,8 +101,6 @@ public class Nimbus {
 
     public void finishFileUpload(java.lang.String location) throws AuthorizationException, org.apache.storm.thrift.TException;
 
-    public java.lang.String beginFileDownload(java.lang.String file) throws AuthorizationException, org.apache.storm.thrift.TException;
-
     public java.nio.ByteBuffer downloadChunk(java.lang.String id) throws AuthorizationException, org.apache.storm.thrift.TException;
 
     public java.lang.String getNimbusConf() throws AuthorizationException, org.apache.storm.thrift.TException;
@@ -237,8 +235,6 @@ public class Nimbus {
 
     public void finishFileUpload(java.lang.String location, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException;
 
-    public void beginFileDownload(java.lang.String file, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.thrift.TException;
-
     public void downloadChunk(java.lang.String id, org.apache.storm.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer> resultHandler) throws org.apache.storm.thrift.TException;
 
     public void getNimbusConf(org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.thrift.TException;
@@ -1093,32 +1089,6 @@ public class Nimbus {
       return;
     }
 
-    public java.lang.String beginFileDownload(java.lang.String file) throws AuthorizationException, org.apache.storm.thrift.TException
-    {
-      send_beginFileDownload(file);
-      return recv_beginFileDownload();
-    }
-
-    public void send_beginFileDownload(java.lang.String file) throws org.apache.storm.thrift.TException
-    {
-      beginFileDownload_args args = new beginFileDownload_args();
-      args.set_file(file);
-      sendBase("beginFileDownload", args);
-    }
-
-    public java.lang.String recv_beginFileDownload() throws AuthorizationException, org.apache.storm.thrift.TException
-    {
-      beginFileDownload_result result = new beginFileDownload_result();
-      receiveBase(result, "beginFileDownload");
-      if (result.is_set_success()) {
-        return result.success;
-      }
-      if (result.aze != null) {
-        throw result.aze;
-      }
-      throw new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.MISSING_RESULT, "beginFileDownload failed: unknown result");
-    }
-
     public java.nio.ByteBuffer downloadChunk(java.lang.String id) throws AuthorizationException, org.apache.storm.thrift.TException
     {
       send_downloadChunk(id);
@@ -2700,38 +2670,6 @@ public class Nimbus {
       }
     }
 
-    public void beginFileDownload(java.lang.String file, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.thrift.TException {
-      checkReady();
-      beginFileDownload_call method_call = new beginFileDownload_call(file, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class beginFileDownload_call extends org.apache.storm.thrift.async.TAsyncMethodCall<java.lang.String> {
-      private java.lang.String file;
-      public beginFileDownload_call(java.lang.String file, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler, org.apache.storm.thrift.async.TAsyncClient client, org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.transport.TNonblockingTransport transport) throws org.apache.storm.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.file = file;
-      }
-
-      public void write_args(org.apache.storm.thrift.protocol.TProtocol prot) throws org.apache.storm.thrift.TException {
-        prot.writeMessageBegin(new org.apache.storm.thrift.protocol.TMessage("beginFileDownload", org.apache.storm.thrift.protocol.TMessageType.CALL, 0));
-        beginFileDownload_args args = new beginFileDownload_args();
-        args.set_file(file);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public java.lang.String getResult() throws AuthorizationException, org.apache.storm.thrift.TException {
-        if (getState() != org.apache.storm.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new java.lang.IllegalStateException("Method call not finished!");
-        }
-        org.apache.storm.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.storm.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.storm.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_beginFileDownload();
-      }
-    }
-
     public void downloadChunk(java.lang.String id, org.apache.storm.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer> resultHandler) throws org.apache.storm.thrift.TException {
       checkReady();
       downloadChunk_call method_call = new downloadChunk_call(id, resultHandler, this, ___protocolFactory, ___transport);
@@ -3430,7 +3368,6 @@ public class Nimbus {
       processMap.put("beginFileUpload", new beginFileUpload());
       processMap.put("uploadChunk", new uploadChunk());
       processMap.put("finishFileUpload", new finishFileUpload());
-      processMap.put("beginFileDownload", new beginFileDownload());
       processMap.put("downloadChunk", new downloadChunk());
       processMap.put("getNimbusConf", new getNimbusConf());
       processMap.put("getClusterInfo", new getClusterInfo());
@@ -4346,35 +4283,6 @@ public class Nimbus {
       }
     }
 
-    public static class beginFileDownload<I extends Iface> extends org.apache.storm.thrift.ProcessFunction<I, beginFileDownload_args> {
-      public beginFileDownload() {
-        super("beginFileDownload");
-      }
-
-      public beginFileDownload_args getEmptyArgsInstance() {
-        return new beginFileDownload_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      @Override
-      protected boolean handleRuntimeExceptions() {
-        return false;
-      }
-
-      public beginFileDownload_result getResult(I iface, beginFileDownload_args args) throws org.apache.storm.thrift.TException {
-        beginFileDownload_result result = new beginFileDownload_result();
-        try {
-          result.success = iface.beginFileDownload(args.file);
-        } catch (AuthorizationException aze) {
-          result.aze = aze;
-        }
-        return result;
-      }
-    }
-
     public static class downloadChunk<I extends Iface> extends org.apache.storm.thrift.ProcessFunction<I, downloadChunk_args> {
       public downloadChunk() {
         super("downloadChunk");
@@ -5014,7 +4922,6 @@ public class Nimbus {
       processMap.put("beginFileUpload", new beginFileUpload());
       processMap.put("uploadChunk", new uploadChunk());
       processMap.put("finishFileUpload", new finishFileUpload());
-      processMap.put("beginFileDownload", new beginFileDownload());
       processMap.put("downloadChunk", new downloadChunk());
       processMap.put("getNimbusConf", new getNimbusConf());
       processMap.put("getClusterInfo", new getClusterInfo());
@@ -7035,20 +6942,85 @@ public class Nimbus {
       }
     }
 
-    public static class beginFileDownload<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, beginFileDownload_args, java.lang.String> {
-      public beginFileDownload() {
-        super("beginFileDownload");
+    public static class downloadChunk<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, downloadChunk_args, java.nio.ByteBuffer> {
+      public downloadChunk() {
+        super("downloadChunk");
+      }
+
+      public downloadChunk_args getEmptyArgsInstance() {
+        return new downloadChunk_args();
+      }
+
+      public org.apache.storm.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+        final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
+        return new org.apache.storm.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer>() { 
+          public void onComplete(java.nio.ByteBuffer o) {
+            downloadChunk_result result = new downloadChunk_result();
+            result.success = o;
+            try {
+              fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
+            } catch (org.apache.storm.thrift.transport.TTransportException e) {
+              _LOGGER.error("TTransportException writing to internal frame buffer", e);
+              fb.close();
+            } catch (java.lang.Exception e) {
+              _LOGGER.error("Exception writing to internal frame buffer", e);
+              onError(e);
+            }
+          }
+          public void onError(java.lang.Exception e) {
+            byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
+            org.apache.storm.thrift.TSerializable msg;
+            downloadChunk_result result = new downloadChunk_result();
+            if (e instanceof AuthorizationException) {
+              result.aze = (AuthorizationException) e;
+              result.set_aze_isSet(true);
+              msg = result;
+            } else if (e instanceof org.apache.storm.thrift.transport.TTransportException) {
+              _LOGGER.error("TTransportException inside handler", e);
+              fb.close();
+              return;
+            } else if (e instanceof org.apache.storm.thrift.TApplicationException) {
+              _LOGGER.error("TApplicationException inside handler", e);
+              msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
+              msg = (org.apache.storm.thrift.TApplicationException)e;
+            } else {
+              _LOGGER.error("Exception inside handler", e);
+              msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
+              msg = new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+            }
+            try {
+              fcall.sendResponse(fb,msg,msgType,seqid);
+            } catch (java.lang.Exception ex) {
+              _LOGGER.error("Exception writing to internal frame buffer", ex);
+              fb.close();
+            }
+          }
+        };
+      }
+
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public void start(I iface, downloadChunk_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer> resultHandler) throws org.apache.storm.thrift.TException {
+        iface.downloadChunk(args.id,resultHandler);
+      }
+    }
+
+    public static class getNimbusConf<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getNimbusConf_args, java.lang.String> {
+      public getNimbusConf() {
+        super("getNimbusConf");
       }
 
-      public beginFileDownload_args getEmptyArgsInstance() {
-        return new beginFileDownload_args();
+      public getNimbusConf_args getEmptyArgsInstance() {
+        return new getNimbusConf_args();
       }
 
       public org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
         final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
         return new org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String>() { 
           public void onComplete(java.lang.String o) {
-            beginFileDownload_result result = new beginFileDownload_result();
+            getNimbusConf_result result = new getNimbusConf_result();
             result.success = o;
             try {
               fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7063,7 +7035,7 @@ public class Nimbus {
           public void onError(java.lang.Exception e) {
             byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
             org.apache.storm.thrift.TSerializable msg;
-            beginFileDownload_result result = new beginFileDownload_result();
+            getNimbusConf_result result = new getNimbusConf_result();
             if (e instanceof AuthorizationException) {
               result.aze = (AuthorizationException) e;
               result.set_aze_isSet(true);
@@ -7095,25 +7067,25 @@ public class Nimbus {
         return false;
       }
 
-      public void start(I iface, beginFileDownload_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.thrift.TException {
-        iface.beginFileDownload(args.file,resultHandler);
+      public void start(I iface, getNimbusConf_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.thrift.TException {
+        iface.getNimbusConf(resultHandler);
       }
     }
 
-    public static class downloadChunk<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, downloadChunk_args, java.nio.ByteBuffer> {
-      public downloadChunk() {
-        super("downloadChunk");
+    public static class getClusterInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getClusterInfo_args, ClusterSummary> {
+      public getClusterInfo() {
+        super("getClusterInfo");
       }
 
-      public downloadChunk_args getEmptyArgsInstance() {
-        return new downloadChunk_args();
+      public getClusterInfo_args getEmptyArgsInstance() {
+        return new getClusterInfo_args();
       }
 
-      public org.apache.storm.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+      public org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
         final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
-        return new org.apache.storm.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer>() { 
-          public void onComplete(java.nio.ByteBuffer o) {
-            downloadChunk_result result = new downloadChunk_result();
+        return new org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary>() { 
+          public void onComplete(ClusterSummary o) {
+            getClusterInfo_result result = new getClusterInfo_result();
             result.success = o;
             try {
               fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7128,7 +7100,7 @@ public class Nimbus {
           public void onError(java.lang.Exception e) {
             byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
             org.apache.storm.thrift.TSerializable msg;
-            downloadChunk_result result = new downloadChunk_result();
+            getClusterInfo_result result = new getClusterInfo_result();
             if (e instanceof AuthorizationException) {
               result.aze = (AuthorizationException) e;
               result.set_aze_isSet(true);
@@ -7160,25 +7132,25 @@ public class Nimbus {
         return false;
       }
 
-      public void start(I iface, downloadChunk_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.nio.ByteBuffer> resultHandler) throws org.apache.storm.thrift.TException {
-        iface.downloadChunk(args.id,resultHandler);
+      public void start(I iface, getClusterInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary> resultHandler) throws org.apache.storm.thrift.TException {
+        iface.getClusterInfo(resultHandler);
       }
     }
 
-    public static class getNimbusConf<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getNimbusConf_args, java.lang.String> {
-      public getNimbusConf() {
-        super("getNimbusConf");
+    public static class getLeader<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getLeader_args, NimbusSummary> {
+      public getLeader() {
+        super("getLeader");
       }
 
-      public getNimbusConf_args getEmptyArgsInstance() {
-        return new getNimbusConf_args();
+      public getLeader_args getEmptyArgsInstance() {
+        return new getLeader_args();
       }
 
-      public org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+      public org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
         final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
-        return new org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String>() { 
-          public void onComplete(java.lang.String o) {
-            getNimbusConf_result result = new getNimbusConf_result();
+        return new org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary>() { 
+          public void onComplete(NimbusSummary o) {
+            getLeader_result result = new getLeader_result();
             result.success = o;
             try {
               fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7193,7 +7165,7 @@ public class Nimbus {
           public void onError(java.lang.Exception e) {
             byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
             org.apache.storm.thrift.TSerializable msg;
-            getNimbusConf_result result = new getNimbusConf_result();
+            getLeader_result result = new getLeader_result();
             if (e instanceof AuthorizationException) {
               result.aze = (AuthorizationException) e;
               result.set_aze_isSet(true);
@@ -7225,26 +7197,27 @@ public class Nimbus {
         return false;
       }
 
-      public void start(I iface, getNimbusConf_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.thrift.TException {
-        iface.getNimbusConf(resultHandler);
+      public void start(I iface, getLeader_args args, org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler) throws org.apache.storm.thrift.TException {
+        iface.getLeader(resultHandler);
       }
     }
 
-    public static class getClusterInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getClusterInfo_args, ClusterSummary> {
-      public getClusterInfo() {
-        super("getClusterInfo");
+    public static class isTopologyNameAllowed<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, isTopologyNameAllowed_args, java.lang.Boolean> {
+      public isTopologyNameAllowed() {
+        super("isTopologyNameAllowed");
       }
 
-      public getClusterInfo_args getEmptyArgsInstance() {
-        return new getClusterInfo_args();
+      public isTopologyNameAllowed_args getEmptyArgsInstance() {
+        return new isTopologyNameAllowed_args();
       }
 
-      public org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+      public org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.Boolean> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
         final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
-        return new org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary>() { 
-          public void onComplete(ClusterSummary o) {
-            getClusterInfo_result result = new getClusterInfo_result();
+        return new org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.Boolean>() { 
+          public void onComplete(java.lang.Boolean o) {
+            isTopologyNameAllowed_result result = new isTopologyNameAllowed_result();
             result.success = o;
+            result.set_success_isSet(true);
             try {
               fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
             } catch (org.apache.storm.thrift.transport.TTransportException e) {
@@ -7258,7 +7231,7 @@ public class Nimbus {
           public void onError(java.lang.Exception e) {
             byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
             org.apache.storm.thrift.TSerializable msg;
-            getClusterInfo_result result = new getClusterInfo_result();
+            isTopologyNameAllowed_result result = new isTopologyNameAllowed_result();
             if (e instanceof AuthorizationException) {
               result.aze = (AuthorizationException) e;
               result.set_aze_isSet(true);
@@ -7290,25 +7263,25 @@ public class Nimbus {
         return false;
       }
 
-      public void start(I iface, getClusterInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary> resultHandler) throws org.apache.storm.thrift.TException {
-        iface.getClusterInfo(resultHandler);
+      public void start(I iface, isTopologyNameAllowed_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.Boolean> resultHandler) throws org.apache.storm.thrift.TException {
+        iface.isTopologyNameAllowed(args.name,resultHandler);
       }
     }
 
-    public static class getLeader<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getLeader_args, NimbusSummary> {
-      public getLeader() {
-        super("getLeader");
+    public static class getTopologyInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyInfo_args, TopologyInfo> {
+      public getTopologyInfo() {
+        super("getTopologyInfo");
       }
 
-      public getLeader_args getEmptyArgsInstance() {
-        return new getLeader_args();
+      public getTopologyInfo_args getEmptyArgsInstance() {
+        return new getTopologyInfo_args();
       }
 
-      public org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+      public org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
         final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
-        return new org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary>() { 
-          public void onComplete(NimbusSummary o) {
-            getLeader_result result = new getLeader_result();
+        return new org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo>() { 
+          public void onComplete(TopologyInfo o) {
+            getTopologyInfo_result result = new getTopologyInfo_result();
             result.success = o;
             try {
               fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7323,8 +7296,150 @@ public class Nimbus {
           public void onError(java.lang.Exception e) {
             byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
             org.apache.storm.thrift.TSerializable msg;
-            getLeader_result result = new getLeader_result();
-            if (e instanceof AuthorizationException) {
+            getTopologyInfo_result result = new getTopologyInfo_result();
+            if (e instanceof NotAliveException) {
+              result.e = (NotAliveException) e;
+              result.set_e_isSet(true);
+              msg = result;
+            } else if (e instanceof AuthorizationException) {
+              result.aze = (AuthorizationException) e;
+              result.set_aze_isSet(true);
+              msg = result;
+            } else if (e instanceof org.apache.storm.thrift.transport.TTransportException) {
+              _LOGGER.error("TTransportException inside handler", e);
+              fb.close();
+              return;
+            } else if (e instanceof org.apache.storm.thrift.TApplicationException) {
+              _LOGGER.error("TApplicationException inside handler", e);
+              msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
+              msg = (org.apache.storm.thrift.TApplicationException)e;
+            } else {
+              _LOGGER.error("Exception inside handler", e);
+              msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
+              msg = new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+            }
+            try {
+              fcall.sendResponse(fb,msg,msgType,seqid);
+            } catch (java.lang.Exception ex) {
+              _LOGGER.error("Exception writing to internal frame buffer", ex);
+              fb.close();
+            }
+          }
+        };
+      }
+
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public void start(I iface, getTopologyInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException {
+        iface.getTopologyInfo(args.id,resultHandler);
+      }
+    }
+
+    public static class getTopologyInfoWithOpts<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyInfoWithOpts_args, TopologyInfo> {
+      public getTopologyInfoWithOpts() {
+        super("getTopologyInfoWithOpts");
+      }
+
+      public getTopologyInfoWithOpts_args getEmptyArgsInstance() {
+        return new getTopologyInfoWithOpts_args();
+      }
+
+      public org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+        final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
+        return new org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo>() { 
+          public void onComplete(TopologyInfo o) {
+            getTopologyInfoWithOpts_result result = new getTopologyInfoWithOpts_result();
+            result.success = o;
+            try {
+              fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
+            } catch (org.apache.storm.thrift.transport.TTransportException e) {
+              _LOGGER.error("TTransportException writing to internal frame buffer", e);
+              fb.close();
+            } catch (java.lang.Exception e) {
+              _LOGGER.error("Exception writing to internal frame buffer", e);
+              onError(e);
+            }
+          }
+          public void onError(java.lang.Exception e) {
+            byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
+            org.apache.storm.thrift.TSerializable msg;
+            getTopologyInfoWithOpts_result result = new getTopologyInfoWithOpts_result();
+            if (e instanceof NotAliveException) {
+              result.e = (NotAliveException) e;
+              result.set_e_isSet(true);
+              msg = result;
+            } else if (e instanceof AuthorizationException) {
+              result.aze = (AuthorizationException) e;
+              result.set_aze_isSet(true);
+              msg = result;
+            } else if (e instanceof org.apache.storm.thrift.transport.TTransportException) {
+              _LOGGER.error("TTransportException inside handler", e);
+              fb.close();
+              return;
+            } else if (e instanceof org.apache.storm.thrift.TApplicationException) {
+              _LOGGER.error("TApplicationException inside handler", e);
+              msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
+              msg = (org.apache.storm.thrift.TApplicationException)e;
+            } else {
+              _LOGGER.error("Exception inside handler", e);
+              msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
+              msg = new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
+            }
+            try {
+              fcall.sendResponse(fb,msg,msgType,seqid);
+            } catch (java.lang.Exception ex) {
+              _LOGGER.error("Exception writing to internal frame buffer", ex);
+              fb.close();
+            }
+          }
+        };
+      }
+
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public void start(I iface, getTopologyInfoWithOpts_args args, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException {
+        iface.getTopologyInfoWithOpts(args.id, args.options,resultHandler);
+      }
+    }
+
+    public static class getTopologyPageInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyPageInfo_args, TopologyPageInfo> {
+      public getTopologyPageInfo() {
+        super("getTopologyPageInfo");
+      }
+
+      public getTopologyPageInfo_args getEmptyArgsInstance() {
+        return new getTopologyPageInfo_args();
+      }
+
+      public org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+        final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
+        return new org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo>() { 
+          public void onComplete(TopologyPageInfo o) {
+            getTopologyPageInfo_result result = new getTopologyPageInfo_result();
+            result.success = o;
+            try {
+              fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
+            } catch (org.apache.storm.thrift.transport.TTransportException e) {
+              _LOGGER.error("TTransportException writing to internal frame buffer", e);
+              fb.close();
+            } catch (java.lang.Exception e) {
+              _LOGGER.error("Exception writing to internal frame buffer", e);
+              onError(e);
+            }
+          }
+          public void onError(java.lang.Exception e) {
+            byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
+            org.apache.storm.thrift.TSerializable msg;
+            getTopologyPageInfo_result result = new getTopologyPageInfo_result();
+            if (e instanceof NotAliveException) {
+              result.e = (NotAliveException) e;
+              result.set_e_isSet(true);
+              msg = result;
+            } else if (e instanceof AuthorizationException) {
               result.aze = (AuthorizationException) e;
               result.set_aze_isSet(true);
               msg = result;
@@ -7355,27 +7470,26 @@ public class Nimbus {
         return false;
       }
 
-      public void start(I iface, getLeader_args args, org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler) throws org.apache.storm.thrift.TException {
-        iface.getLeader(resultHandler);
+      public void start(I iface, getTopologyPageInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> resultHandler) throws org.apache.storm.thrift.TException {
+        iface.getTopologyPageInfo(args.id, args.window, args.is_include_sys,resultHandler);
       }
     }
 
-    public static class isTopologyNameAllowed<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, isTopologyNameAllowed_args, java.lang.Boolean> {
-      public isTopologyNameAllowed() {
-        super("isTopologyNameAllowed");
+    public static class getSupervisorPageInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getSupervisorPageInfo_args, SupervisorPageInfo> {
+      public getSupervisorPageInfo() {
+        super("getSupervisorPageInfo");
       }
 
-      public isTopologyNameAllowed_args getEmptyArgsInstance() {
-        return new isTopologyNameAllowed_args();
+      public getSupervisorPageInfo_args getEmptyArgsInstance() {
+        return new getSupervisorPageInfo_args();
       }
 
-      public org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.Boolean> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+      public org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
         final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
-        return new org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.Boolean>() { 
-          public void onComplete(java.lang.Boolean o) {
-            isTopologyNameAllowed_result result = new isTopologyNameAllowed_result();
+        return new org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo>() { 
+          public void onComplete(SupervisorPageInfo o) {
+            getSupervisorPageInfo_result result = new getSupervisorPageInfo_result();
             result.success = o;
-            result.set_success_isSet(true);
             try {
               fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
             } catch (org.apache.storm.thrift.transport.TTransportException e) {
@@ -7389,8 +7503,12 @@ public class Nimbus {
           public void onError(java.lang.Exception e) {
             byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
             org.apache.storm.thrift.TSerializable msg;
-            isTopologyNameAllowed_result result = new isTopologyNameAllowed_result();
-            if (e instanceof AuthorizationException) {
+            getSupervisorPageInfo_result result = new getSupervisorPageInfo_result();
+            if (e instanceof NotAliveException) {
+              result.e = (NotAliveException) e;
+              result.set_e_isSet(true);
+              msg = result;
+            } else if (e instanceof AuthorizationException) {
               result.aze = (AuthorizationException) e;
               result.set_aze_isSet(true);
               msg = result;
@@ -7421,25 +7539,25 @@ public class Nimbus {
         return false;
       }
 
-      public void start(I iface, isTopologyNameAllowed_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.Boolean> resultHandler) throws org.apache.storm.thrift.TException {
-        iface.isTopologyNameAllowed(args.name,resultHandler);
+      public void start(I iface, getSupervisorPageInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo> resultHandler) throws org.apache.storm.thrift.TException {
+        iface.getSupervisorPageInfo(args.id, args.host, args.is_include_sys,resultHandler);
       }
     }
 
-    public static class getTopologyInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyInfo_args, TopologyInfo> {
-      public getTopologyInfo() {
-        super("getTopologyInfo");
+    public static class getComponentPageInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getComponentPageInfo_args, ComponentPageInfo> {
+      public getComponentPageInfo() {
+        super("getComponentPageInfo");
       }
 
-      public getTopologyInfo_args getEmptyArgsInstance() {
-        return new getTopologyInfo_args();
+      public getComponentPageInfo_args getEmptyArgsInstance() {
+        return new getComponentPageInfo_args();
       }
 
-      public org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+      public org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
         final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
-        return new org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo>() { 
-          public void onComplete(TopologyInfo o) {
-            getTopologyInfo_result result = new getTopologyInfo_result();
+        return new org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo>() { 
+          public void onComplete(ComponentPageInfo o) {
+            getComponentPageInfo_result result = new getComponentPageInfo_result();
             result.success = o;
             try {
               fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7454,7 +7572,7 @@ public class Nimbus {
           public void onError(java.lang.Exception e) {
             byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
             org.apache.storm.thrift.TSerializable msg;
-            getTopologyInfo_result result = new getTopologyInfo_result();
+            getComponentPageInfo_result result = new getComponentPageInfo_result();
             if (e instanceof NotAliveException) {
               result.e = (NotAliveException) e;
               result.set_e_isSet(true);
@@ -7490,25 +7608,25 @@ public class Nimbus {
         return false;
       }
 
-      public void start(I iface, getTopologyInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException {
-        iface.getTopologyInfo(args.id,resultHandler);
+      public void start(I iface, getComponentPageInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> resultHandler) throws org.apache.storm.thrift.TException {
+        iface.getComponentPageInfo(args.topology_id, args.component_id, args.window, args.is_include_sys,resultHandler);
       }
     }
 
-    public static class getTopologyInfoWithOpts<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyInfoWithOpts_args, TopologyInfo> {
-      public getTopologyInfoWithOpts() {
-        super("getTopologyInfoWithOpts");
+    public static class getTopologyConf<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyConf_args, java.lang.String> {
+      public getTopologyConf() {
+        super("getTopologyConf");
       }
 
-      public getTopologyInfoWithOpts_args getEmptyArgsInstance() {
-        return new getTopologyInfoWithOpts_args();
+      public getTopologyConf_args getEmptyArgsInstance() {
+        return new getTopologyConf_args();
       }
 
-      public org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+      public org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
         final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
-        return new org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo>() { 
-          public void onComplete(TopologyInfo o) {
-            getTopologyInfoWithOpts_result result = new getTopologyInfoWithOpts_result();
+        return new org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String>() { 
+          public void onComplete(java.lang.String o) {
+            getTopologyConf_result result = new getTopologyConf_result();
             result.success = o;
             try {
               fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7523,7 +7641,7 @@ public class Nimbus {
           public void onError(java.lang.Exception e) {
             byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
             org.apache.storm.thrift.TSerializable msg;
-            getTopologyInfoWithOpts_result result = new getTopologyInfoWithOpts_result();
+            getTopologyConf_result result = new getTopologyConf_result();
             if (e instanceof NotAliveException) {
               result.e = (NotAliveException) e;
               result.set_e_isSet(true);
@@ -7559,25 +7677,25 @@ public class Nimbus {
         return false;
       }
 
-      public void start(I iface, getTopologyInfoWithOpts_args args, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException {
-        iface.getTopologyInfoWithOpts(args.id, args.options,resultHandler);
+      public void start(I iface, getTopologyConf_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.thrift.TException {
+        iface.getTopologyConf(args.id,resultHandler);
       }
     }
 
-    public static class getTopologyPageInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyPageInfo_args, TopologyPageInfo> {
-      public getTopologyPageInfo() {
-        super("getTopologyPageInfo");
+    public static class getTopology<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopology_args, StormTopology> {
+      public getTopology() {
+        super("getTopology");
       }
 
-      public getTopologyPageInfo_args getEmptyArgsInstance() {
-        return new getTopologyPageInfo_args();
+      public getTopology_args getEmptyArgsInstance() {
+        return new getTopology_args();
       }
 
-      public org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+      public org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
         final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
-        return new org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo>() { 
-          public void onComplete(TopologyPageInfo o) {
-            getTopologyPageInfo_result result = new getTopologyPageInfo_result();
+        return new org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology>() { 
+          public void onComplete(StormTopology o) {
+            getTopology_result result = new getTopology_result();
             result.success = o;
             try {
               fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7592,7 +7710,7 @@ public class Nimbus {
           public void onError(java.lang.Exception e) {
             byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
             org.apache.storm.thrift.TSerializable msg;
-            getTopologyPageInfo_result result = new getTopologyPageInfo_result();
+            getTopology_result result = new getTopology_result();
             if (e instanceof NotAliveException) {
               result.e = (NotAliveException) e;
               result.set_e_isSet(true);
@@ -7628,25 +7746,25 @@ public class Nimbus {
         return false;
       }
 
-      public void start(I iface, getTopologyPageInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> resultHandler) throws org.apache.storm.thrift.TException {
-        iface.getTopologyPageInfo(args.id, args.window, args.is_include_sys,resultHandler);
+      public void start(I iface, getTopology_args args, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.storm.thrift.TException {
+        iface.getTopology(args.id,resultHandler);
       }
     }
 
-    public static class getSupervisorPageInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getSupervisorPageInfo_args, SupervisorPageInfo> {
-      public getSupervisorPageInfo() {
-        super("getSupervisorPageInfo");
+    public static class getUserTopology<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getUserTopology_args, StormTopology> {
+      public getUserTopology() {
+        super("getUserTopology");
       }
 
-      public getSupervisorPageInfo_args getEmptyArgsInstance() {
-        return new getSupervisorPageInfo_args();
+      public getUserTopology_args getEmptyArgsInstance() {
+        return new getUserTopology_args();
       }
 
-      public org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+      public org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
         final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
-        return new org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo>() { 
-          public void onComplete(SupervisorPageInfo o) {
-            getSupervisorPageInfo_result result = new getSupervisorPageInfo_result();
+        return new org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology>() { 
+          public void onComplete(StormTopology o) {
+            getUserTopology_result result = new getUserTopology_result();
             result.success = o;
             try {
               fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7661,7 +7779,7 @@ public class Nimbus {
           public void onError(java.lang.Exception e) {
             byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
             org.apache.storm.thrift.TSerializable msg;
-            getSupervisorPageInfo_result result = new getSupervisorPageInfo_result();
+            getUserTopology_result result = new getUserTopology_result();
             if (e instanceof NotAliveException) {
               result.e = (NotAliveException) e;
               result.set_e_isSet(true);
@@ -7697,25 +7815,25 @@ public class Nimbus {
         return false;
       }
 
-      public void start(I iface, getSupervisorPageInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo> resultHandler) throws org.apache.storm.thrift.TException {
-        iface.getSupervisorPageInfo(args.id, args.host, args.is_include_sys,resultHandler);
+      public void start(I iface, getUserTopology_args args, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.storm.thrift.TException {
+        iface.getUserTopology(args.id,resultHandler);
       }
     }
 
-    public static class getComponentPageInfo<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getComponentPageInfo_args, ComponentPageInfo> {
-      public getComponentPageInfo() {
-        super("getComponentPageInfo");
+    public static class getTopologyHistory<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyHistory_args, TopologyHistoryInfo> {
+      public getTopologyHistory() {
+        super("getTopologyHistory");
       }
 
-      public getComponentPageInfo_args getEmptyArgsInstance() {
-        return new getComponentPageInfo_args();
+      public getTopologyHistory_args getEmptyArgsInstance() {
+        return new getTopologyHistory_args();
       }
 
-      public org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+      public org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
         final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
-        return new org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo>() { 
-          public void onComplete(ComponentPageInfo o) {
-            getComponentPageInfo_result result = new getComponentPageInfo_result();
+        return new org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo>() { 
+          public void onComplete(TopologyHistoryInfo o) {
+            getTopologyHistory_result result = new getTopologyHistory_result();
             result.success = o;
             try {
               fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7730,12 +7848,8 @@ public class Nimbus {
           public void onError(java.lang.Exception e) {
             byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
             org.apache.storm.thrift.TSerializable msg;
-            getComponentPageInfo_result result = new getComponentPageInfo_result();
-            if (e instanceof NotAliveException) {
-              result.e = (NotAliveException) e;
-              result.set_e_isSet(true);
-              msg = result;
-            } else if (e instanceof AuthorizationException) {
+            getTopologyHistory_result result = new getTopologyHistory_result();
+            if (e instanceof AuthorizationException) {
               result.aze = (AuthorizationException) e;
               result.set_aze_isSet(true);
               msg = result;
@@ -7766,25 +7880,25 @@ public class Nimbus {
         return false;
       }
 
-      public void start(I iface, getComponentPageInfo_args args, org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> resultHandler) throws org.apache.storm.thrift.TException {
-        iface.getComponentPageInfo(args.topology_id, args.component_id, args.window, args.is_include_sys,resultHandler);
+      public void start(I iface, getTopologyHistory_args args, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler) throws org.apache.storm.thrift.TException {
+        iface.getTopologyHistory(args.user,resultHandler);
       }
     }
 
-    public static class getTopologyConf<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyConf_args, java.lang.String> {
-      public getTopologyConf() {
-        super("getTopologyConf");
+    public static class getOwnerResourceSummaries<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getOwnerResourceSummaries_args, java.util.List<OwnerResourceSummary>> {
+      public getOwnerResourceSummaries() {
+        super("getOwnerResourceSummaries");
       }
 
-      public getTopologyConf_args getEmptyArgsInstance() {
-        return new getTopologyConf_args();
+      public getOwnerResourceSummaries_args getEmptyArgsInstance() {
+        return new getOwnerResourceSummaries_args();
       }
 
-      public org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+      public org.apache.storm.thrift.async.AsyncMethodCallback<java.util.List<OwnerResourceSummary>> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
         final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
-        return new org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String>() { 
-          public void onComplete(java.lang.String o) {
-            getTopologyConf_result result = new getTopologyConf_result();
+        return new org.apache.storm.thrift.async.AsyncMethodCallback<java.util.List<OwnerResourceSummary>>() { 
+          public void onComplete(java.util.List<OwnerResourceSummary> o) {
+            getOwnerResourceSummaries_result result = new getOwnerResourceSummaries_result();
             result.success = o;
             try {
               fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7799,12 +7913,8 @@ public class Nimbus {
           public void onError(java.lang.Exception e) {
             byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
             org.apache.storm.thrift.TSerializable msg;
-            getTopologyConf_result result = new getTopologyConf_result();
-            if (e instanceof NotAliveException) {
-              result.e = (NotAliveException) e;
-              result.set_e_isSet(true);
-              msg = result;
-            } else if (e instanceof AuthorizationException) {
+            getOwnerResourceSummaries_result result = new getOwnerResourceSummaries_result();
+            if (e instanceof AuthorizationException) {
               result.aze = (AuthorizationException) e;
               result.set_aze_isSet(true);
               msg = result;
@@ -7835,25 +7945,25 @@ public class Nimbus {
         return false;
       }
 
-      public void start(I iface, getTopologyConf_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.lang.String> resultHandler) throws org.apache.storm.thrift.TException {
-        iface.getTopologyConf(args.id,resultHandler);
+      public void start(I iface, getOwnerResourceSummaries_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.util.List<OwnerResourceSummary>> resultHandler) throws org.apache.storm.thrift.TException {
+        iface.getOwnerResourceSummaries(args.owner,resultHandler);
       }
     }
 
-    public static class getTopology<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopology_args, StormTopology> {
-      public getTopology() {
-        super("getTopology");
+    public static class getSupervisorAssignments<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getSupervisorAssignments_args, SupervisorAssignments> {
+      public getSupervisorAssignments() {
+        super("getSupervisorAssignments");
       }
 
-      public getTopology_args getEmptyArgsInstance() {
-        return new getTopology_args();
+      public getSupervisorAssignments_args getEmptyArgsInstance() {
+        return new getSupervisorAssignments_args();
       }
 
-      public org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+      public org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
         final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
-        return new org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology>() { 
-          public void onComplete(StormTopology o) {
-            getTopology_result result = new getTopology_result();
+        return new org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments>() { 
+          public void onComplete(SupervisorAssignments o) {
+            getSupervisorAssignments_result result = new getSupervisorAssignments_result();
             result.success = o;
             try {
               fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
@@ -7868,12 +7978,8 @@ public class Nimbus {
           public void onError(java.lang.Exception e) {
             byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
             org.apache.storm.thrift.TSerializable msg;
-            getTopology_result result = new getTopology_result();
-            if (e instanceof NotAliveException) {
-              result.e = (NotAliveException) e;
-              result.set_e_isSet(true);
-              msg = result;
-            } else if (e instanceof AuthorizationException) {
+            getSupervisorAssignments_result result = new getSupervisorAssignments_result();
+            if (e instanceof AuthorizationException) {
               result.aze = (AuthorizationException) e;
               result.set_aze_isSet(true);
               msg = result;
@@ -7904,26 +8010,25 @@ public class Nimbus {
         return false;
       }
 
-      public void start(I iface, getTopology_args args, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.storm.thrift.TException {
-        iface.getTopology(args.id,resultHandler);
+      public void start(I iface, getSupervisorAssignments_args args, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler) throws org.apache.storm.thrift.TException {
+        iface.getSupervisorAssignments(args.node,resultHandler);
       }
     }
 
-    public static class getUserTopology<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getUserTopology_args, StormTopology> {
-      public getUserTopology() {
-        super("getUserTopology");
+    public static class sendSupervisorWorkerHeartbeats<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, sendSupervisorWorkerHeartbeats_args, Void> {
+      public sendSupervisorWorkerHeartbeats() {
+        super("sendSupervisorWorkerHeartbeats");
       }
 
-      public getUserTopology_args getEmptyArgsInstance() {
-        return new getUserTopology_args();
+      public sendSupervisorWorkerHeartbeats_args getEmptyArgsInstance() {
+        return new sendSupervisorWorkerHeartbeats_args();
       }
 
-      public org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+      public org.apache.storm.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
         final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
-        return new org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology>() { 
-          public void onComplete(StormTopology o) {
-            getUserTopology_result result = new getUserTopology_result();
-            result.success = o;
+        return new org.apache.storm.thrift.async.AsyncMethodCallback<Void>() { 
+          public void onComplete(Void o) {
+            sendSupervisorWorkerHeartbeats_result result = new sendSupervisorWorkerHeartbeats_result();
             try {
               fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
             } catch (org.apache.storm.thrift.transport.TTransportException e) {
@@ -7937,12 +8042,8 @@ public class Nimbus {
           public void onError(java.lang.Exception e) {
             byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
             org.apache.storm.thrift.TSerializable msg;
-            getUserTopology_result result = new getUserTopology_result();
-            if (e instanceof NotAliveException) {
-              result.e = (NotAliveException) e;
-              result.set_e_isSet(true);
-              msg = result;
-            } else if (e instanceof AuthorizationException) {
+            sendSupervisorWorkerHeartbeats_result result = new sendSupervisorWorkerHeartbeats_result();
+            if (e instanceof AuthorizationException) {
               result.aze = (AuthorizationException) e;
               result.set_aze_isSet(true);
               msg = result;
@@ -7973,26 +8074,25 @@ public class Nimbus {
         return false;
       }
 
-      public void start(I iface, getUserTopology_args args, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.storm.thrift.TException {
-        iface.getUserTopology(args.id,resultHandler);
+      public void start(I iface, sendSupervisorWorkerHeartbeats_args args, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException {
+        iface.sendSupervisorWorkerHeartbeats(args.heartbeats,resultHandler);
       }
     }
 
-    public static class getTopologyHistory<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getTopologyHistory_args, TopologyHistoryInfo> {
-      public getTopologyHistory() {
-        super("getTopologyHistory");
+    public static class sendSupervisorWorkerHeartbeat<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, sendSupervisorWorkerHeartbeat_args, Void> {
+      public sendSupervisorWorkerHeartbeat() {
+        super("sendSupervisorWorkerHeartbeat");
       }
 
-      public getTopologyHistory_args getEmptyArgsInstance() {
-        return new getTopologyHistory_args();
+      public sendSupervisorWorkerHeartbeat_args getEmptyArgsInstance() {
+        return new sendSupervisorWorkerHeartbeat_args();
       }
 
-      public org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
+      public org.apache.storm.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
         final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
-        return new org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo>() { 
-          public void onComplete(TopologyHistoryInfo o) {
-            getTopologyHistory_result result = new getTopologyHistory_result();
-            result.success = o;
+        return new org.apache.storm.thrift.async.AsyncMethodCallback<Void>() { 
+          public void onComplete(Void o) {
+            sendSupervisorWorkerHeartbeat_result result = new sendSupervisorWorkerHeartbeat_result();
             try {
               fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
             } catch (org.apache.storm.thrift.transport.TTransportException e) {
@@ -8006,272 +8106,14 @@ public class Nimbus {
           public void onError(java.lang.Exception e) {
             byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
             org.apache.storm.thrift.TSerializable msg;
-            getTopologyHistory_result result = new getTopologyHistory_result();
+            sendSupervisorWorkerHeartbeat_result result = new sendSupervisorWorkerHeartbeat_result();
             if (e instanceof AuthorizationException) {
               result.aze = (AuthorizationException) e;
               result.set_aze_isSet(true);
-              msg = result;
-            } else if (e instanceof org.apache.storm.thrift.transport.TTransportException) {
-              _LOGGER.error("TTransportException inside handler", e);
-              fb.close();
-              return;
-            } else if (e instanceof org.apache.storm.thrift.TApplicationException) {
-              _LOGGER.error("TApplicationException inside handler", e);
-              msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
-              msg = (org.apache.storm.thrift.TApplicationException)e;
-            } else {
-              _LOGGER.error("Exception inside handler", e);
-              msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
-              msg = new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
-            }
-            try {
-              fcall.sendResponse(fb,msg,msgType,seqid);
-            } catch (java.lang.Exception ex) {
-              _LOGGER.error("Exception writing to internal frame buffer", ex);
-              fb.close();
-            }
-          }
-        };
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public void start(I iface, getTopologyHistory_args args, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler) throws org.apache.storm.thrift.TException {
-        iface.getTopologyHistory(args.user,resultHandler);
-      }
-    }
-
-    public static class getOwnerResourceSummaries<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getOwnerResourceSummaries_args, java.util.List<OwnerResourceSummary>> {
-      public getOwnerResourceSummaries() {
-        super("getOwnerResourceSummaries");
-      }
-
-      public getOwnerResourceSummaries_args getEmptyArgsInstance() {
-        return new getOwnerResourceSummaries_args();
-      }
-
-      public org.apache.storm.thrift.async.AsyncMethodCallback<java.util.List<OwnerResourceSummary>> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
-        final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
-        return new org.apache.storm.thrift.async.AsyncMethodCallback<java.util.List<OwnerResourceSummary>>() { 
-          public void onComplete(java.util.List<OwnerResourceSummary> o) {
-            getOwnerResourceSummaries_result result = new getOwnerResourceSummaries_result();
-            result.success = o;
-            try {
-              fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
-            } catch (org.apache.storm.thrift.transport.TTransportException e) {
-              _LOGGER.error("TTransportException writing to internal frame buffer", e);
-              fb.close();
-            } catch (java.lang.Exception e) {
-              _LOGGER.error("Exception writing to internal frame buffer", e);
-              onError(e);
-            }
-          }
-          public void onError(java.lang.Exception e) {
-            byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
-            org.apache.storm.thrift.TSerializable msg;
-            getOwnerResourceSummaries_result result = new getOwnerResourceSummaries_result();
-            if (e instanceof AuthorizationException) {
-              result.aze = (AuthorizationException) e;
-              result.set_aze_isSet(true);
-              msg = result;
-            } else if (e instanceof org.apache.storm.thrift.transport.TTransportException) {
-              _LOGGER.error("TTransportException inside handler", e);
-              fb.close();
-              return;
-            } else if (e instanceof org.apache.storm.thrift.TApplicationException) {
-              _LOGGER.error("TApplicationException inside handler", e);
-              msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
-              msg = (org.apache.storm.thrift.TApplicationException)e;
-            } else {
-              _LOGGER.error("Exception inside handler", e);
-              msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
-              msg = new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
-            }
-            try {
-              fcall.sendResponse(fb,msg,msgType,seqid);
-            } catch (java.lang.Exception ex) {
-              _LOGGER.error("Exception writing to internal frame buffer", ex);
-              fb.close();
-            }
-          }
-        };
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public void start(I iface, getOwnerResourceSummaries_args args, org.apache.storm.thrift.async.AsyncMethodCallback<java.util.List<OwnerResourceSummary>> resultHandler) throws org.apache.storm.thrift.TException {
-        iface.getOwnerResourceSummaries(args.owner,resultHandler);
-      }
-    }
-
-    public static class getSupervisorAssignments<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, getSupervisorAssignments_args, SupervisorAssignments> {
-      public getSupervisorAssignments() {
-        super("getSupervisorAssignments");
-      }
-
-      public getSupervisorAssignments_args getEmptyArgsInstance() {
-        return new getSupervisorAssignments_args();
-      }
-
-      public org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
-        final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
-        return new org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments>() { 
-          public void onComplete(SupervisorAssignments o) {
-            getSupervisorAssignments_result result = new getSupervisorAssignments_result();
-            result.success = o;
-            try {
-              fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
-            } catch (org.apache.storm.thrift.transport.TTransportException e) {
-              _LOGGER.error("TTransportException writing to internal frame buffer", e);
-              fb.close();
-            } catch (java.lang.Exception e) {
-              _LOGGER.error("Exception writing to internal frame buffer", e);
-              onError(e);
-            }
-          }
-          public void onError(java.lang.Exception e) {
-            byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
-            org.apache.storm.thrift.TSerializable msg;
-            getSupervisorAssignments_result result = new getSupervisorAssignments_result();
-            if (e instanceof AuthorizationException) {
-              result.aze = (AuthorizationException) e;
-              result.set_aze_isSet(true);
-              msg = result;
-            } else if (e instanceof org.apache.storm.thrift.transport.TTransportException) {
-              _LOGGER.error("TTransportException inside handler", e);
-              fb.close();
-              return;
-            } else if (e instanceof org.apache.storm.thrift.TApplicationException) {
-              _LOGGER.error("TApplicationException inside handler", e);
-              msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
-              msg = (org.apache.storm.thrift.TApplicationException)e;
-            } else {
-              _LOGGER.error("Exception inside handler", e);
-              msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
-              msg = new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
-            }
-            try {
-              fcall.sendResponse(fb,msg,msgType,seqid);
-            } catch (java.lang.Exception ex) {
-              _LOGGER.error("Exception writing to internal frame buffer", ex);
-              fb.close();
-            }
-          }
-        };
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public void start(I iface, getSupervisorAssignments_args args, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler) throws org.apache.storm.thrift.TException {
-        iface.getSupervisorAssignments(args.node,resultHandler);
-      }
-    }
-
-    public static class sendSupervisorWorkerHeartbeats<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, sendSupervisorWorkerHeartbeats_args, Void> {
-      public sendSupervisorWorkerHeartbeats() {
-        super("sendSupervisorWorkerHeartbeats");
-      }
-
-      public sendSupervisorWorkerHeartbeats_args getEmptyArgsInstance() {
-        return new sendSupervisorWorkerHeartbeats_args();
-      }
-
-      public org.apache.storm.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
-        final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
-        return new org.apache.storm.thrift.async.AsyncMethodCallback<Void>() { 
-          public void onComplete(Void o) {
-            sendSupervisorWorkerHeartbeats_result result = new sendSupervisorWorkerHeartbeats_result();
-            try {
-              fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
-            } catch (org.apache.storm.thrift.transport.TTransportException e) {
-              _LOGGER.error("TTransportException writing to internal frame buffer", e);
-              fb.close();
-            } catch (java.lang.Exception e) {
-              _LOGGER.error("Exception writing to internal frame buffer", e);
-              onError(e);
-            }
-          }
-          public void onError(java.lang.Exception e) {
-            byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
-            org.apache.storm.thrift.TSerializable msg;
-            sendSupervisorWorkerHeartbeats_result result = new sendSupervisorWorkerHeartbeats_result();
-            if (e instanceof AuthorizationException) {
-              result.aze = (AuthorizationException) e;
-              result.set_aze_isSet(true);
-              msg = result;
-            } else if (e instanceof org.apache.storm.thrift.transport.TTransportException) {
-              _LOGGER.error("TTransportException inside handler", e);
-              fb.close();
-              return;
-            } else if (e instanceof org.apache.storm.thrift.TApplicationException) {
-              _LOGGER.error("TApplicationException inside handler", e);
-              msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
-              msg = (org.apache.storm.thrift.TApplicationException)e;
-            } else {
-              _LOGGER.error("Exception inside handler", e);
-              msgType = org.apache.storm.thrift.protocol.TMessageType.EXCEPTION;
-              msg = new org.apache.storm.thrift.TApplicationException(org.apache.storm.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage());
-            }
-            try {
-              fcall.sendResponse(fb,msg,msgType,seqid);
-            } catch (java.lang.Exception ex) {
-              _LOGGER.error("Exception writing to internal frame buffer", ex);
-              fb.close();
-            }
-          }
-        };
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public void start(I iface, sendSupervisorWorkerHeartbeats_args args, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException {
-        iface.sendSupervisorWorkerHeartbeats(args.heartbeats,resultHandler);
-      }
-    }
-
-    public static class sendSupervisorWorkerHeartbeat<I extends AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I, sendSupervisorWorkerHeartbeat_args, Void> {
-      public sendSupervisorWorkerHeartbeat() {
-        super("sendSupervisorWorkerHeartbeat");
-      }
-
-      public sendSupervisorWorkerHeartbeat_args getEmptyArgsInstance() {
-        return new sendSupervisorWorkerHeartbeat_args();
-      }
-
-      public org.apache.storm.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
-        final org.apache.storm.thrift.AsyncProcessFunction fcall = this;
-        return new org.apache.storm.thrift.async.AsyncMethodCallback<Void>() { 
-          public void onComplete(Void o) {
-            sendSupervisorWorkerHeartbeat_result result = new sendSupervisorWorkerHeartbeat_result();
-            try {
-              fcall.sendResponse(fb, result, org.apache.storm.thrift.protocol.TMessageType.REPLY,seqid);
-            } catch (org.apache.storm.thrift.transport.TTransportException e) {
-              _LOGGER.error("TTransportException writing to internal frame buffer", e);
-              fb.close();
-            } catch (java.lang.Exception e) {
-              _LOGGER.error("Exception writing to internal frame buffer", e);
-              onError(e);
-            }
-          }
-          public void onError(java.lang.Exception e) {
-            byte msgType = org.apache.storm.thrift.protocol.TMessageType.REPLY;
-            org.apache.storm.thrift.TSerializable msg;
-            sendSupervisorWorkerHeartbeat_result result = new sendSupervisorWorkerHeartbeat_result();
-            if (e instanceof AuthorizationException) {
-              result.aze = (AuthorizationException) e;
-              result.set_aze_isSet(true);
-              msg = result;
-            } else if (e instanceof NotAliveException) {
-              result.e = (NotAliveException) e;
-              result.set_e_isSet(true);
+              msg = result;
+            } else if (e instanceof NotAliveException) {
+              result.e = (NotAliveException) e;
+              result.set_e_isSet(true);
               msg = result;
             } else if (e instanceof org.apache.storm.thrift.transport.TTransportException) {
               _LOGGER.error("TTransportException inside handler", e);
@@ -33279,909 +33121,14 @@ public class Nimbus {
 
     public void setFieldValue(_Fields field, java.lang.Object value) {
       switch (field) {
-      case SUCCESS:
-        if (value == null) {
-          unset_success();
-        } else {
-          set_success((java.lang.String)value);
-        }
-        break;
-
-      case AZE:
-        if (value == null) {
-          unset_aze();
-        } else {
-          set_aze((AuthorizationException)value);
-        }
-        break;
-
-      }
-    }
-
-    public java.lang.Object getFieldValue(_Fields field) {
-      switch (field) {
-      case SUCCESS:
-        return get_success();
-
-      case AZE:
-        return get_aze();
-
-      }
-      throw new java.lang.IllegalStateException();
-    }
-
-    /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
-    public boolean isSet(_Fields field) {
-      if (field == null) {
-        throw new java.lang.IllegalArgumentException();
-      }
-
-      switch (field) {
-      case SUCCESS:
-        return is_set_success();
-      case AZE:
-        return is_set_aze();
-      }
-      throw new java.lang.IllegalStateException();
-    }
-
-    @Override
-    public boolean equals(java.lang.Object that) {
-      if (that == null)
-        return false;
-      if (that instanceof beginFileUpload_result)
-        return this.equals((beginFileUpload_result)that);
-      return false;
-    }
-
-    public boolean equals(beginFileUpload_result that) {
-      if (that == null)
-        return false;
-      if (this == that)
-        return true;
-
-      boolean this_present_success = true && this.is_set_success();
-      boolean that_present_success = true && that.is_set_success();
-      if (this_present_success || that_present_success) {
-        if (!(this_present_success && that_present_success))
-          return false;
-        if (!this.success.equals(that.success))
-          return false;
-      }
-
-      boolean this_present_aze = true && this.is_set_aze();
-      boolean that_present_aze = true && that.is_set_aze();
-      if (this_present_aze || that_present_aze) {
-        if (!(this_present_aze && that_present_aze))
-          return false;
-        if (!this.aze.equals(that.aze))
-          return false;
-      }
-
-      return true;
-    }
-
-    @Override
-    public int hashCode() {
-      int hashCode = 1;
-
-      hashCode = hashCode * 8191 + ((is_set_success()) ? 131071 : 524287);
-      if (is_set_success())
-        hashCode = hashCode * 8191 + success.hashCode();
-
-      hashCode = hashCode * 8191 + ((is_set_aze()) ? 131071 : 524287);
-      if (is_set_aze())
-        hashCode = hashCode * 8191 + aze.hashCode();
-
-      return hashCode;
-    }
-
-    @Override
-    public int compareTo(beginFileUpload_result other) {
-      if (!getClass().equals(other.getClass())) {
-        return getClass().getName().compareTo(other.getClass().getName());
-      }
-
-      int lastComparison = 0;
-
-      lastComparison = java.lang.Boolean.valueOf(is_set_success()).compareTo(other.is_set_success());
-      if (lastComparison != 0) {
-        return lastComparison;
-      }
-      if (is_set_success()) {
-        lastComparison = org.apache.storm.thrift.TBaseHelper.compareTo(this.success, other.success);
-        if (lastComparison != 0) {
-          return lastComparison;
-        }
-      }
-      lastComparison = java.lang.Boolean.valueOf(is_set_aze()).compareTo(other.is_set_aze());
-      if (lastComparison != 0) {
-        return lastComparison;
-      }
-      if (is_set_aze()) {
-        lastComparison = org.apache.storm.thrift.TBaseHelper.compareTo(this.aze, other.aze);
-        if (lastComparison != 0) {
-          return lastComparison;
-        }
-      }
-      return 0;
-    }
-
-    public _Fields fieldForId(int fieldId) {
-      return _Fields.findByThriftId(fieldId);
-    }
-
-    public void read(org.apache.storm.thrift.protocol.TProtocol iprot) throws org.apache.storm.thrift.TException {
-      scheme(iprot).read(iprot, this);
-    }
-
-    public void write(org.apache.storm.thrift.protocol.TProtocol oprot) throws org.apache.storm.thrift.TException {
-      scheme(oprot).write(oprot, this);
-      }
-
-    @Override
-    public java.lang.String toString() {
-      java.lang.StringBuilder sb = new java.lang.StringBuilder("beginFileUpload_result(");
-      boolean first = true;
-
-      sb.append("success:");
-      if (this.success == null) {
-        sb.append("null");
-      } else {
-        sb.append(this.success);
-      }
-      first = false;
-      if (!first) sb.append(", ");
-      sb.append("aze:");
-      if (this.aze == null) {
-        sb.append("null");
-      } else {
-        sb.append(this.aze);
-      }
-      first = false;
-      sb.append(")");
-      return sb.toString();
-    }
-
-    public void validate() throws org.apache.storm.thrift.TException {
-      // check for required fields
-      // check for sub-struct validity
-    }
-
-    private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
-      try {
-        write(new org.apache.storm.thrift.protocol.TCompactProtocol(new org.apache.storm.thrift.transport.TIOStreamTransport(out)));
-      } catch (org.apache.storm.thrift.TException te) {
-        throw new java.io.IOException(te);
-      }
-    }
-
-    private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException {
-      try {
-        read(new org.apache.storm.thrift.protocol.TCompactProtocol(new org.apache.storm.thrift.transport.TIOStreamTransport(in)));
-      } catch (org.apache.storm.thrift.TException te) {
-        throw new java.io.IOException(te);
-      }
-    }
-
-    private static class beginFileUpload_resultStandardSchemeFactory implements org.apache.storm.thrift.scheme.SchemeFactory {
-      public beginFileUpload_resultStandardScheme getScheme() {
-        return new beginFileUpload_resultStandardScheme();
-      }
-    }
-
-    private static class beginFileUpload_resultStandardScheme extends org.apache.storm.thrift.scheme.StandardScheme<beginFileUpload_result> {
-
-      public void read(org.apache.storm.thrift.protocol.TProtocol iprot, beginFileUpload_result struct) throws org.apache.storm.thrift.TException {
-        org.apache.storm.thrift.protocol.TField schemeField;
-        iprot.readStructBegin();
-        while (true)
-        {
-          schemeField = iprot.readFieldBegin();
-          if (schemeField.type == org.apache.storm.thrift.protocol.TType.STOP) { 
-            break;
-          }
-          switch (schemeField.id) {
-            case 0: // SUCCESS
-              if (schemeField.type == org.apache.storm.thrift.protocol.TType.STRING) {
-                struct.success = iprot.readString();
-                struct.set_success_isSet(true);
-              } else { 
-                org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
-              }
-              break;
-            case 1: // AZE
-              if (schemeField.type == org.apache.storm.thrift.protocol.TType.STRUCT) {
-                struct.aze = new AuthorizationException();
-                struct.aze.read(iprot);
-                struct.set_aze_isSet(true);
-              } else { 
-                org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
-              }
-              break;
-            default:
-              org.apache.storm.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
-          }
-          iprot.readFieldEnd();
-        }
-        iprot.readStructEnd();
-        struct.validate();
-      }
-
-      public void write(org.apache.storm.thrift.protocol.TProtocol oprot, beginFileUpload_result struct) throws org.apache.storm.thrift.TException {
-        struct.validate();
-
-        oprot.writeStructBegin(STRUCT_DESC);
-        if (struct.success != null) {
-          oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
-          oprot.writeString(struct.success);
-          oprot.writeFieldEnd();
-        }
-        if (struct.aze != null) {
-          oprot.writeFieldBegin(AZE_FIELD_DESC);
-          struct.aze.write(oprot);
-          oprot.writeFieldEnd();
-        }
-        oprot.writeFieldStop();
-        oprot.writeStructEnd();
-      }
-
-    }
-
-    private static class beginFileUpload_resultTupleSchemeFactory implements org.apache.storm.thrift.scheme.SchemeFactory {
-      public beginFileUpload_resultTupleScheme getScheme() {
-        return new beginFileUpload_resultTupleScheme();
-      }
-    }
-
-    private static class beginFileUpload_resultTupleScheme extends org.apache.storm.thrift.scheme.TupleScheme<beginFileUpload_result> {
-
-      @Override
-      public void write(org.apache.storm.thrift.protocol.TProtocol prot, beginFileUpload_result struct) throws org.apache.storm.thrift.TException {
-        org.apache.storm.thrift.protocol.TTupleProtocol oprot = (org.apache.storm.thrift.protocol.TTupleProtocol) prot;
-        java.util.BitSet optionals = new java.util.BitSet();
-        if (struct.is_set_success()) {
-          optionals.set(0);
-        }
-        if (struct.is_set_aze()) {
-          optionals.set(1);
-        }
-        oprot.writeBitSet(optionals, 2);
-        if (struct.is_set_success()) {
-          oprot.writeString(struct.success);
-        }
-        if (struct.is_set_aze()) {
-          struct.aze.write(oprot);
-        }
-      }
-
-      @Override
-      public void read(org.apache.storm.thrift.protocol.TProtocol prot, beginFileUpload_result struct) throws org.apache.storm.thrift.TException {
-        org.apache.storm.thrift.protocol.TTupleProtocol iprot = (org.apache.storm.thrift.protocol.TTupleProtocol) prot;
-        java.util.BitSet incoming = iprot.readBitSet(2);
-        if (incoming.get(0)) {
-          struct.success = iprot.readString();
-          struct.set_success_isSet(true);
-        }
-        if (incoming.get(1)) {
-          struct.aze = new AuthorizationException();
-          struct.aze.read(iprot);
-          struct.set_aze_isSet(true);
-        }
-      }
-    }
-
-    private static <S extends org.apache.storm.thrift.scheme.IScheme> S scheme(org.apache.storm.thrift.protocol.TProtocol proto) {
-      return (org.apache.storm.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme();
-    }
-  }
-
-  public static class uploadChunk_args implements org.apache.storm.thrift.TBase<uploadChunk_args, uploadChunk_args._Fields>, java.io.Serializable, Cloneable, Comparable<uploadChunk_args>   {
-    private static final org.apache.storm.thrift.protocol.TStruct STRUCT_DESC = new org.apache.storm.thrift.protocol.TStruct("uploadChunk_args");
-
-    private static final org.apache.storm.thrift.protocol.TField LOCATION_FIELD_DESC = new org.apache.storm.thrift.protocol.TField("location", org.apache.storm.thrift.protocol.TType.STRING, (short)1);
-    private static final org.apache.storm.thrift.protocol.TField CHUNK_FIELD_DESC = new org.apache.storm.thrift.protocol.TField("chunk", org.apache.storm.thrift.protocol.TType.STRING, (short)2);
-
-    private static final org.apache.storm.thrift.scheme.Sch

<TRUNCATED>

Mime
View raw message