[53/60] [abbrv] storm git commit: removed jstorm-on-yarn subdirectory

[pt...@apache.org]

http://git-wip-us.apache.org/repos/asf/storm/blob/e1f68448/jstorm-on-yarn/src/main/java/com/alibaba/jstorm/yarn/generated/StormMaster.java
----------------------------------------------------------------------
diff --git a/jstorm-on-yarn/src/main/java/com/alibaba/jstorm/yarn/generated/StormMaster.java b/jstorm-on-yarn/src/main/java/com/alibaba/jstorm/yarn/generated/StormMaster.java
deleted file mode 100644
index b6ca97c..0000000
--- a/jstorm-on-yarn/src/main/java/com/alibaba/jstorm/yarn/generated/StormMaster.java
+++ /dev/null
@@ -1,5113 +0,0 @@
-/**
- * Autogenerated by Thrift Compiler (0.7.0)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- */
-package com.alibaba.jstorm.yarn.generated;
-
-import java.util.BitSet;
-import java.util.Collections;
-import java.util.EnumMap;
-import java.util.EnumSet;
-import java.util.HashMap;
-import java.util.Map;
-
-import org.apache.commons.lang.builder.HashCodeBuilder;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class StormMaster {
-
-  public interface Iface {
-
-    public String getStormConf() throws org.apache.thrift7.TException;
-
-    public void setStormConf(String storm_conf) throws org.apache.thrift7.TException;
-
-    public void addSupervisors(int number) throws org.apache.thrift7.TException;
-
-    public void startNimbus() throws org.apache.thrift7.TException;
-
-    public void stopNimbus() throws org.apache.thrift7.TException;
-
-    public void startUI() throws org.apache.thrift7.TException;
-
-    public void stopUI() throws org.apache.thrift7.TException;
-
-    public void startSupervisors() throws org.apache.thrift7.TException;
-
-    public void stopSupervisors() throws org.apache.thrift7.TException;
-
-    public void shutdown() throws org.apache.thrift7.TException;
-
-  }
-
-  public interface AsyncIface {
-
-    public void getStormConf(org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.getStormConf_call> resultHandler) throws org.apache.thrift7.TException;
-
-    public void setStormConf(String storm_conf, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.setStormConf_call> resultHandler) throws org.apache.thrift7.TException;
-
-    public void addSupervisors(int number, org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.addSupervisors_call> resultHandler) throws org.apache.thrift7.TException;
-
-    public void startNimbus(org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.startNimbus_call> resultHandler) throws org.apache.thrift7.TException;
-
-    public void stopNimbus(org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.stopNimbus_call> resultHandler) throws org.apache.thrift7.TException;
-
-    public void startUI(org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.startUI_call> resultHandler) throws org.apache.thrift7.TException;
-
-    public void stopUI(org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.stopUI_call> resultHandler) throws org.apache.thrift7.TException;
-
-    public void startSupervisors(org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.startSupervisors_call> resultHandler) throws org.apache.thrift7.TException;
-
-    public void stopSupervisors(org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.stopSupervisors_call> resultHandler) throws org.apache.thrift7.TException;
-
-    public void shutdown(org.apache.thrift7.async.AsyncMethodCallback<AsyncClient.shutdown_call> resultHandler) throws org.apache.thrift7.TException;
-
-  }
-
-  public static class Client extends org.apache.thrift7.TServiceClient implements Iface {
-    public static class Factory implements org.apache.thrift7.TServiceClientFactory<Client> {
-      public Factory() {}
-      public Client getClient(org.apache.thrift7.protocol.TProtocol prot) {
-        return new Client(prot);
-      }
-      public Client getClient(org.apache.thrift7.protocol.TProtocol iprot, org.apache.thrift7.protocol.TProtocol oprot) {
-        return new Client(iprot, oprot);
-      }
-    }
-
-    public Client(org.apache.thrift7.protocol.TProtocol prot)
-    {
-      super(prot, prot);
-    }
-
-    public Client(org.apache.thrift7.protocol.TProtocol iprot, org.apache.thrift7.protocol.TProtocol oprot) {
-      super(iprot, oprot);
-    }
-
-    public String getStormConf() throws org.apache.thrift7.TException
-    {
-      send_getStormConf();
-      return recv_getStormConf();
-    }
-
-    public void send_getStormConf() throws org.apache.thrift7.TException
-    {
-      getStormConf_args args = new getStormConf_args();
-      sendBase("getStormConf", args);
-    }
-
-    public String recv_getStormConf() throws org.apache.thrift7.TException
-    {
-      getStormConf_result result = new getStormConf_result();
-      receiveBase(result, "getStormConf");
-      if (result.is_set_success()) {
-        return result.success;
-      }
-      throw new org.apache.thrift7.TApplicationException(org.apache.thrift7.TApplicationException.MISSING_RESULT, "getStormConf failed: unknown result");
-    }
-
-    public void setStormConf(String storm_conf) throws org.apache.thrift7.TException
-    {
-      send_setStormConf(storm_conf);
-      recv_setStormConf();
-    }
-
-    public void send_setStormConf(String storm_conf) throws org.apache.thrift7.TException
-    {
-      setStormConf_args args = new setStormConf_args();
-      args.set_storm_conf(storm_conf);
-      sendBase("setStormConf", args);
-    }
-
-    public void recv_setStormConf() throws org.apache.thrift7.TException
-    {
-      setStormConf_result result = new setStormConf_result();
-      receiveBase(result, "setStormConf");
-      return;
-    }
-
-    public void addSupervisors(int number) throws org.apache.thrift7.TException
-    {
-      send_addSupervisors(number);
-      recv_addSupervisors();
-    }
-
-    public void send_addSupervisors(int number) throws org.apache.thrift7.TException
-    {
-      addSupervisors_args args = new addSupervisors_args();
-      args.set_number(number);
-      sendBase("addSupervisors", args);
-    }
-
-    public void recv_addSupervisors() throws org.apache.thrift7.TException
-    {
-      addSupervisors_result result = new addSupervisors_result();
-      receiveBase(result, "addSupervisors");
-      return;
-    }
-
-    public void startNimbus() throws org.apache.thrift7.TException
-    {
-      send_startNimbus();
-      recv_startNimbus();
-    }
-
-    public void send_startNimbus() throws org.apache.thrift7.TException
-    {
-      startNimbus_args args = new startNimbus_args();
-      sendBase("startNimbus", args);
-    }
-
-    public void recv_startNimbus() throws org.apache.thrift7.TException
-    {
-      startNimbus_result result = new startNimbus_result();
-      receiveBase(result, "startNimbus");
-      return;
-    }
-
-    public void stopNimbus() throws org.apache.thrift7.TException
-    {
-      send_stopNimbus();
-      recv_stopNimbus();
-    }
-
-    public void send_stopNimbus() throws org.apache.thrift7.TException
-    {
-      stopNimbus_args args = new stopNimbus_args();
-      sendBase("stopNimbus", args);
-    }
-
-    public void recv_stopNimbus() throws org.apache.thrift7.TException
-    {
-      stopNimbus_result result = new stopNimbus_result();
-      receiveBase(result, "stopNimbus");
-      return;
-    }
-
-    public void startUI() throws org.apache.thrift7.TException
-    {
-      send_startUI();
-      recv_startUI();
-    }
-
-    public void send_startUI() throws org.apache.thrift7.TException
-    {
-      startUI_args args = new startUI_args();
-      sendBase("startUI", args);
-    }
-
-    public void recv_startUI() throws org.apache.thrift7.TException
-    {
-      startUI_result result = new startUI_result();
-      receiveBase(result, "startUI");
-      return;
-    }
-
-    public void stopUI() throws org.apache.thrift7.TException
-    {
-      send_stopUI();
-      recv_stopUI();
-    }
-
-    public void send_stopUI() throws org.apache.thrift7.TException
-    {
-      stopUI_args args = new stopUI_args();
-      sendBase("stopUI", args);
-    }
-
-    public void recv_stopUI() throws org.apache.thrift7.TException
-    {
-      stopUI_result result = new stopUI_result();
-      receiveBase(result, "stopUI");
-      return;
-    }
-
-    public void startSupervisors() throws org.apache.thrift7.TException
-    {
-      send_startSupervisors();
-      recv_startSupervisors();
-    }
-
-    public void send_startSupervisors() throws org.apache.thrift7.TException
-    {
-      startSupervisors_args args = new startSupervisors_args();
-      sendBase("startSupervisors", args);
-    }
-
-    public void recv_startSupervisors() throws org.apache.thrift7.TException
-    {
-      startSupervisors_result result = new startSupervisors_result();
-      receiveBase(result, "startSupervisors");
-      return;
-    }
-
-    public void stopSupervisors() throws org.apache.thrift7.TException
-    {
-      send_stopSupervisors();
-      recv_stopSupervisors();
-    }
-
-    public void send_stopSupervisors() throws org.apache.thrift7.TException
-    {
-      stopSupervisors_args args = new stopSupervisors_args();
-      sendBase("stopSupervisors", args);
-    }
-
-    public void recv_stopSupervisors() throws org.apache.thrift7.TException
-    {
-      stopSupervisors_result result = new stopSupervisors_result();
-      receiveBase(result, "stopSupervisors");
-      return;
-    }
-
-    public void shutdown() throws org.apache.thrift7.TException
-    {
-      send_shutdown();
-      recv_shutdown();
-    }
-
-    public void send_shutdown() throws org.apache.thrift7.TException
-    {
-      shutdown_args args = new shutdown_args();
-      sendBase("shutdown", args);
-    }
-
-    public void recv_shutdown() throws org.apache.thrift7.TException
-    {
-      shutdown_result result = new shutdown_result();
-      receiveBase(result, "shutdown");
-      return;
-    }
-
-  }
-  public static class AsyncClient extends org.apache.thrift7.async.TAsyncClient implements AsyncIface {
-    public static class Factory implements org.apache.thrift7.async.TAsyncClientFactory<AsyncClient> {
-      private org.apache.thrift7.async.TAsyncClientManager clientManager;
-      private org.apache.thrift7.protocol.TProtocolFactory protocolFactory;
-      public Factory(org.apache.thrift7.async.TAsyncClientManager clientManager, org.apache.thrift7.protocol.TProtocolFactory protocolFactory) {
-        this.clientManager = clientManager;
-        this.protocolFactory = protocolFactory;
-      }
-      public AsyncClient getAsyncClient(org.apache.thrift7.transport.TNonblockingTransport transport) {
-        return new AsyncClient(protocolFactory, clientManager, transport);
-      }
-    }
-
-    public AsyncClient(org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.async.TAsyncClientManager clientManager, org.apache.thrift7.transport.TNonblockingTransport transport) {
-      super(protocolFactory, clientManager, transport);
-    }
-
-    public void getStormConf(org.apache.thrift7.async.AsyncMethodCallback<getStormConf_call> resultHandler) throws org.apache.thrift7.TException {
-      checkReady();
-      getStormConf_call method_call = new getStormConf_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class getStormConf_call extends org.apache.thrift7.async.TAsyncMethodCall {
-      public getStormConf_call(org.apache.thrift7.async.AsyncMethodCallback<getStormConf_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-      }
-
-      public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
-        prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("getStormConf", org.apache.thrift7.protocol.TMessageType.CALL, 0));
-        getStormConf_args args = new getStormConf_args();
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public String getResult() throws org.apache.thrift7.TException {
-        if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_getStormConf();
-      }
-    }
-
-    public void setStormConf(String storm_conf, org.apache.thrift7.async.AsyncMethodCallback<setStormConf_call> resultHandler) throws org.apache.thrift7.TException {
-      checkReady();
-      setStormConf_call method_call = new setStormConf_call(storm_conf, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class setStormConf_call extends org.apache.thrift7.async.TAsyncMethodCall {
-      private String storm_conf;
-      public setStormConf_call(String storm_conf, org.apache.thrift7.async.AsyncMethodCallback<setStormConf_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.storm_conf = storm_conf;
-      }
-
-      public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
-        prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("setStormConf", org.apache.thrift7.protocol.TMessageType.CALL, 0));
-        setStormConf_args args = new setStormConf_args();
-        args.set_storm_conf(storm_conf);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws org.apache.thrift7.TException {
-        if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_setStormConf();
-      }
-    }
-
-    public void addSupervisors(int number, org.apache.thrift7.async.AsyncMethodCallback<addSupervisors_call> resultHandler) throws org.apache.thrift7.TException {
-      checkReady();
-      addSupervisors_call method_call = new addSupervisors_call(number, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class addSupervisors_call extends org.apache.thrift7.async.TAsyncMethodCall {
-      private int number;
-      public addSupervisors_call(int number, org.apache.thrift7.async.AsyncMethodCallback<addSupervisors_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.number = number;
-      }
-
-      public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
-        prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("addSupervisors", org.apache.thrift7.protocol.TMessageType.CALL, 0));
-        addSupervisors_args args = new addSupervisors_args();
-        args.set_number(number);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws org.apache.thrift7.TException {
-        if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_addSupervisors();
-      }
-    }
-
-    public void startNimbus(org.apache.thrift7.async.AsyncMethodCallback<startNimbus_call> resultHandler) throws org.apache.thrift7.TException {
-      checkReady();
-      startNimbus_call method_call = new startNimbus_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class startNimbus_call extends org.apache.thrift7.async.TAsyncMethodCall {
-      public startNimbus_call(org.apache.thrift7.async.AsyncMethodCallback<startNimbus_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-      }
-
-      public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
-        prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("startNimbus", org.apache.thrift7.protocol.TMessageType.CALL, 0));
-        startNimbus_args args = new startNimbus_args();
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws org.apache.thrift7.TException {
-        if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_startNimbus();
-      }
-    }
-
-    public void stopNimbus(org.apache.thrift7.async.AsyncMethodCallback<stopNimbus_call> resultHandler) throws org.apache.thrift7.TException {
-      checkReady();
-      stopNimbus_call method_call = new stopNimbus_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class stopNimbus_call extends org.apache.thrift7.async.TAsyncMethodCall {
-      public stopNimbus_call(org.apache.thrift7.async.AsyncMethodCallback<stopNimbus_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-      }
-
-      public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
-        prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("stopNimbus", org.apache.thrift7.protocol.TMessageType.CALL, 0));
-        stopNimbus_args args = new stopNimbus_args();
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws org.apache.thrift7.TException {
-        if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_stopNimbus();
-      }
-    }
-
-    public void startUI(org.apache.thrift7.async.AsyncMethodCallback<startUI_call> resultHandler) throws org.apache.thrift7.TException {
-      checkReady();
-      startUI_call method_call = new startUI_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class startUI_call extends org.apache.thrift7.async.TAsyncMethodCall {
-      public startUI_call(org.apache.thrift7.async.AsyncMethodCallback<startUI_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-      }
-
-      public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
-        prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("startUI", org.apache.thrift7.protocol.TMessageType.CALL, 0));
-        startUI_args args = new startUI_args();
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws org.apache.thrift7.TException {
-        if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_startUI();
-      }
-    }
-
-    public void stopUI(org.apache.thrift7.async.AsyncMethodCallback<stopUI_call> resultHandler) throws org.apache.thrift7.TException {
-      checkReady();
-      stopUI_call method_call = new stopUI_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class stopUI_call extends org.apache.thrift7.async.TAsyncMethodCall {
-      public stopUI_call(org.apache.thrift7.async.AsyncMethodCallback<stopUI_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-      }
-
-      public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
-        prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("stopUI", org.apache.thrift7.protocol.TMessageType.CALL, 0));
-        stopUI_args args = new stopUI_args();
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws org.apache.thrift7.TException {
-        if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_stopUI();
-      }
-    }
-
-    public void startSupervisors(org.apache.thrift7.async.AsyncMethodCallback<startSupervisors_call> resultHandler) throws org.apache.thrift7.TException {
-      checkReady();
-      startSupervisors_call method_call = new startSupervisors_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class startSupervisors_call extends org.apache.thrift7.async.TAsyncMethodCall {
-      public startSupervisors_call(org.apache.thrift7.async.AsyncMethodCallback<startSupervisors_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-      }
-
-      public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
-        prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("startSupervisors", org.apache.thrift7.protocol.TMessageType.CALL, 0));
-        startSupervisors_args args = new startSupervisors_args();
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws org.apache.thrift7.TException {
-        if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_startSupervisors();
-      }
-    }
-
-    public void stopSupervisors(org.apache.thrift7.async.AsyncMethodCallback<stopSupervisors_call> resultHandler) throws org.apache.thrift7.TException {
-      checkReady();
-      stopSupervisors_call method_call = new stopSupervisors_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class stopSupervisors_call extends org.apache.thrift7.async.TAsyncMethodCall {
-      public stopSupervisors_call(org.apache.thrift7.async.AsyncMethodCallback<stopSupervisors_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-      }
-
-      public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
-        prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("stopSupervisors", org.apache.thrift7.protocol.TMessageType.CALL, 0));
-        stopSupervisors_args args = new stopSupervisors_args();
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws org.apache.thrift7.TException {
-        if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_stopSupervisors();
-      }
-    }
-
-    public void shutdown(org.apache.thrift7.async.AsyncMethodCallback<shutdown_call> resultHandler) throws org.apache.thrift7.TException {
-      checkReady();
-      shutdown_call method_call = new shutdown_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class shutdown_call extends org.apache.thrift7.async.TAsyncMethodCall {
-      public shutdown_call(org.apache.thrift7.async.AsyncMethodCallback<shutdown_call> resultHandler, org.apache.thrift7.async.TAsyncClient client, org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.transport.TNonblockingTransport transport) throws org.apache.thrift7.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-      }
-
-      public void write_args(org.apache.thrift7.protocol.TProtocol prot) throws org.apache.thrift7.TException {
-        prot.writeMessageBegin(new org.apache.thrift7.protocol.TMessage("shutdown", org.apache.thrift7.protocol.TMessageType.CALL, 0));
-        shutdown_args args = new shutdown_args();
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws org.apache.thrift7.TException {
-        if (getState() != org.apache.thrift7.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift7.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift7.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift7.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_shutdown();
-      }
-    }
-
-  }
-
-  public static class Processor<I extends Iface> extends org.apache.thrift7.TBaseProcessor implements org.apache.thrift7.TProcessor {
-    private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName());
-    public Processor(I iface) {
-      super(iface, getProcessMap(new HashMap<String, org.apache.thrift7.ProcessFunction<I, ? extends org.apache.thrift7.TBase>>()));
-    }
-
-    protected Processor(I iface, Map<String,  org.apache.thrift7.ProcessFunction<I, ? extends  org.apache.thrift7.TBase>> processMap) {
-      super(iface, getProcessMap(processMap));
-    }
-
-    private static <I extends Iface> Map<String,  org.apache.thrift7.ProcessFunction<I, ? extends  org.apache.thrift7.TBase>> getProcessMap(Map<String,  org.apache.thrift7.ProcessFunction<I, ? extends  org.apache.thrift7.TBase>> processMap) {
-      processMap.put("getStormConf", new getStormConf());
-      processMap.put("setStormConf", new setStormConf());
-      processMap.put("addSupervisors", new addSupervisors());
-      processMap.put("startNimbus", new startNimbus());
-      processMap.put("stopNimbus", new stopNimbus());
-      processMap.put("startUI", new startUI());
-      processMap.put("stopUI", new stopUI());
-      processMap.put("startSupervisors", new startSupervisors());
-      processMap.put("stopSupervisors", new stopSupervisors());
-      processMap.put("shutdown", new shutdown());
-      return processMap;
-    }
-
-    private static class getStormConf<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, getStormConf_args> {
-      public getStormConf() {
-        super("getStormConf");
-      }
-
-      protected getStormConf_args getEmptyArgsInstance() {
-        return new getStormConf_args();
-      }
-
-      protected getStormConf_result getResult(I iface, getStormConf_args args) throws org.apache.thrift7.TException {
-        getStormConf_result result = new getStormConf_result();
-        result.success = iface.getStormConf();
-        return result;
-      }
-    }
-
-    private static class setStormConf<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, setStormConf_args> {
-      public setStormConf() {
-        super("setStormConf");
-      }
-
-      protected setStormConf_args getEmptyArgsInstance() {
-        return new setStormConf_args();
-      }
-
-      protected setStormConf_result getResult(I iface, setStormConf_args args) throws org.apache.thrift7.TException {
-        setStormConf_result result = new setStormConf_result();
-        iface.setStormConf(args.storm_conf);
-        return result;
-      }
-    }
-
-    private static class addSupervisors<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, addSupervisors_args> {
-      public addSupervisors() {
-        super("addSupervisors");
-      }
-
-      protected addSupervisors_args getEmptyArgsInstance() {
-        return new addSupervisors_args();
-      }
-
-      protected addSupervisors_result getResult(I iface, addSupervisors_args args) throws org.apache.thrift7.TException {
-        addSupervisors_result result = new addSupervisors_result();
-        iface.addSupervisors(args.number);
-        return result;
-      }
-    }
-
-    private static class startNimbus<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, startNimbus_args> {
-      public startNimbus() {
-        super("startNimbus");
-      }
-
-      protected startNimbus_args getEmptyArgsInstance() {
-        return new startNimbus_args();
-      }
-
-      protected startNimbus_result getResult(I iface, startNimbus_args args) throws org.apache.thrift7.TException {
-        startNimbus_result result = new startNimbus_result();
-        iface.startNimbus();
-        return result;
-      }
-    }
-
-    private static class stopNimbus<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, stopNimbus_args> {
-      public stopNimbus() {
-        super("stopNimbus");
-      }
-
-      protected stopNimbus_args getEmptyArgsInstance() {
-        return new stopNimbus_args();
-      }
-
-      protected stopNimbus_result getResult(I iface, stopNimbus_args args) throws org.apache.thrift7.TException {
-        stopNimbus_result result = new stopNimbus_result();
-        iface.stopNimbus();
-        return result;
-      }
-    }
-
-    private static class startUI<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, startUI_args> {
-      public startUI() {
-        super("startUI");
-      }
-
-      protected startUI_args getEmptyArgsInstance() {
-        return new startUI_args();
-      }
-
-      protected startUI_result getResult(I iface, startUI_args args) throws org.apache.thrift7.TException {
-        startUI_result result = new startUI_result();
-        iface.startUI();
-        return result;
-      }
-    }
-
-    private static class stopUI<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, stopUI_args> {
-      public stopUI() {
-        super("stopUI");
-      }
-
-      protected stopUI_args getEmptyArgsInstance() {
-        return new stopUI_args();
-      }
-
-      protected stopUI_result getResult(I iface, stopUI_args args) throws org.apache.thrift7.TException {
-        stopUI_result result = new stopUI_result();
-        iface.stopUI();
-        return result;
-      }
-    }
-
-    private static class startSupervisors<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, startSupervisors_args> {
-      public startSupervisors() {
-        super("startSupervisors");
-      }
-
-      protected startSupervisors_args getEmptyArgsInstance() {
-        return new startSupervisors_args();
-      }
-
-      protected startSupervisors_result getResult(I iface, startSupervisors_args args) throws org.apache.thrift7.TException {
-        startSupervisors_result result = new startSupervisors_result();
-        iface.startSupervisors();
-        return result;
-      }
-    }
-
-    private static class stopSupervisors<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, stopSupervisors_args> {
-      public stopSupervisors() {
-        super("stopSupervisors");
-      }
-
-      protected stopSupervisors_args getEmptyArgsInstance() {
-        return new stopSupervisors_args();
-      }
-
-      protected stopSupervisors_result getResult(I iface, stopSupervisors_args args) throws org.apache.thrift7.TException {
-        stopSupervisors_result result = new stopSupervisors_result();
-        iface.stopSupervisors();
-        return result;
-      }
-    }
-
-    private static class shutdown<I extends Iface> extends org.apache.thrift7.ProcessFunction<I, shutdown_args> {
-      public shutdown() {
-        super("shutdown");
-      }
-
-      protected shutdown_args getEmptyArgsInstance() {
-        return new shutdown_args();
-      }
-
-      protected shutdown_result getResult(I iface, shutdown_args args) throws org.apache.thrift7.TException {
-        shutdown_result result = new shutdown_result();
-        iface.shutdown();
-        return result;
-      }
-    }
-
-  }
-
-  public static class getStormConf_args implements org.apache.thrift7.TBase<getStormConf_args, getStormConf_args._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct("getStormConf_args");
-
-
-
-    /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
-    public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
-;
-
-      private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
-
-      static {
-        for (_Fields field : EnumSet.allOf(_Fields.class)) {
-          byName.put(field.getFieldName(), field);
-        }
-      }
-
-      /**
-       * Find the _Fields constant that matches fieldId, or null if its not found.
-       */
-      public static _Fields findByThriftId(int fieldId) {
-        switch(fieldId) {
-          default:
-            return null;
-        }
-      }
-
-      /**
-       * Find the _Fields constant that matches fieldId, throwing an exception
-       * if it is not found.
-       */
-      public static _Fields findByThriftIdOrThrow(int fieldId) {
-        _Fields fields = findByThriftId(fieldId);
-        if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
-        return fields;
-      }
-
-      /**
-       * Find the _Fields constant that matches name, or null if its not found.
-       */
-      public static _Fields findByName(String name) {
-        return byName.get(name);
-      }
-
-      private final short _thriftId;
-      private final String _fieldName;
-
-      _Fields(short thriftId, String fieldName) {
-        _thriftId = thriftId;
-        _fieldName = fieldName;
-      }
-
-      public short getThriftFieldId() {
-        return _thriftId;
-      }
-
-      public String getFieldName() {
-        return _fieldName;
-      }
-    }
-    public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
-    static {
-      Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(_Fields.class);
-      metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(getStormConf_args.class, metaDataMap);
-    }
-
-    public getStormConf_args() {
-    }
-
-    /**
-     * Performs a deep copy on <i>other</i>.
-     */
-    public getStormConf_args(getStormConf_args other) {
-    }
-
-    public getStormConf_args deepCopy() {
-      return new getStormConf_args(this);
-    }
-
-    @Override
-    public void clear() {
-    }
-
-    public void setFieldValue(_Fields field, Object value) {
-      switch (field) {
-      }
-    }
-
-    public Object getFieldValue(_Fields field) {
-      switch (field) {
-      }
-      throw new 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 IllegalArgumentException();
-      }
-
-      switch (field) {
-      }
-      throw new IllegalStateException();
-    }
-
-    @Override
-    public boolean equals(Object that) {
-      if (that == null)
-        return false;
-      if (that instanceof getStormConf_args)
-        return this.equals((getStormConf_args)that);
-      return false;
-    }
-
-    public boolean equals(getStormConf_args that) {
-      if (that == null)
-        return false;
-
-      return true;
-    }
-
-    @Override
-    public int hashCode() {
-      HashCodeBuilder builder = new HashCodeBuilder();
-
-      return builder.toHashCode();
-    }
-
-    public int compareTo(getStormConf_args other) {
-      if (!getClass().equals(other.getClass())) {
-        return getClass().getName().compareTo(other.getClass().getName());
-      }
-
-      int lastComparison = 0;
-      getStormConf_args typedOther = (getStormConf_args)other;
-
-      return 0;
-    }
-
-    public _Fields fieldForId(int fieldId) {
-      return _Fields.findByThriftId(fieldId);
-    }
-
-    public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
-      org.apache.thrift7.protocol.TField field;
-      iprot.readStructBegin();
-      while (true)
-      {
-        field = iprot.readFieldBegin();
-        if (field.type == org.apache.thrift7.protocol.TType.STOP) { 
-          break;
-        }
-        switch (field.id) {
-          default:
-            org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
-        }
-        iprot.readFieldEnd();
-      }
-      iprot.readStructEnd();
-      validate();
-    }
-
-    public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
-      validate();
-
-      oprot.writeStructBegin(STRUCT_DESC);
-      oprot.writeFieldStop();
-      oprot.writeStructEnd();
-    }
-
-    @Override
-    public String toString() {
-      StringBuilder sb = new StringBuilder("getStormConf_args(");
-      boolean first = true;
-
-      sb.append(")");
-      return sb.toString();
-    }
-
-    public void validate() throws org.apache.thrift7.TException {
-      // check for required fields
-    }
-
-    private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
-      try {
-        write(new org.apache.thrift7.protocol.TCompactProtocol(new org.apache.thrift7.transport.TIOStreamTransport(out)));
-      } catch (org.apache.thrift7.TException te) {
-        throw new java.io.IOException(te);
-      }
-    }
-
-    private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
-      try {
-        read(new org.apache.thrift7.protocol.TCompactProtocol(new org.apache.thrift7.transport.TIOStreamTransport(in)));
-      } catch (org.apache.thrift7.TException te) {
-        throw new java.io.IOException(te);
-      }
-    }
-
-  }
-
-  public static class getStormConf_result implements org.apache.thrift7.TBase<getStormConf_result, getStormConf_result._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct("getStormConf_result");
-
-    private static final org.apache.thrift7.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift7.protocol.TField("success", org.apache.thrift7.protocol.TType.STRING, (short)0);
-
-    private String success; // required
-
-    /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
-    public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
-      SUCCESS((short)0, "success");
-
-      private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
-
-      static {
-        for (_Fields field : EnumSet.allOf(_Fields.class)) {
-          byName.put(field.getFieldName(), field);
-        }
-      }
-
-      /**
-       * Find the _Fields constant that matches fieldId, or null if its not found.
-       */
-      public static _Fields findByThriftId(int fieldId) {
-        switch(fieldId) {
-          case 0: // SUCCESS
-            return SUCCESS;
-          default:
-            return null;
-        }
-      }
-
-      /**
-       * Find the _Fields constant that matches fieldId, throwing an exception
-       * if it is not found.
-       */
-      public static _Fields findByThriftIdOrThrow(int fieldId) {
-        _Fields fields = findByThriftId(fieldId);
-        if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
-        return fields;
-      }
-
-      /**
-       * Find the _Fields constant that matches name, or null if its not found.
-       */
-      public static _Fields findByName(String name) {
-        return byName.get(name);
-      }
-
-      private final short _thriftId;
-      private final String _fieldName;
-
-      _Fields(short thriftId, String fieldName) {
-        _thriftId = thriftId;
-        _fieldName = fieldName;
-      }
-
-      public short getThriftFieldId() {
-        return _thriftId;
-      }
-
-      public String getFieldName() {
-        return _fieldName;
-      }
-    }
-
-    // isset id assignments
-
-    public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
-    static {
-      Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(_Fields.class);
-      tmpMap.put(_Fields.SUCCESS, new org.apache.thrift7.meta_data.FieldMetaData("success", org.apache.thrift7.TFieldRequirementType.DEFAULT, 
-          new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.STRING)));
-      metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(getStormConf_result.class, metaDataMap);
-    }
-
-    public getStormConf_result() {
-    }
-
-    public getStormConf_result(
-      String success)
-    {
-      this();
-      this.success = success;
-    }
-
-    /**
-     * Performs a deep copy on <i>other</i>.
-     */
-    public getStormConf_result(getStormConf_result other) {
-      if (other.is_set_success()) {
-        this.success = other.success;
-      }
-    }
-
-    public getStormConf_result deepCopy() {
-      return new getStormConf_result(this);
-    }
-
-    @Override
-    public void clear() {
-      this.success = null;
-    }
-
-    public String get_success() {
-      return this.success;
-    }
-
-    public void set_success(String success) {
-      this.success = success;
-    }
-
-    public void unset_success() {
-      this.success = null;
-    }
-
-    /** Returns true if field success is set (has been assigned a value) and false otherwise */
-    public boolean is_set_success() {
-      return this.success != null;
-    }
-
-    public void set_success_isSet(boolean value) {
-      if (!value) {
-        this.success = null;
-      }
-    }
-
-    public void setFieldValue(_Fields field, Object value) {
-      switch (field) {
-      case SUCCESS:
-        if (value == null) {
-          unset_success();
-        } else {
-          set_success((String)value);
-        }
-        break;
-
-      }
-    }
-
-    public Object getFieldValue(_Fields field) {
-      switch (field) {
-      case SUCCESS:
-        return get_success();
-
-      }
-      throw new 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 IllegalArgumentException();
-      }
-
-      switch (field) {
-      case SUCCESS:
-        return is_set_success();
-      }
-      throw new IllegalStateException();
-    }
-
-    @Override
-    public boolean equals(Object that) {
-      if (that == null)
-        return false;
-      if (that instanceof getStormConf_result)
-        return this.equals((getStormConf_result)that);
-      return false;
-    }
-
-    public boolean equals(getStormConf_result that) {
-      if (that == null)
-        return false;
-
-      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;
-      }
-
-      return true;
-    }
-
-    @Override
-    public int hashCode() {
-      HashCodeBuilder builder = new HashCodeBuilder();
-
-      boolean present_success = true && (is_set_success());
-      builder.append(present_success);
-      if (present_success)
-        builder.append(success);
-
-      return builder.toHashCode();
-    }
-
-    public int compareTo(getStormConf_result other) {
-      if (!getClass().equals(other.getClass())) {
-        return getClass().getName().compareTo(other.getClass().getName());
-      }
-
-      int lastComparison = 0;
-      getStormConf_result typedOther = (getStormConf_result)other;
-
-      lastComparison = Boolean.valueOf(is_set_success()).compareTo(typedOther.is_set_success());
-      if (lastComparison != 0) {
-        return lastComparison;
-      }
-      if (is_set_success()) {
-        lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.success, typedOther.success);
-        if (lastComparison != 0) {
-          return lastComparison;
-        }
-      }
-      return 0;
-    }
-
-    public _Fields fieldForId(int fieldId) {
-      return _Fields.findByThriftId(fieldId);
-    }
-
-    public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
-      org.apache.thrift7.protocol.TField field;
-      iprot.readStructBegin();
-      while (true)
-      {
-        field = iprot.readFieldBegin();
-        if (field.type == org.apache.thrift7.protocol.TType.STOP) { 
-          break;
-        }
-        switch (field.id) {
-          case 0: // SUCCESS
-            if (field.type == org.apache.thrift7.protocol.TType.STRING) {
-              this.success = iprot.readString();
-            } else { 
-              org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
-            }
-            break;
-          default:
-            org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
-        }
-        iprot.readFieldEnd();
-      }
-      iprot.readStructEnd();
-      validate();
-    }
-
-    public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
-      oprot.writeStructBegin(STRUCT_DESC);
-
-      if (this.is_set_success()) {
-        oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
-        oprot.writeString(this.success);
-        oprot.writeFieldEnd();
-      }
-      oprot.writeFieldStop();
-      oprot.writeStructEnd();
-    }
-
-    @Override
-    public String toString() {
-      StringBuilder sb = new StringBuilder("getStormConf_result(");
-      boolean first = true;
-
-      sb.append("success:");
-      if (this.success == null) {
-        sb.append("null");
-      } else {
-        sb.append(this.success);
-      }
-      first = false;
-      sb.append(")");
-      return sb.toString();
-    }
-
-    public void validate() throws org.apache.thrift7.TException {
-      // check for required fields
-    }
-
-    private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
-      try {
-        write(new org.apache.thrift7.protocol.TCompactProtocol(new org.apache.thrift7.transport.TIOStreamTransport(out)));
-      } catch (org.apache.thrift7.TException te) {
-        throw new java.io.IOException(te);
-      }
-    }
-
-    private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
-      try {
-        read(new org.apache.thrift7.protocol.TCompactProtocol(new org.apache.thrift7.transport.TIOStreamTransport(in)));
-      } catch (org.apache.thrift7.TException te) {
-        throw new java.io.IOException(te);
-      }
-    }
-
-  }
-
-  public static class setStormConf_args implements org.apache.thrift7.TBase<setStormConf_args, setStormConf_args._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct("setStormConf_args");
-
-    private static final org.apache.thrift7.protocol.TField STORM_CONF_FIELD_DESC = new org.apache.thrift7.protocol.TField("storm_conf", org.apache.thrift7.protocol.TType.STRING, (short)1);
-
-    private String storm_conf; // required
-
-    /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
-    public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
-      STORM_CONF((short)1, "storm_conf");
-
-      private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
-
-      static {
-        for (_Fields field : EnumSet.allOf(_Fields.class)) {
-          byName.put(field.getFieldName(), field);
-        }
-      }
-
-      /**
-       * Find the _Fields constant that matches fieldId, or null if its not found.
-       */
-      public static _Fields findByThriftId(int fieldId) {
-        switch(fieldId) {
-          case 1: // STORM_CONF
-            return STORM_CONF;
-          default:
-            return null;
-        }
-      }
-
-      /**
-       * Find the _Fields constant that matches fieldId, throwing an exception
-       * if it is not found.
-       */
-      public static _Fields findByThriftIdOrThrow(int fieldId) {
-        _Fields fields = findByThriftId(fieldId);
-        if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
-        return fields;
-      }
-
-      /**
-       * Find the _Fields constant that matches name, or null if its not found.
-       */
-      public static _Fields findByName(String name) {
-        return byName.get(name);
-      }
-
-      private final short _thriftId;
-      private final String _fieldName;
-
-      _Fields(short thriftId, String fieldName) {
-        _thriftId = thriftId;
-        _fieldName = fieldName;
-      }
-
-      public short getThriftFieldId() {
-        return _thriftId;
-      }
-
-      public String getFieldName() {
-        return _fieldName;
-      }
-    }
-
-    // isset id assignments
-
-    public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
-    static {
-      Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(_Fields.class);
-      tmpMap.put(_Fields.STORM_CONF, new org.apache.thrift7.meta_data.FieldMetaData("storm_conf", org.apache.thrift7.TFieldRequirementType.DEFAULT, 
-          new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.STRING)));
-      metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(setStormConf_args.class, metaDataMap);
-    }
-
-    public setStormConf_args() {
-    }
-
-    public setStormConf_args(
-      String storm_conf)
-    {
-      this();
-      this.storm_conf = storm_conf;
-    }
-
-    /**
-     * Performs a deep copy on <i>other</i>.
-     */
-    public setStormConf_args(setStormConf_args other) {
-      if (other.is_set_storm_conf()) {
-        this.storm_conf = other.storm_conf;
-      }
-    }
-
-    public setStormConf_args deepCopy() {
-      return new setStormConf_args(this);
-    }
-
-    @Override
-    public void clear() {
-      this.storm_conf = null;
-    }
-
-    public String get_storm_conf() {
-      return this.storm_conf;
-    }
-
-    public void set_storm_conf(String storm_conf) {
-      this.storm_conf = storm_conf;
-    }
-
-    public void unset_storm_conf() {
-      this.storm_conf = null;
-    }
-
-    /** Returns true if field storm_conf is set (has been assigned a value) and false otherwise */
-    public boolean is_set_storm_conf() {
-      return this.storm_conf != null;
-    }
-
-    public void set_storm_conf_isSet(boolean value) {
-      if (!value) {
-        this.storm_conf = null;
-      }
-    }
-
-    public void setFieldValue(_Fields field, Object value) {
-      switch (field) {
-      case STORM_CONF:
-        if (value == null) {
-          unset_storm_conf();
-        } else {
-          set_storm_conf((String)value);
-        }
-        break;
-
-      }
-    }
-
-    public Object getFieldValue(_Fields field) {
-      switch (field) {
-      case STORM_CONF:
-        return get_storm_conf();
-
-      }
-      throw new 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 IllegalArgumentException();
-      }
-
-      switch (field) {
-      case STORM_CONF:
-        return is_set_storm_conf();
-      }
-      throw new IllegalStateException();
-    }
-
-    @Override
-    public boolean equals(Object that) {
-      if (that == null)
-        return false;
-      if (that instanceof setStormConf_args)
-        return this.equals((setStormConf_args)that);
-      return false;
-    }
-
-    public boolean equals(setStormConf_args that) {
-      if (that == null)
-        return false;
-
-      boolean this_present_storm_conf = true && this.is_set_storm_conf();
-      boolean that_present_storm_conf = true && that.is_set_storm_conf();
-      if (this_present_storm_conf || that_present_storm_conf) {
-        if (!(this_present_storm_conf && that_present_storm_conf))
-          return false;
-        if (!this.storm_conf.equals(that.storm_conf))
-          return false;
-      }
-
-      return true;
-    }
-
-    @Override
-    public int hashCode() {
-      HashCodeBuilder builder = new HashCodeBuilder();
-
-      boolean present_storm_conf = true && (is_set_storm_conf());
-      builder.append(present_storm_conf);
-      if (present_storm_conf)
-        builder.append(storm_conf);
-
-      return builder.toHashCode();
-    }
-
-    public int compareTo(setStormConf_args other) {
-      if (!getClass().equals(other.getClass())) {
-        return getClass().getName().compareTo(other.getClass().getName());
-      }
-
-      int lastComparison = 0;
-      setStormConf_args typedOther = (setStormConf_args)other;
-
-      lastComparison = Boolean.valueOf(is_set_storm_conf()).compareTo(typedOther.is_set_storm_conf());
-      if (lastComparison != 0) {
-        return lastComparison;
-      }
-      if (is_set_storm_conf()) {
-        lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.storm_conf, typedOther.storm_conf);
-        if (lastComparison != 0) {
-          return lastComparison;
-        }
-      }
-      return 0;
-    }
-
-    public _Fields fieldForId(int fieldId) {
-      return _Fields.findByThriftId(fieldId);
-    }
-
-    public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
-      org.apache.thrift7.protocol.TField field;
-      iprot.readStructBegin();
-      while (true)
-      {
-        field = iprot.readFieldBegin();
-        if (field.type == org.apache.thrift7.protocol.TType.STOP) { 
-          break;
-        }
-        switch (field.id) {
-          case 1: // STORM_CONF
-            if (field.type == org.apache.thrift7.protocol.TType.STRING) {
-              this.storm_conf = iprot.readString();
-            } else { 
-              org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
-            }
-            break;
-          default:
-            org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
-        }
-        iprot.readFieldEnd();
-      }
-      iprot.readStructEnd();
-      validate();
-    }
-
-    public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
-      validate();
-
-      oprot.writeStructBegin(STRUCT_DESC);
-      if (this.storm_conf != null) {
-        oprot.writeFieldBegin(STORM_CONF_FIELD_DESC);
-        oprot.writeString(this.storm_conf);
-        oprot.writeFieldEnd();
-      }
-      oprot.writeFieldStop();
-      oprot.writeStructEnd();
-    }
-
-    @Override
-    public String toString() {
-      StringBuilder sb = new StringBuilder("setStormConf_args(");
-      boolean first = true;
-
-      sb.append("storm_conf:");
-      if (this.storm_conf == null) {
-        sb.append("null");
-      } else {
-        sb.append(this.storm_conf);
-      }
-      first = false;
-      sb.append(")");
-      return sb.toString();
-    }
-
-    public void validate() throws org.apache.thrift7.TException {
-      // check for required fields
-    }
-
-    private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
-      try {
-        write(new org.apache.thrift7.protocol.TCompactProtocol(new org.apache.thrift7.transport.TIOStreamTransport(out)));
-      } catch (org.apache.thrift7.TException te) {
-        throw new java.io.IOException(te);
-      }
-    }
-
-    private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
-      try {
-        read(new org.apache.thrift7.protocol.TCompactProtocol(new org.apache.thrift7.transport.TIOStreamTransport(in)));
-      } catch (org.apache.thrift7.TException te) {
-        throw new java.io.IOException(te);
-      }
-    }
-
-  }
-
-  public static class setStormConf_result implements org.apache.thrift7.TBase<setStormConf_result, setStormConf_result._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct("setStormConf_result");
-
-
-
-    /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
-    public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
-;
-
-      private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
-
-      static {
-        for (_Fields field : EnumSet.allOf(_Fields.class)) {
-          byName.put(field.getFieldName(), field);
-        }
-      }
-
-      /**
-       * Find the _Fields constant that matches fieldId, or null if its not found.
-       */
-      public static _Fields findByThriftId(int fieldId) {
-        switch(fieldId) {
-          default:
-            return null;
-        }
-      }
-
-      /**
-       * Find the _Fields constant that matches fieldId, throwing an exception
-       * if it is not found.
-       */
-      public static _Fields findByThriftIdOrThrow(int fieldId) {
-        _Fields fields = findByThriftId(fieldId);
-        if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
-        return fields;
-      }
-
-      /**
-       * Find the _Fields constant that matches name, or null if its not found.
-       */
-      public static _Fields findByName(String name) {
-        return byName.get(name);
-      }
-
-      private final short _thriftId;
-      private final String _fieldName;
-
-      _Fields(short thriftId, String fieldName) {
-        _thriftId = thriftId;
-        _fieldName = fieldName;
-      }
-
-      public short getThriftFieldId() {
-        return _thriftId;
-      }
-
-      public String getFieldName() {
-        return _fieldName;
-      }
-    }
-    public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
-    static {
-      Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(_Fields.class);
-      metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(setStormConf_result.class, metaDataMap);
-    }
-
-    public setStormConf_result() {
-    }
-
-    /**
-     * Performs a deep copy on <i>other</i>.
-     */
-    public setStormConf_result(setStormConf_result other) {
-    }
-
-    public setStormConf_result deepCopy() {
-      return new setStormConf_result(this);
-    }
-
-    @Override
-    public void clear() {
-    }
-
-    public void setFieldValue(_Fields field, Object value) {
-      switch (field) {
-      }
-    }
-
-    public Object getFieldValue(_Fields field) {
-      switch (field) {
-      }
-      throw new 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 IllegalArgumentException();
-      }
-
-      switch (field) {
-      }
-      throw new IllegalStateException();
-    }
-
-    @Override
-    public boolean equals(Object that) {
-      if (that == null)
-        return false;
-      if (that instanceof setStormConf_result)
-        return this.equals((setStormConf_result)that);
-      return false;
-    }
-
-    public boolean equals(setStormConf_result that) {
-      if (that == null)
-        return false;
-
-      return true;
-    }
-
-    @Override
-    public int hashCode() {
-      HashCodeBuilder builder = new HashCodeBuilder();
-
-      return builder.toHashCode();
-    }
-
-    public int compareTo(setStormConf_result other) {
-      if (!getClass().equals(other.getClass())) {
-        return getClass().getName().compareTo(other.getClass().getName());
-      }
-
-      int lastComparison = 0;
-      setStormConf_result typedOther = (setStormConf_result)other;
-
-      return 0;
-    }
-
-    public _Fields fieldForId(int fieldId) {
-      return _Fields.findByThriftId(fieldId);
-    }
-
-    public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
-      org.apache.thrift7.protocol.TField field;
-      iprot.readStructBegin();
-      while (true)
-      {
-        field = iprot.readFieldBegin();
-        if (field.type == org.apache.thrift7.protocol.TType.STOP) { 
-          break;
-        }
-        switch (field.id) {
-          default:
-            org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
-        }
-        iprot.readFieldEnd();
-      }
-      iprot.readStructEnd();
-      validate();
-    }
-
-    public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
-      oprot.writeStructBegin(STRUCT_DESC);
-
-      oprot.writeFieldStop();
-      oprot.writeStructEnd();
-    }
-
-    @Override
-    public String toString() {
-      StringBuilder sb = new StringBuilder("setStormConf_result(");
-      boolean first = true;
-
-      sb.append(")");
-      return sb.toString();
-    }
-
-    public void validate() throws org.apache.thrift7.TException {
-      // check for required fields
-    }
-
-    private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
-      try {
-        write(new org.apache.thrift7.protocol.TCompactProtocol(new org.apache.thrift7.transport.TIOStreamTransport(out)));
-      } catch (org.apache.thrift7.TException te) {
-        throw new java.io.IOException(te);
-      }
-    }
-
-    private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
-      try {
-        read(new org.apache.thrift7.protocol.TCompactProtocol(new org.apache.thrift7.transport.TIOStreamTransport(in)));
-      } catch (org.apache.thrift7.TException te) {
-        throw new java.io.IOException(te);
-      }
-    }
-
-  }
-
-  public static class addSupervisors_args implements org.apache.thrift7.TBase<addSupervisors_args, addSupervisors_args._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct("addSupervisors_args");
-
-    private static final org.apache.thrift7.protocol.TField NUMBER_FIELD_DESC = new org.apache.thrift7.protocol.TField("number", org.apache.thrift7.protocol.TType.I32, (short)1);
-
-    private int number; // required
-
-    /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
-    public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
-      NUMBER((short)1, "number");
-
-      private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
-
-      static {
-        for (_Fields field : EnumSet.allOf(_Fields.class)) {
-          byName.put(field.getFieldName(), field);
-        }
-      }
-
-      /**
-       * Find the _Fields constant that matches fieldId, or null if its not found.
-       */
-      public static _Fields findByThriftId(int fieldId) {
-        switch(fieldId) {
-          case 1: // NUMBER
-            return NUMBER;
-          default:
-            return null;
-        }
-      }
-
-      /**
-       * Find the _Fields constant that matches fieldId, throwing an exception
-       * if it is not found.
-       */
-      public static _Fields findByThriftIdOrThrow(int fieldId) {
-        _Fields fields = findByThriftId(fieldId);
-        if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
-        return fields;
-      }
-
-      /**
-       * Find the _Fields constant that matches name, or null if its not found.
-       */
-      public static _Fields findByName(String name) {
-        return byName.get(name);
-      }
-
-      private final short _thriftId;
-      private final String _fieldName;
-
-      _Fields(short thriftId, String fieldName) {
-        _thriftId = thriftId;
-        _fieldName = fieldName;
-      }
-
-      public short getThriftFieldId() {
-        return _thriftId;
-      }
-
-      public String getFieldName() {
-        return _fieldName;
-      }
-    }
-
-    // isset id assignments
-    private static final int __NUMBER_ISSET_ID = 0;
-    private BitSet __isset_bit_vector = new BitSet(1);
-
-    public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
-    static {
-      Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(_Fields.class);
-      tmpMap.put(_Fields.NUMBER, new org.apache.thrift7.meta_data.FieldMetaData("number", org.apache.thrift7.TFieldRequirementType.DEFAULT, 
-          new org.apache.thrift7.meta_data.FieldValueMetaData(org.apache.thrift7.protocol.TType.I32)));
-      metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(addSupervisors_args.class, metaDataMap);
-    }
-
-    public addSupervisors_args() {
-    }
-
-    public addSupervisors_args(
-      int number)
-    {
-      this();
-      this.number = number;
-      set_number_isSet(true);
-    }
-
-    /**
-     * Performs a deep copy on <i>other</i>.
-     */
-    public addSupervisors_args(addSupervisors_args other) {
-      __isset_bit_vector.clear();
-      __isset_bit_vector.or(other.__isset_bit_vector);
-      this.number = other.number;
-    }
-
-    public addSupervisors_args deepCopy() {
-      return new addSupervisors_args(this);
-    }
-
-    @Override
-    public void clear() {
-      set_number_isSet(false);
-      this.number = 0;
-    }
-
-    public int get_number() {
-      return this.number;
-    }
-
-    public void set_number(int number) {
-      this.number = number;
-      set_number_isSet(true);
-    }
-
-    public void unset_number() {
-      __isset_bit_vector.clear(__NUMBER_ISSET_ID);
-    }
-
-    /** Returns true if field number is set (has been assigned a value) and false otherwise */
-    public boolean is_set_number() {
-      return __isset_bit_vector.get(__NUMBER_ISSET_ID);
-    }
-
-    public void set_number_isSet(boolean value) {
-      __isset_bit_vector.set(__NUMBER_ISSET_ID, value);
-    }
-
-    public void setFieldValue(_Fields field, Object value) {
-      switch (field) {
-      case NUMBER:
-        if (value == null) {
-          unset_number();
-        } else {
-          set_number((Integer)value);
-        }
-        break;
-
-      }
-    }
-
-    public Object getFieldValue(_Fields field) {
-      switch (field) {
-      case NUMBER:
-        return Integer.valueOf(get_number());
-
-      }
-      throw new 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 IllegalArgumentException();
-      }
-
-      switch (field) {
-      case NUMBER:
-        return is_set_number();
-      }
-      throw new IllegalStateException();
-    }
-
-    @Override
-    public boolean equals(Object that) {
-      if (that == null)
-        return false;
-      if (that instanceof addSupervisors_args)
-        return this.equals((addSupervisors_args)that);
-      return false;
-    }
-
-    public boolean equals(addSupervisors_args that) {
-      if (that == null)
-        return false;
-
-      boolean this_present_number = true;
-      boolean that_present_number = true;
-      if (this_present_number || that_present_number) {
-        if (!(this_present_number && that_present_number))
-          return false;
-        if (this.number != that.number)
-          return false;
-      }
-
-      return true;
-    }
-
-    @Override
-    public int hashCode() {
-      HashCodeBuilder builder = new HashCodeBuilder();
-
-      boolean present_number = true;
-      builder.append(present_number);
-      if (present_number)
-        builder.append(number);
-
-      return builder.toHashCode();
-    }
-
-    public int compareTo(addSupervisors_args other) {
-      if (!getClass().equals(other.getClass())) {
-        return getClass().getName().compareTo(other.getClass().getName());
-      }
-
-      int lastComparison = 0;
-      addSupervisors_args typedOther = (addSupervisors_args)other;
-
-      lastComparison = Boolean.valueOf(is_set_number()).compareTo(typedOther.is_set_number());
-      if (lastComparison != 0) {
-        return lastComparison;
-      }
-      if (is_set_number()) {
-        lastComparison = org.apache.thrift7.TBaseHelper.compareTo(this.number, typedOther.number);
-        if (lastComparison != 0) {
-          return lastComparison;
-        }
-      }
-      return 0;
-    }
-
-    public _Fields fieldForId(int fieldId) {
-      return _Fields.findByThriftId(fieldId);
-    }
-
-    public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
-      org.apache.thrift7.protocol.TField field;
-      iprot.readStructBegin();
-      while (true)
-      {
-        field = iprot.readFieldBegin();
-        if (field.type == org.apache.thrift7.protocol.TType.STOP) { 
-          break;
-        }
-        switch (field.id) {
-          case 1: // NUMBER
-            if (field.type == org.apache.thrift7.protocol.TType.I32) {
-              this.number = iprot.readI32();
-              set_number_isSet(true);
-            } else { 
-              org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
-            }
-            break;
-          default:
-            org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
-        }
-        iprot.readFieldEnd();
-      }
-      iprot.readStructEnd();
-      validate();
-    }
-
-    public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
-      validate();
-
-      oprot.writeStructBegin(STRUCT_DESC);
-      oprot.writeFieldBegin(NUMBER_FIELD_DESC);
-      oprot.writeI32(this.number);
-      oprot.writeFieldEnd();
-      oprot.writeFieldStop();
-      oprot.writeStructEnd();
-    }
-
-    @Override
-    public String toString() {
-      StringBuilder sb = new StringBuilder("addSupervisors_args(");
-      boolean first = true;
-
-      sb.append("number:");
-      sb.append(this.number);
-      first = false;
-      sb.append(")");
-      return sb.toString();
-    }
-
-    public void validate() throws org.apache.thrift7.TException {
-      // check for required fields
-    }
-
-    private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
-      try {
-        write(new org.apache.thrift7.protocol.TCompactProtocol(new org.apache.thrift7.transport.TIOStreamTransport(out)));
-      } catch (org.apache.thrift7.TException te) {
-        throw new java.io.IOException(te);
-      }
-    }
-
-    private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
-      try {
-        // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
-        __isset_bit_vector = new BitSet(1);
-        read(new org.apache.thrift7.protocol.TCompactProtocol(new org.apache.thrift7.transport.TIOStreamTransport(in)));
-      } catch (org.apache.thrift7.TException te) {
-        throw new java.io.IOException(te);
-      }
-    }
-
-  }
-
-  public static class addSupervisors_result implements org.apache.thrift7.TBase<addSupervisors_result, addSupervisors_result._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct("addSupervisors_result");
-
-
-
-    /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
-    public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
-;
-
-      private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
-
-      static {
-        for (_Fields field : EnumSet.allOf(_Fields.class)) {
-          byName.put(field.getFieldName(), field);
-        }
-      }
-
-      /**
-       * Find the _Fields constant that matches fieldId, or null if its not found.
-       */
-      public static _Fields findByThriftId(int fieldId) {
-        switch(fieldId) {
-          default:
-            return null;
-        }
-      }
-
-      /**
-       * Find the _Fields constant that matches fieldId, throwing an exception
-       * if it is not found.
-       */
-      public static _Fields findByThriftIdOrThrow(int fieldId) {
-        _Fields fields = findByThriftId(fieldId);
-        if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
-        return fields;
-      }
-
-      /**
-       * Find the _Fields constant that matches name, or null if its not found.
-       */
-      public static _Fields findByName(String name) {
-        return byName.get(name);
-      }
-
-      private final short _thriftId;
-      private final String _fieldName;
-
-      _Fields(short thriftId, String fieldName) {
-        _thriftId = thriftId;
-        _fieldName = fieldName;
-      }
-
-      public short getThriftFieldId() {
-        return _thriftId;
-      }
-
-      public String getFieldName() {
-        return _fieldName;
-      }
-    }
-    public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
-    static {
-      Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(_Fields.class);
-      metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(addSupervisors_result.class, metaDataMap);
-    }
-
-    public addSupervisors_result() {
-    }
-
-    /**
-     * Performs a deep copy on <i>other</i>.
-     */
-    public addSupervisors_result(addSupervisors_result other) {
-    }
-
-    public addSupervisors_result deepCopy() {
-      return new addSupervisors_result(this);
-    }
-
-    @Override
-    public void clear() {
-    }
-
-    public void setFieldValue(_Fields field, Object value) {
-      switch (field) {
-      }
-    }
-
-    public Object getFieldValue(_Fields field) {
-      switch (field) {
-      }
-      throw new 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 IllegalArgumentException();
-      }
-
-      switch (field) {
-      }
-      throw new IllegalStateException();
-    }
-
-    @Override
-    public boolean equals(Object that) {
-      if (that == null)
-        return false;
-      if (that instanceof addSupervisors_result)
-        return this.equals((addSupervisors_result)that);
-      return false;
-    }
-
-    public boolean equals(addSupervisors_result that) {
-      if (that == null)
-        return false;
-
-      return true;
-    }
-
-    @Override
-    public int hashCode() {
-      HashCodeBuilder builder = new HashCodeBuilder();
-
-      return builder.toHashCode();
-    }
-
-    public int compareTo(addSupervisors_result other) {
-      if (!getClass().equals(other.getClass())) {
-        return getClass().getName().compareTo(other.getClass().getName());
-      }
-
-      int lastComparison = 0;
-      addSupervisors_result typedOther = (addSupervisors_result)other;
-
-      return 0;
-    }
-
-    public _Fields fieldForId(int fieldId) {
-      return _Fields.findByThriftId(fieldId);
-    }
-
-    public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
-      org.apache.thrift7.protocol.TField field;
-      iprot.readStructBegin();
-      while (true)
-      {
-        field = iprot.readFieldBegin();
-        if (field.type == org.apache.thrift7.protocol.TType.STOP) { 
-          break;
-        }
-        switch (field.id) {
-          default:
-            org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
-        }
-        iprot.readFieldEnd();
-      }
-      iprot.readStructEnd();
-      validate();
-    }
-
-    public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
-      oprot.writeStructBegin(STRUCT_DESC);
-
-      oprot.writeFieldStop();
-      oprot.writeStructEnd();
-    }
-
-    @Override
-    public String toString() {
-      StringBuilder sb = new StringBuilder("addSupervisors_result(");
-      boolean first = true;
-
-      sb.append(")");
-      return sb.toString();
-    }
-
-    public void validate() throws org.apache.thrift7.TException {
-      // check for required fields
-    }
-
-    private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
-      try {
-        write(new org.apache.thrift7.protocol.TCompactProtocol(new org.apache.thrift7.transport.TIOStreamTransport(out)));
-      } catch (org.apache.thrift7.TException te) {
-        throw new java.io.IOException(te);
-      }
-    }
-
-    private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
-      try {
-        read(new org.apache.thrift7.protocol.TCompactProtocol(new org.apache.thrift7.transport.TIOStreamTransport(in)));
-      } catch (org.apache.thrift7.TException te) {
-        throw new java.io.IOException(te);
-      }
-    }
-
-  }
-
-  public static class startNimbus_args implements org.apache.thrift7.TBase<startNimbus_args, startNimbus_args._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift7.protocol.TStruct STRUCT_DESC = new org.apache.thrift7.protocol.TStruct("startNimbus_args");
-
-
-
-    /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
-    public enum _Fields implements org.apache.thrift7.TFieldIdEnum {
-;
-
-      private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
-
-      static {
-        for (_Fields field : EnumSet.allOf(_Fields.class)) {
-          byName.put(field.getFieldName(), field);
-        }
-      }
-
-      /**
-       * Find the _Fields constant that matches fieldId, or null if its not found.
-       */
-      public static _Fields findByThriftId(int fieldId) {
-        switch(fieldId) {
-          default:
-            return null;
-        }
-      }
-
-      /**
-       * Find the _Fields constant that matches fieldId, throwing an exception
-       * if it is not found.
-       */
-      public static _Fields findByThriftIdOrThrow(int fieldId) {
-        _Fields fields = findByThriftId(fieldId);
-        if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
-        return fields;
-      }
-
-      /**
-       * Find the _Fields constant that matches name, or null if its not found.
-       */
-      public static _Fields findByName(String name) {
-        return byName.get(name);
-      }
-
-      private final short _thriftId;
-      private final String _fieldName;
-
-      _Fields(short thriftId, String fieldName) {
-        _thriftId = thriftId;
-        _fieldName = fieldName;
-      }
-
-      public short getThriftFieldId() {
-        return _thriftId;
-      }
-
-      public String getFieldName() {
-        return _fieldName;
-      }
-    }
-    public static final Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> metaDataMap;
-    static {
-      Map<_Fields, org.apache.thrift7.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift7.meta_data.FieldMetaData>(_Fields.class);
-      metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift7.meta_data.FieldMetaData.addStructMetaDataMap(startNimbus_args.class, metaDataMap);
-    }
-
-    public startNimbus_args() {
-    }
-
-    /**
-     * Performs a deep copy on <i>other</i>.
-     */
-    public startNimbus_args(startNimbus_args other) {
-    }
-
-    public startNimbus_args deepCopy() {
-      return new startNimbus_args(this);
-    }
-
-    @Override
-    public void clear() {
-    }
-
-    public void setFieldValue(_Fields field, Object value) {
-      switch (field) {
-      }
-    }
-
-    public Object getFieldValue(_Fields field) {
-      switch (field) {
-      }
-      throw new 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 IllegalArgumentException();
-      }
-
-      switch (field) {
-      }
-      throw new IllegalStateException();
-    }
-
-    @Override
-    public boolean equals(Object that) {
-      if (that == null)
-        return false;
-      if (that instanceof startNimbus_args)
-        return this.equals((startNimbus_args)that);
-      return false;
-    }
-
-    public boolean equals(startNimbus_args that) {
-      if (that == null)
-        return false;
-
-      return true;
-    }
-
-    @Override
-    public int hashCode() {
-      HashCodeBuilder builder = new HashCodeBuilder();
-
-      return builder.toHashCode();
-    }
-
-    public int compareTo(startNimbus_args other) {
-      if (!getClass().equals(other.getClass())) {
-        return getClass().getName().compareTo(other.getClass().getName());
-      }
-
-      int lastComparison = 0;
-      startNimbus_args typedOther = (startNimbus_args)other;
-
-      return 0;
-    }
-
-    public _Fields fieldForId(int fieldId) {
-      return _Fields.findByThriftId(fieldId);
-    }
-
-    public void read(org.apache.thrift7.protocol.TProtocol iprot) throws org.apache.thrift7.TException {
-      org.apache.thrift7.protocol.TField field;
-      iprot.readStructBegin();
-      while (true)
-      {
-        field = iprot.readFieldBegin();
-        if (field.type == org.apache.thrift7.protocol.TType.STOP) { 
-          break;
-        }
-        switch (field.id) {
-          default:
-            org.apache.thrift7.protocol.TProtocolUtil.skip(iprot, field.type);
-        }
-        iprot.readFieldEnd();
-      }
-      iprot.readStructEnd();
-      validate();
-    }
-
-    public void write(org.apache.thrift7.protocol.TProtocol oprot) throws org.apache.thrift7.TException {
-      validate();
-
-      oprot.writeStructBegin(STRUCT_DESC);
-      oprot.writeFieldStop();
-      oprot.writeStructEnd();
-    }
-
-    @Override
-    public String toString() {
-      StringBuilder sb = new StringBuilder("startNimbus_args(");
-      boolean first = true;
-
-      sb.append(")");
-      return sb.toString();
-    }
-
-    public void validate() throws org.apache.thrift7.TException {
-      // check for required fields
-    }
-
-    private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
-      try {
-        write(new org.apache.thrift7.protocol.TCompactProtocol(new org.apache.thrift7.transport.TIOStreamTransport(out)));
-      } catch (org.apache.thrift7.TException te) {
-        throw new java.io.IOException(te);
-      }
-    }
-
-    private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
-      try {
-        read(new org.apache.thrift7.protocol.TCompactProtocol(new org.apache.thrift7.transport.TIOStreamTransport(in)));
-      } catch (org.apache.thrift7.TException te) {
-        throw new java.io.IOException(te);
-      }
-    }
-
-  }
-
-  public static class startNimbus_result implements org.apache.thrift7.TB

<TRUNCATED>