Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
Autogenerated by Thrift Compiler (0.7.0) DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
   
   package com.splout.db.thrift;
   
   import java.util.List;
   import java.util.ArrayList;
  import java.util.Map;
  import java.util.HashMap;
  import java.util.EnumMap;
  import java.util.Set;
  import java.util.HashSet;
  import java.util.EnumSet;
  import java.util.BitSet;
  import java.util.Arrays;
  import org.slf4j.Logger;
  
  public class DNodeService {
  
    public interface Iface {
  
      public String sqlQuery(String tablespacelong versionint partitionString querythrows DNodeException, org.apache.thrift.TException;
  
      public String deleteOldVersions(List<TablespaceVersionversionsthrows DNodeException, org.apache.thrift.TException;
  
      public String deploy(List<DeployActiondeployActionslong versionthrows DNodeException, org.apache.thrift.TException;
  
      public String rollback(List<RollbackActionrollbackActionsString distributedBarrierthrows DNodeException, org.apache.thrift.TException;
  
      public String status() throws DNodeException, org.apache.thrift.TException;
  
      public String abortDeploy(long versionthrows DNodeException, org.apache.thrift.TException;
  
      public String testCommand(String commandthrows DNodeException, org.apache.thrift.TException;
  
    }
  
    public interface AsyncIface {
  
      public void sqlQuery(String tablespacelong versionint partitionString query, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.sqlQuery_callresultHandlerthrows org.apache.thrift.TException;
  
      public void deleteOldVersions(List<TablespaceVersionversions, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteOldVersions_callresultHandlerthrows org.apache.thrift.TException;
  
      public void deploy(List<DeployActiondeployActionslong version, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deploy_callresultHandlerthrows org.apache.thrift.TException;
  
      public void rollback(List<RollbackActionrollbackActionsString distributedBarrier, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.rollback_callresultHandlerthrows org.apache.thrift.TException;
  
      public void status(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.status_callresultHandlerthrows org.apache.thrift.TException;
  
      public void abortDeploy(long version, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.abortDeploy_callresultHandlerthrows org.apache.thrift.TException;
  
      public void testCommand(String command, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.testCommand_callresultHandlerthrows org.apache.thrift.TException;
  
    }
  
    public static class Client extends org.apache.thrift.TServiceClient implements Iface {
      public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> {
        public Factory() {}
        public Client getClient(org.apache.thrift.protocol.TProtocol prot) {
          return new Client(prot);
        }
        public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
          return new Client(iprotoprot);
        }
      }
  
      public Client(org.apache.thrift.protocol.TProtocol prot)
      {
        super(protprot);
      }
  
      public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
        super(iprotoprot);
      }
  
      public String sqlQuery(String tablespacelong versionint partitionString querythrows DNodeException, org.apache.thrift.TException
      {
        send_sqlQuery(tablespaceversionpartitionquery);
        return recv_sqlQuery();
      }
  
      public void send_sqlQuery(String tablespacelong versionint partitionString querythrows org.apache.thrift.TException
      {
        sqlQuery_args args = new sqlQuery_args();
        args.setTablespace(tablespace);
        args.setVersion(version);
        args.setPartition(partition);
        args.setQuery(query);
        sendBase("sqlQuery"args);
      }
  
      public String recv_sqlQuery() throws DNodeException, org.apache.thrift.TException
      {
        sqlQuery_result result = new sqlQuery_result();
       receiveBase(result"sqlQuery");
       if (result.isSetSuccess()) {
         return result.success;
       }
       if (result.excep != null) {
         throw result.excep;
       }
       throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "sqlQuery failed: unknown result");
     }
 
     public String deleteOldVersions(List<TablespaceVersionversionsthrows DNodeException, org.apache.thrift.TException
     {
       send_deleteOldVersions(versions);
       return recv_deleteOldVersions();
     }
 
     public void send_deleteOldVersions(List<TablespaceVersionversionsthrows org.apache.thrift.TException
     {
       deleteOldVersions_args args = new deleteOldVersions_args();
       args.setVersions(versions);
       sendBase("deleteOldVersions"args);
     }
 
     public String recv_deleteOldVersions() throws DNodeException, org.apache.thrift.TException
     {
       deleteOldVersions_result result = new deleteOldVersions_result();
       receiveBase(result"deleteOldVersions");
       if (result.isSetSuccess()) {
         return result.success;
       }
       if (result.excep != null) {
         throw result.excep;
       }
       throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deleteOldVersions failed: unknown result");
     }
 
     public String deploy(List<DeployActiondeployActionslong versionthrows DNodeException, org.apache.thrift.TException
     {
       send_deploy(deployActionsversion);
       return recv_deploy();
     }
 
     public void send_deploy(List<DeployActiondeployActionslong versionthrows org.apache.thrift.TException
     {
       deploy_args args = new deploy_args();
       args.setDeployActions(deployActions);
       args.setVersion(version);
       sendBase("deploy"args);
     }
 
     public String recv_deploy() throws DNodeException, org.apache.thrift.TException
     {
       deploy_result result = new deploy_result();
       receiveBase(result"deploy");
       if (result.isSetSuccess()) {
         return result.success;
       }
       if (result.excep != null) {
         throw result.excep;
       }
       throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deploy failed: unknown result");
     }
 
     public String rollback(List<RollbackActionrollbackActionsString distributedBarrierthrows DNodeException, org.apache.thrift.TException
     {
       send_rollback(rollbackActionsdistributedBarrier);
       return recv_rollback();
     }
 
     public void send_rollback(List<RollbackActionrollbackActionsString distributedBarrierthrows org.apache.thrift.TException
     {
       rollback_args args = new rollback_args();
       args.setRollbackActions(rollbackActions);
       args.setDistributedBarrier(distributedBarrier);
       sendBase("rollback"args);
     }
 
     public String recv_rollback() throws DNodeException, org.apache.thrift.TException
     {
       rollback_result result = new rollback_result();
       receiveBase(result"rollback");
       if (result.isSetSuccess()) {
         return result.success;
       }
       if (result.excep != null) {
         throw result.excep;
       }
       throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "rollback failed: unknown result");
     }
 
     public String status() throws DNodeException, org.apache.thrift.TException
     {
       send_status();
       return recv_status();
     }
 
     public void send_status() throws org.apache.thrift.TException
     {
       status_args args = new status_args();
       sendBase("status"args);
     }
 
     public String recv_status() throws DNodeException, org.apache.thrift.TException
     {
       status_result result = new status_result();
       receiveBase(result"status");
       if (result.isSetSuccess()) {
         return result.success;
       }
       if (result.excep != null) {
         throw result.excep;
       }
       throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "status failed: unknown result");
     }
 
     public String abortDeploy(long versionthrows DNodeException, org.apache.thrift.TException
     {
       send_abortDeploy(version);
       return recv_abortDeploy();
     }
 
     public void send_abortDeploy(long versionthrows org.apache.thrift.TException
     {
       abortDeploy_args args = new abortDeploy_args();
       args.setVersion(version);
       sendBase("abortDeploy"args);
     }
 
     public String recv_abortDeploy() throws DNodeException, org.apache.thrift.TException
     {
       abortDeploy_result result = new abortDeploy_result();
       receiveBase(result"abortDeploy");
       if (result.isSetSuccess()) {
         return result.success;
       }
       if (result.excep != null) {
         throw result.excep;
       }
       throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "abortDeploy failed: unknown result");
     }
 
     public String testCommand(String commandthrows DNodeException, org.apache.thrift.TException
     {
       send_testCommand(command);
       return recv_testCommand();
     }
 
     public void send_testCommand(String commandthrows org.apache.thrift.TException
     {
       testCommand_args args = new testCommand_args();
       args.setCommand(command);
       sendBase("testCommand"args);
     }
 
     public String recv_testCommand() throws DNodeException, org.apache.thrift.TException
     {
       testCommand_result result = new testCommand_result();
       receiveBase(result"testCommand");
       if (result.isSetSuccess()) {
         return result.success;
       }
       if (result.excep != null) {
         throw result.excep;
       }
       throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "testCommand failed: unknown result");
     }
 
   }
   public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface {
     public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {
       private org.apache.thrift.async.TAsyncClientManager clientManager;
       private org.apache.thrift.protocol.TProtocolFactory protocolFactory;
       public Factory(org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) {
         this. = clientManager;
         this. = protocolFactory;
       }
       public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) {
         return new AsyncClient(transport);
       }
     }
 
     public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) {
       super(protocolFactoryclientManagertransport);
     }
 
     public void sqlQuery(String tablespacelong versionint partitionString query, org.apache.thrift.async.AsyncMethodCallback<sqlQuery_callresultHandlerthrows org.apache.thrift.TException {
       checkReady();
       sqlQuery_call method_call = new sqlQuery_call(tablespaceversionpartitionqueryresultHandlerthis, ___protocolFactory, ___transport);
       this. = method_call;
       ___manager.call(method_call);
     }
 
     public static class sqlQuery_call extends org.apache.thrift.async.TAsyncMethodCall {
       private String tablespace;
       private long version;
       private int partition;
       private String query;
       public sqlQuery_call(String tablespacelong versionint partitionString query, org.apache.thrift.async.AsyncMethodCallback<sqlQuery_callresultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transportthrows org.apache.thrift.TException {
         super(clientprotocolFactorytransportresultHandlerfalse);
         this. = tablespace;
         this. = version;
         this. = partition;
         this. = query;
       }
 
       public void write_args(org.apache.thrift.protocol.TProtocol protthrows org.apache.thrift.TException {
         prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("sqlQuery", org.apache.thrift.protocol.TMessageType.CALL, 0));
         sqlQuery_args args = new sqlQuery_args();
         args.setTablespace();
         args.setVersion();
         args.setPartition();
         args.setQuery();
         args.write(prot);
         prot.writeMessageEnd();
       }
 
       public String getResult() throws DNodeException, org.apache.thrift.TException {
         if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
           throw new IllegalStateException("Method call not finished!");
         }
         org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
         org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
         return (new Client(prot)).recv_sqlQuery();
       }
     }
 
     public void deleteOldVersions(List<TablespaceVersionversions, org.apache.thrift.async.AsyncMethodCallback<deleteOldVersions_callresultHandlerthrows org.apache.thrift.TException {
       checkReady();
       deleteOldVersions_call method_call = new deleteOldVersions_call(versionsresultHandlerthis, ___protocolFactory, ___transport);
       this. = method_call;
       ___manager.call(method_call);
     }
 
     public static class deleteOldVersions_call extends org.apache.thrift.async.TAsyncMethodCall {
       private List<TablespaceVersionversions;
       public deleteOldVersions_call(List<TablespaceVersionversions, org.apache.thrift.async.AsyncMethodCallback<deleteOldVersions_callresultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transportthrows org.apache.thrift.TException {
         super(clientprotocolFactorytransportresultHandlerfalse);
         this. = versions;
       }
 
       public void write_args(org.apache.thrift.protocol.TProtocol protthrows org.apache.thrift.TException {
         prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteOldVersions", org.apache.thrift.protocol.TMessageType.CALL, 0));
         deleteOldVersions_args args = new deleteOldVersions_args();
         args.setVersions();
         args.write(prot);
         prot.writeMessageEnd();
       }
 
       public String getResult() throws DNodeException, org.apache.thrift.TException {
         if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
           throw new IllegalStateException("Method call not finished!");
         }
         org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
         org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
         return (new Client(prot)).recv_deleteOldVersions();
       }
     }
 
     public void deploy(List<DeployActiondeployActionslong version, org.apache.thrift.async.AsyncMethodCallback<deploy_callresultHandlerthrows org.apache.thrift.TException {
       checkReady();
       deploy_call method_call = new deploy_call(deployActionsversionresultHandlerthis, ___protocolFactory, ___transport);
       this. = method_call;
       ___manager.call(method_call);
     }
 
     public static class deploy_call extends org.apache.thrift.async.TAsyncMethodCall {
       private List<DeployActiondeployActions;
       private long version;
       public deploy_call(List<DeployActiondeployActionslong version, org.apache.thrift.async.AsyncMethodCallback<deploy_callresultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transportthrows org.apache.thrift.TException {
         super(clientprotocolFactorytransportresultHandlerfalse);
         this. = deployActions;
         this. = version;
       }
 
       public void write_args(org.apache.thrift.protocol.TProtocol protthrows org.apache.thrift.TException {
         prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deploy", org.apache.thrift.protocol.TMessageType.CALL, 0));
         deploy_args args = new deploy_args();
         args.setDeployActions();
         args.setVersion();
         args.write(prot);
         prot.writeMessageEnd();
       }
 
       public String getResult() throws DNodeException, org.apache.thrift.TException {
         if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
           throw new IllegalStateException("Method call not finished!");
         }
         org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
         org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
         return (new Client(prot)).recv_deploy();
       }
     }
 
     public void rollback(List<RollbackActionrollbackActionsString distributedBarrier, org.apache.thrift.async.AsyncMethodCallback<rollback_callresultHandlerthrows org.apache.thrift.TException {
       checkReady();
       rollback_call method_call = new rollback_call(rollbackActionsdistributedBarrierresultHandlerthis, ___protocolFactory, ___transport);
       this. = method_call;
       ___manager.call(method_call);
     }
 
     public static class rollback_call extends org.apache.thrift.async.TAsyncMethodCall {
       private List<RollbackActionrollbackActions;
       private String distributedBarrier;
       public rollback_call(List<RollbackActionrollbackActionsString distributedBarrier, org.apache.thrift.async.AsyncMethodCallback<rollback_callresultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transportthrows org.apache.thrift.TException {
         super(clientprotocolFactorytransportresultHandlerfalse);
         this. = rollbackActions;
         this. = distributedBarrier;
       }
 
       public void write_args(org.apache.thrift.protocol.TProtocol protthrows org.apache.thrift.TException {
         prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("rollback", org.apache.thrift.protocol.TMessageType.CALL, 0));
         rollback_args args = new rollback_args();
         args.setRollbackActions();
         args.write(prot);
         prot.writeMessageEnd();
       }
 
       public String getResult() throws DNodeException, org.apache.thrift.TException {
         if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
           throw new IllegalStateException("Method call not finished!");
         }
         org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
         org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
         return (new Client(prot)).recv_rollback();
       }
     }
 
     public void status(org.apache.thrift.async.AsyncMethodCallback<status_callresultHandlerthrows org.apache.thrift.TException {
       checkReady();
       status_call method_call = new status_call(resultHandlerthis, ___protocolFactory, ___transport);
       this. = method_call;
       ___manager.call(method_call);
     }
 
     public static class status_call extends org.apache.thrift.async.TAsyncMethodCall {
       public status_call(org.apache.thrift.async.AsyncMethodCallback<status_callresultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transportthrows org.apache.thrift.TException {
         super(clientprotocolFactorytransportresultHandlerfalse);
       }
 
       public void write_args(org.apache.thrift.protocol.TProtocol protthrows org.apache.thrift.TException {
         prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("status", org.apache.thrift.protocol.TMessageType.CALL, 0));
         status_args args = new status_args();
         args.write(prot);
         prot.writeMessageEnd();
       }
 
       public String getResult() throws DNodeException, org.apache.thrift.TException {
         if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
           throw new IllegalStateException("Method call not finished!");
         }
         org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
         org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
         return (new Client(prot)).recv_status();
       }
     }
 
     public void abortDeploy(long version, org.apache.thrift.async.AsyncMethodCallback<abortDeploy_callresultHandlerthrows org.apache.thrift.TException {
       checkReady();
       abortDeploy_call method_call = new abortDeploy_call(versionresultHandlerthis, ___protocolFactory, ___transport);
       this. = method_call;
       ___manager.call(method_call);
     }
 
     public static class abortDeploy_call extends org.apache.thrift.async.TAsyncMethodCall {
       private long version;
       public abortDeploy_call(long version, org.apache.thrift.async.AsyncMethodCallback<abortDeploy_callresultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transportthrows org.apache.thrift.TException {
         super(clientprotocolFactorytransportresultHandlerfalse);
         this. = version;
       }
 
       public void write_args(org.apache.thrift.protocol.TProtocol protthrows org.apache.thrift.TException {
         prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("abortDeploy", org.apache.thrift.protocol.TMessageType.CALL, 0));
         abortDeploy_args args = new abortDeploy_args();
         args.setVersion();
         args.write(prot);
         prot.writeMessageEnd();
       }
 
       public String getResult() throws DNodeException, org.apache.thrift.TException {
         if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
           throw new IllegalStateException("Method call not finished!");
         }
         org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
         org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
         return (new Client(prot)).recv_abortDeploy();
       }
     }
 
     public void testCommand(String command, org.apache.thrift.async.AsyncMethodCallback<testCommand_callresultHandlerthrows org.apache.thrift.TException {
       checkReady();
       testCommand_call method_call = new testCommand_call(commandresultHandlerthis, ___protocolFactory, ___transport);
       this. = method_call;
       ___manager.call(method_call);
     }
 
     public static class testCommand_call extends org.apache.thrift.async.TAsyncMethodCall {
       private String command;
       public testCommand_call(String command, org.apache.thrift.async.AsyncMethodCallback<testCommand_callresultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transportthrows org.apache.thrift.TException {
         super(clientprotocolFactorytransportresultHandlerfalse);
         this. = command;
       }
 
       public void write_args(org.apache.thrift.protocol.TProtocol protthrows org.apache.thrift.TException {
         prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("testCommand", org.apache.thrift.protocol.TMessageType.CALL, 0));
         testCommand_args args = new testCommand_args();
         args.setCommand();
         args.write(prot);
         prot.writeMessageEnd();
       }
 
       public String getResult() throws DNodeException, org.apache.thrift.TException {
         if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
           throw new IllegalStateException("Method call not finished!");
         }
         org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
         org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
         return (new Client(prot)).recv_testCommand();
       }
     }
 
   }
 
   public static class Processor<I extends Ifaceextends org.apache.thrift.TBaseProcessor implements org.apache.thrift.TProcessor {
     private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName());
     public Processor(I iface) {
       super(iface, getProcessMap(new HashMap<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>()));
     }
 
     protected Processor(I ifaceMap<String,  org.apache.thrift.ProcessFunction<I, ? extends  org.apache.thrift.TBase>> processMap) {
       super(iface, getProcessMap(processMap));
     }
 
     private static <I extends IfaceMap<String,  org.apache.thrift.ProcessFunction<I, ? extends  org.apache.thrift.TBase>> getProcessMap(Map<String,  org.apache.thrift.ProcessFunction<I, ? extends  org.apache.thrift.TBase>> processMap) {
       processMap.put("sqlQuery"new sqlQuery());
       processMap.put("deleteOldVersions"new deleteOldVersions());
       processMap.put("deploy"new deploy());
       processMap.put("rollback"new rollback());
       processMap.put("status"new status());
       processMap.put("abortDeploy"new abortDeploy());
       processMap.put("testCommand"new testCommand());
       return processMap;
     }
 
     private static class sqlQuery<I extends Ifaceextends org.apache.thrift.ProcessFunction<I, sqlQuery_args> {
       public sqlQuery() {
         super("sqlQuery");
       }
 
       protected sqlQuery_args getEmptyArgsInstance() {
         return new sqlQuery_args();
       }
 
       protected sqlQuery_result getResult(I ifacesqlQuery_args argsthrows org.apache.thrift.TException {
         sqlQuery_result result = new sqlQuery_result();
         try {
           result.success = iface.sqlQuery(args.tablespaceargs.versionargs.partitionargs.query);
         } catch (DNodeException excep) {
           result.excep = excep;
         }
         return result;
       }
     }
 
     private static class deleteOldVersions<I extends Ifaceextends org.apache.thrift.ProcessFunction<I, deleteOldVersions_args> {
       public deleteOldVersions() {
         super("deleteOldVersions");
       }
 
       protected deleteOldVersions_args getEmptyArgsInstance() {
         return new deleteOldVersions_args();
       }
 
       protected deleteOldVersions_result getResult(I ifacedeleteOldVersions_args argsthrows org.apache.thrift.TException {
         deleteOldVersions_result result = new deleteOldVersions_result();
         try {
           result.success = iface.deleteOldVersions(args.versions);
         } catch (DNodeException excep) {
           result.excep = excep;
         }
         return result;
       }
     }
 
     private static class deploy<I extends Ifaceextends org.apache.thrift.ProcessFunction<I, deploy_args> {
       public deploy() {
         super("deploy");
       }
 
       protected deploy_args getEmptyArgsInstance() {
         return new deploy_args();
       }
 
       protected deploy_result getResult(I ifacedeploy_args argsthrows org.apache.thrift.TException {
         deploy_result result = new deploy_result();
         try {
           result.success = iface.deploy(args.deployActionsargs.version);
         } catch (DNodeException excep) {
           result.excep = excep;
         }
         return result;
       }
     }
 
     private static class rollback<I extends Ifaceextends org.apache.thrift.ProcessFunction<I, rollback_args> {
       public rollback() {
         super("rollback");
       }
 
       protected rollback_args getEmptyArgsInstance() {
         return new rollback_args();
       }
 
       protected rollback_result getResult(I ifacerollback_args argsthrows org.apache.thrift.TException {
         rollback_result result = new rollback_result();
         try {
           result.success = iface.rollback(args.rollbackActionsargs.distributedBarrier);
         } catch (DNodeException excep) {
           result.excep = excep;
         }
         return result;
       }
     }
 
     private static class status<I extends Ifaceextends org.apache.thrift.ProcessFunction<I, status_args> {
       public status() {
         super("status");
       }
 
       protected status_args getEmptyArgsInstance() {
         return new status_args();
       }
 
       protected status_result getResult(I ifacestatus_args argsthrows org.apache.thrift.TException {
         status_result result = new status_result();
         try {
           result.success = iface.status();
         } catch (DNodeException excep) {
           result.excep = excep;
         }
         return result;
       }
     }
 
     private static class abortDeploy<I extends Ifaceextends org.apache.thrift.ProcessFunction<I, abortDeploy_args> {
       public abortDeploy() {
         super("abortDeploy");
       }
 
       protected abortDeploy_args getEmptyArgsInstance() {
         return new abortDeploy_args();
       }
 
       protected abortDeploy_result getResult(I ifaceabortDeploy_args argsthrows org.apache.thrift.TException {
         abortDeploy_result result = new abortDeploy_result();
         try {
           result.success = iface.abortDeploy(args.version);
         } catch (DNodeException excep) {
           result.excep = excep;
         }
         return result;
       }
     }
 
     private static class testCommand<I extends Ifaceextends org.apache.thrift.ProcessFunction<I, testCommand_args> {
       public testCommand() {
         super("testCommand");
       }
 
       protected testCommand_args getEmptyArgsInstance() {
         return new testCommand_args();
       }
 
       protected testCommand_result getResult(I ifacetestCommand_args argsthrows org.apache.thrift.TException {
         testCommand_result result = new testCommand_result();
         try {
           result.success = iface.testCommand(args.command);
         } catch (DNodeException excep) {
           result.excep = excep;
         }
         return result;
       }
     }
 
   }
 
   public static class sqlQuery_args implements org.apache.thrift.TBase<sqlQuery_argssqlQuery_args._Fields>, java.io.SerializableCloneable   {
     private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("sqlQuery_args");
 
     private static final org.apache.thrift.protocol.TField TABLESPACE_FIELD_DESC = new org.apache.thrift.protocol.TField("tablespace", org.apache.thrift.protocol.TType.STRING, (short)1);
     private static final org.apache.thrift.protocol.TField VERSION_FIELD_DESC = new org.apache.thrift.protocol.TField("version", org.apache.thrift.protocol.TType.I64, (short)2);
     private static final org.apache.thrift.protocol.TField PARTITION_FIELD_DESC = new org.apache.thrift.protocol.TField("partition", org.apache.thrift.protocol.TType.I32, (short)3);
     private static final org.apache.thrift.protocol.TField QUERY_FIELD_DESC = new org.apache.thrift.protocol.TField("query", org.apache.thrift.protocol.TType.STRING, (short)4);
 
     public String tablespace// required
     public long version// required
     public int partition// required
     public String query// required
 
    
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
 
     public enum _Fields implements org.apache.thrift.TFieldIdEnum {
       TABLESPACE((short)1, "tablespace"),
       VERSION((short)2, "version"),
       PARTITION((short)3, "partition"),
       QUERY((short)4, "query");
 
       private static final Map<String_FieldsbyName = new HashMap<String_Fields>();
 
       static {
         for (_Fields field : EnumSet.allOf(_Fields.class)) {
           .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: // TABLESPACE
             return ;
           case 2: // VERSION
             return ;
           case 3: // PARTITION
             return ;
           case 4: // QUERY
             return ;
           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 == nullthrow 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 .get(name);
       }
 
       private final short _thriftId;
       private final String _fieldName;
 
       _Fields(short thriftIdString fieldName) {
          = thriftId;
          = fieldName;
       }
 
       public short getThriftFieldId() {
         return ;
       }
 
       public String getFieldName() {
         return ;
       }
     }
 
     // isset id assignments
     private static final int __VERSION_ISSET_ID = 0;
     private static final int __PARTITION_ISSET_ID = 1;
     private BitSet __isset_bit_vector = new BitSet(2);
 
     public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
     static {
       Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
       tmpMap.put(.new org.apache.thrift.meta_data.FieldMetaData("tablespace", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
       tmpMap.put(.new org.apache.thrift.meta_data.FieldMetaData("version", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
       tmpMap.put(.new org.apache.thrift.meta_data.FieldMetaData("partition", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
       tmpMap.put(.new org.apache.thrift.meta_data.FieldMetaData("query", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
        = Collections.unmodifiableMap(tmpMap);
       org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(sqlQuery_args.class);
     }
 
     public sqlQuery_args() {
     }
 
     public sqlQuery_args(
       String tablespace,
       long version,
       int partition,
       String query)
     {
       this();
       this. = tablespace;
       this. = version;
       setVersionIsSet(true);
       this. = partition;
       setPartitionIsSet(true);
       this. = query;
     }

    
Performs a deep copy on other.
 
     public sqlQuery_args(sqlQuery_args other) {
       .clear();
       .or(other.__isset_bit_vector);
       if (other.isSetTablespace()) {
         this. = other.tablespace;
       }
       this. = other.version;
       this. = other.partition;
       if (other.isSetQuery()) {
         this. = other.query;
       }
     }
 
     public sqlQuery_args deepCopy() {
       return new sqlQuery_args(this);
     }
 
     @Override
     public void clear() {
       this. = null;
       setVersionIsSet(false);
       this. = 0;
       setPartitionIsSet(false);
       this. = 0;
       this. = null;
     }
 
     public String getTablespace() {
       return this.;
     }
 
     public sqlQuery_args setTablespace(String tablespace) {
       this. = tablespace;
       return this;
     }
 
     public void unsetTablespace() {
       this. = null;
     }

    
Returns true if field tablespace is set (has been assigned a value) and false otherwise
 
     public boolean isSetTablespace() {
       return this. != null;
     }
 
     public void setTablespaceIsSet(boolean value) {
       if (!value) {
         this. = null;
       }
     }
 
     public long getVersion() {
       return this.;
     }
 
     public sqlQuery_args setVersion(long version) {
       this. = version;
       setVersionIsSet(true);
       return this;
     }
 
     public void unsetVersion() {
     }

    
Returns true if field version is set (has been assigned a value) and false otherwise
 
     public boolean isSetVersion() {
     }
 
     public void setVersionIsSet(boolean value) {
     }
 
     public int getPartition() {
       return this.;
     }
 
     public sqlQuery_args setPartition(int partition) {
       this. = partition;
       setPartitionIsSet(true);
       return this;
     }
 
     public void unsetPartition() {
     }

    
Returns true if field partition is set (has been assigned a value) and false otherwise
 
     public boolean isSetPartition() {
     }
 
     public void setPartitionIsSet(boolean value) {
     }
 
     public String getQuery() {
       return this.;
     }
 
     public sqlQuery_args setQuery(String query) {
       this. = query;
       return this;
     }
 
     public void unsetQuery() {
       this. = null;
     }

    
Returns true if field query is set (has been assigned a value) and false otherwise
 
     public boolean isSetQuery() {
       return this. != null;
     }
 
     public void setQueryIsSet(boolean value) {
       if (!value) {
         this. = null;
       }
     }
 
     public void setFieldValue(_Fields fieldObject value) {
       switch (field) {
       case :
         if (value == null) {
           unsetTablespace();
         } else {
           setTablespace((String)value);
         }
         break;
 
       case :
         if (value == null) {
           unsetVersion();
         } else {
           setVersion((Long)value);
         }
         break;
 
       case :
         if (value == null) {
           unsetPartition();
         } else {
           setPartition((Integer)value);
         }
         break;
 
       case :
         if (value == null) {
           unsetQuery();
         } else {
           setQuery((String)value);
         }
         break;
 
       }
     }
 
     public Object getFieldValue(_Fields field) {
       switch (field) {
       case :
         return getTablespace();
 
       case :
         return Long.valueOf(getVersion());
 
       case :
         return Integer.valueOf(getPartition());
 
       case :
         return getQuery();
 
       }
       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 :
         return isSetTablespace();
       case :
         return isSetVersion();
       case :
         return isSetPartition();
       case :
         return isSetQuery();
       }
       throw new IllegalStateException();
    }
    @Override
    public boolean equals(Object that) {
      if (that == null)
        return false;
      if (that instanceof sqlQuery_args)
        return this.equals((sqlQuery_args)that);
      return false;
    }
    public boolean equals(sqlQuery_args that) {
      if (that == null)
        return false;
      boolean this_present_tablespace = true && this.isSetTablespace();
      boolean that_present_tablespace = true && that.isSetTablespace();
      if (this_present_tablespace || that_present_tablespace) {
        if (!(this_present_tablespace && that_present_tablespace))
          return false;
        if (!this..equals(that.tablespace))
          return false;
      }
      boolean this_present_version = true;
      boolean that_present_version = true;
      if (this_present_version || that_present_version) {
        if (!(this_present_version && that_present_version))
          return false;
        if (this. != that.version)
          return false;
      }
      boolean this_present_partition = true;
      boolean that_present_partition = true;
      if (this_present_partition || that_present_partition) {
        if (!(this_present_partition && that_present_partition))
          return false;
        if (this. != that.partition)
          return false;
      }
      boolean this_present_query = true && this.isSetQuery();
      boolean that_present_query = true && that.isSetQuery();
      if (this_present_query || that_present_query) {
        if (!(this_present_query && that_present_query))
          return false;
        if (!this..equals(that.query))
          return false;
      }
      return true;
    }
    @Override
    public int hashCode() {
      return 0;
    }
    public int compareTo(sqlQuery_args other) {
      if (!getClass().equals(other.getClass())) {
        return getClass().getName().compareTo(other.getClass().getName());
      }
      int lastComparison = 0;
      sqlQuery_args typedOther = (sqlQuery_args)other;
      lastComparison = Boolean.valueOf(isSetTablespace()).compareTo(typedOther.isSetTablespace());
      if (lastComparison != 0) {
        return lastComparison;
      }
      if (isSetTablespace()) {
        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.typedOther.tablespace);
       &nbs