incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [5/8] Removed the session parameter from a few methods in the interface. Now the query statuses are tracked at the server level instead of inside each session.
Date Sun, 03 Mar 2013 19:37:03 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/cf92e0ff/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java b/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
index d27a94b..21c1414 100644
--- a/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
+++ b/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
@@ -235,48 +235,42 @@ public class Blur {
 
     /**
      * Cancels a query that is executing within the given session.
-     * @param session the Session.
      * @param server the server name to receive the call, null for all servers.
      * @param id the id of the query, (QueryArgs.id).
      * 
-     * @param session
      * @param server
      * @param id
      */
-    public void cancelQuery(Session session, String server, String id) throws BlurException, org.apache.thrift.TException;
+    public void cancelQuery(String server, String id) throws BlurException, org.apache.thrift.TException;
 
     /**
      * Returns a list of the query ids of queries that have recently been executed within the given session.
-     * @param session the Session.
      * @param server the server name to receive the call, null for all servers.
      * @return the ids of the query objects, (QueryArgs.id).
      * 
-     * @param session
      * @param server
      */
-    public Map<String,List<String>> queryStatusIdList(Session session, String server) throws BlurException, org.apache.thrift.TException;
+    public Map<String,List<String>> queryStatusIdList(String server) throws BlurException, org.apache.thrift.TException;
 
     /**
      * Returns the query status for the given session and query id, (QueryArgs.id).
-     * @param session the Session.
      * @param server the server name to receive the call, null for all servers.
      * @param id the id of the query, (QueryArgs.id).
      * @return a map of server to the query status for the given session and id.
      * 
-     * @param session
      * @param server
      * @param id
      */
-    public Map<String,QueryStatus> queryStatus(Session session, String server, String id) throws BlurException, org.apache.thrift.TException;
+    public Map<String,QueryStatus> queryStatus(String server, String id) throws BlurException, org.apache.thrift.TException;
 
     /**
-     * Returns the the schema for the given session.
-     * @param session the Session.
+     * Returns the the schema for the given table.
+     * @param tableName the table name.
      * @return the table schema.
      * 
-     * @param session
+     * @param tableName
      */
-    public TableSchema schema(Session session) throws BlurException, org.apache.thrift.TException;
+    public TableSchema schema(String tableName) throws BlurException, org.apache.thrift.TException;
 
     public TableStats tableStats(String table) throws BlurException, org.apache.thrift.TException;
 
@@ -322,13 +316,13 @@ public class Blur {
 
     public void describe(String table, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.describe_call> resultHandler) throws org.apache.thrift.TException;
 
-    public void cancelQuery(Session session, String server, String id, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.cancelQuery_call> resultHandler) throws org.apache.thrift.TException;
+    public void cancelQuery(String server, String id, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.cancelQuery_call> resultHandler) throws org.apache.thrift.TException;
 
-    public void queryStatusIdList(Session session, String server, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.queryStatusIdList_call> resultHandler) throws org.apache.thrift.TException;
+    public void queryStatusIdList(String server, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.queryStatusIdList_call> resultHandler) throws org.apache.thrift.TException;
 
-    public void queryStatus(Session session, String server, String id, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.queryStatus_call> resultHandler) throws org.apache.thrift.TException;
+    public void queryStatus(String server, String id, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.queryStatus_call> resultHandler) throws org.apache.thrift.TException;
 
-    public void schema(Session session, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.schema_call> resultHandler) throws org.apache.thrift.TException;
+    public void schema(String tableName, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.schema_call> resultHandler) throws org.apache.thrift.TException;
 
     public void tableStats(String table, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.tableStats_call> resultHandler) throws org.apache.thrift.TException;
 
@@ -837,16 +831,15 @@ public class Blur {
       throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "describe failed: unknown result");
     }
 
-    public void cancelQuery(Session session, String server, String id) throws BlurException, org.apache.thrift.TException
+    public void cancelQuery(String server, String id) throws BlurException, org.apache.thrift.TException
     {
-      send_cancelQuery(session, server, id);
+      send_cancelQuery(server, id);
       recv_cancelQuery();
     }
 
-    public void send_cancelQuery(Session session, String server, String id) throws org.apache.thrift.TException
+    public void send_cancelQuery(String server, String id) throws org.apache.thrift.TException
     {
       cancelQuery_args args = new cancelQuery_args();
-      args.setSession(session);
       args.setServer(server);
       args.setId(id);
       sendBase("cancelQuery", args);
@@ -862,16 +855,15 @@ public class Blur {
       return;
     }
 
-    public Map<String,List<String>> queryStatusIdList(Session session, String server) throws BlurException, org.apache.thrift.TException
+    public Map<String,List<String>> queryStatusIdList(String server) throws BlurException, org.apache.thrift.TException
     {
-      send_queryStatusIdList(session, server);
+      send_queryStatusIdList(server);
       return recv_queryStatusIdList();
     }
 
-    public void send_queryStatusIdList(Session session, String server) throws org.apache.thrift.TException
+    public void send_queryStatusIdList(String server) throws org.apache.thrift.TException
     {
       queryStatusIdList_args args = new queryStatusIdList_args();
-      args.setSession(session);
       args.setServer(server);
       sendBase("queryStatusIdList", args);
     }
@@ -889,16 +881,15 @@ public class Blur {
       throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "queryStatusIdList failed: unknown result");
     }
 
-    public Map<String,QueryStatus> queryStatus(Session session, String server, String id) throws BlurException, org.apache.thrift.TException
+    public Map<String,QueryStatus> queryStatus(String server, String id) throws BlurException, org.apache.thrift.TException
     {
-      send_queryStatus(session, server, id);
+      send_queryStatus(server, id);
       return recv_queryStatus();
     }
 
-    public void send_queryStatus(Session session, String server, String id) throws org.apache.thrift.TException
+    public void send_queryStatus(String server, String id) throws org.apache.thrift.TException
     {
       queryStatus_args args = new queryStatus_args();
-      args.setSession(session);
       args.setServer(server);
       args.setId(id);
       sendBase("queryStatus", args);
@@ -917,16 +908,16 @@ public class Blur {
       throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "queryStatus failed: unknown result");
     }
 
-    public TableSchema schema(Session session) throws BlurException, org.apache.thrift.TException
+    public TableSchema schema(String tableName) throws BlurException, org.apache.thrift.TException
     {
-      send_schema(session);
+      send_schema(tableName);
       return recv_schema();
     }
 
-    public void send_schema(Session session) throws org.apache.thrift.TException
+    public void send_schema(String tableName) throws org.apache.thrift.TException
     {
       schema_args args = new schema_args();
-      args.setSession(session);
+      args.setTableName(tableName);
       sendBase("schema", args);
     }
 
@@ -1616,20 +1607,18 @@ public class Blur {
       }
     }
 
-    public void cancelQuery(Session session, String server, String id, org.apache.thrift.async.AsyncMethodCallback<cancelQuery_call> resultHandler) throws org.apache.thrift.TException {
+    public void cancelQuery(String server, String id, org.apache.thrift.async.AsyncMethodCallback<cancelQuery_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
-      cancelQuery_call method_call = new cancelQuery_call(session, server, id, resultHandler, this, ___protocolFactory, ___transport);
+      cancelQuery_call method_call = new cancelQuery_call(server, id, resultHandler, this, ___protocolFactory, ___transport);
       this.___currentMethod = method_call;
       ___manager.call(method_call);
     }
 
     public static class cancelQuery_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private Session session;
       private String server;
       private String id;
-      public cancelQuery_call(Session session, String server, String id, org.apache.thrift.async.AsyncMethodCallback<cancelQuery_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+      public cancelQuery_call(String server, String id, org.apache.thrift.async.AsyncMethodCallback<cancelQuery_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
         super(client, protocolFactory, transport, resultHandler, false);
-        this.session = session;
         this.server = server;
         this.id = id;
       }
@@ -1637,7 +1626,6 @@ public class Blur {
       public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
         prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("cancelQuery", org.apache.thrift.protocol.TMessageType.CALL, 0));
         cancelQuery_args args = new cancelQuery_args();
-        args.setSession(session);
         args.setServer(server);
         args.setId(id);
         args.write(prot);
@@ -1654,26 +1642,23 @@ public class Blur {
       }
     }
 
-    public void queryStatusIdList(Session session, String server, org.apache.thrift.async.AsyncMethodCallback<queryStatusIdList_call> resultHandler) throws org.apache.thrift.TException {
+    public void queryStatusIdList(String server, org.apache.thrift.async.AsyncMethodCallback<queryStatusIdList_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
-      queryStatusIdList_call method_call = new queryStatusIdList_call(session, server, resultHandler, this, ___protocolFactory, ___transport);
+      queryStatusIdList_call method_call = new queryStatusIdList_call(server, resultHandler, this, ___protocolFactory, ___transport);
       this.___currentMethod = method_call;
       ___manager.call(method_call);
     }
 
     public static class queryStatusIdList_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private Session session;
       private String server;
-      public queryStatusIdList_call(Session session, String server, org.apache.thrift.async.AsyncMethodCallback<queryStatusIdList_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+      public queryStatusIdList_call(String server, org.apache.thrift.async.AsyncMethodCallback<queryStatusIdList_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
         super(client, protocolFactory, transport, resultHandler, false);
-        this.session = session;
         this.server = server;
       }
 
       public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
         prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("queryStatusIdList", org.apache.thrift.protocol.TMessageType.CALL, 0));
         queryStatusIdList_args args = new queryStatusIdList_args();
-        args.setSession(session);
         args.setServer(server);
         args.write(prot);
         prot.writeMessageEnd();
@@ -1689,20 +1674,18 @@ public class Blur {
       }
     }
 
-    public void queryStatus(Session session, String server, String id, org.apache.thrift.async.AsyncMethodCallback<queryStatus_call> resultHandler) throws org.apache.thrift.TException {
+    public void queryStatus(String server, String id, org.apache.thrift.async.AsyncMethodCallback<queryStatus_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
-      queryStatus_call method_call = new queryStatus_call(session, server, id, resultHandler, this, ___protocolFactory, ___transport);
+      queryStatus_call method_call = new queryStatus_call(server, id, resultHandler, this, ___protocolFactory, ___transport);
       this.___currentMethod = method_call;
       ___manager.call(method_call);
     }
 
     public static class queryStatus_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private Session session;
       private String server;
       private String id;
-      public queryStatus_call(Session session, String server, String id, org.apache.thrift.async.AsyncMethodCallback<queryStatus_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+      public queryStatus_call(String server, String id, org.apache.thrift.async.AsyncMethodCallback<queryStatus_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
         super(client, protocolFactory, transport, resultHandler, false);
-        this.session = session;
         this.server = server;
         this.id = id;
       }
@@ -1710,7 +1693,6 @@ public class Blur {
       public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
         prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("queryStatus", org.apache.thrift.protocol.TMessageType.CALL, 0));
         queryStatus_args args = new queryStatus_args();
-        args.setSession(session);
         args.setServer(server);
         args.setId(id);
         args.write(prot);
@@ -1727,24 +1709,24 @@ public class Blur {
       }
     }
 
-    public void schema(Session session, org.apache.thrift.async.AsyncMethodCallback<schema_call> resultHandler) throws org.apache.thrift.TException {
+    public void schema(String tableName, org.apache.thrift.async.AsyncMethodCallback<schema_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
-      schema_call method_call = new schema_call(session, resultHandler, this, ___protocolFactory, ___transport);
+      schema_call method_call = new schema_call(tableName, resultHandler, this, ___protocolFactory, ___transport);
       this.___currentMethod = method_call;
       ___manager.call(method_call);
     }
 
     public static class schema_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private Session session;
-      public schema_call(Session session, org.apache.thrift.async.AsyncMethodCallback<schema_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+      private String tableName;
+      public schema_call(String tableName, org.apache.thrift.async.AsyncMethodCallback<schema_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
         super(client, protocolFactory, transport, resultHandler, false);
-        this.session = session;
+        this.tableName = tableName;
       }
 
       public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
         prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("schema", org.apache.thrift.protocol.TMessageType.CALL, 0));
         schema_args args = new schema_args();
-        args.setSession(session);
+        args.setTableName(tableName);
         args.write(prot);
         prot.writeMessageEnd();
       }
@@ -2304,7 +2286,7 @@ public class Blur {
       public cancelQuery_result getResult(I iface, cancelQuery_args args) throws org.apache.thrift.TException {
         cancelQuery_result result = new cancelQuery_result();
         try {
-          iface.cancelQuery(args.session, args.server, args.id);
+          iface.cancelQuery(args.server, args.id);
         } catch (BlurException ex) {
           result.ex = ex;
         }
@@ -2328,7 +2310,7 @@ public class Blur {
       public queryStatusIdList_result getResult(I iface, queryStatusIdList_args args) throws org.apache.thrift.TException {
         queryStatusIdList_result result = new queryStatusIdList_result();
         try {
-          result.success = iface.queryStatusIdList(args.session, args.server);
+          result.success = iface.queryStatusIdList(args.server);
         } catch (BlurException ex) {
           result.ex = ex;
         }
@@ -2352,7 +2334,7 @@ public class Blur {
       public queryStatus_result getResult(I iface, queryStatus_args args) throws org.apache.thrift.TException {
         queryStatus_result result = new queryStatus_result();
         try {
-          result.success = iface.queryStatus(args.session, args.server, args.id);
+          result.success = iface.queryStatus(args.server, args.id);
         } catch (BlurException ex) {
           result.ex = ex;
         }
@@ -2376,7 +2358,7 @@ public class Blur {
       public schema_result getResult(I iface, schema_args args) throws org.apache.thrift.TException {
         schema_result result = new schema_result();
         try {
-          result.success = iface.schema(args.session);
+          result.success = iface.schema(args.tableName);
         } catch (BlurException ex) {
           result.ex = ex;
         }
@@ -18849,9 +18831,8 @@ public class Blur {
   public static class cancelQuery_args implements org.apache.thrift.TBase<cancelQuery_args, cancelQuery_args._Fields>, java.io.Serializable, Cloneable   {
     private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("cancelQuery_args");
 
-    private static final org.apache.thrift.protocol.TField SESSION_FIELD_DESC = new org.apache.thrift.protocol.TField("session", org.apache.thrift.protocol.TType.STRUCT, (short)1);
-    private static final org.apache.thrift.protocol.TField SERVER_FIELD_DESC = new org.apache.thrift.protocol.TField("server", org.apache.thrift.protocol.TType.STRING, (short)2);
-    private static final org.apache.thrift.protocol.TField ID_FIELD_DESC = new org.apache.thrift.protocol.TField("id", org.apache.thrift.protocol.TType.STRING, (short)3);
+    private static final org.apache.thrift.protocol.TField SERVER_FIELD_DESC = new org.apache.thrift.protocol.TField("server", org.apache.thrift.protocol.TType.STRING, (short)1);
+    private static final org.apache.thrift.protocol.TField ID_FIELD_DESC = new org.apache.thrift.protocol.TField("id", org.apache.thrift.protocol.TType.STRING, (short)2);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
@@ -18859,15 +18840,13 @@ public class Blur {
       schemes.put(TupleScheme.class, new cancelQuery_argsTupleSchemeFactory());
     }
 
-    public Session session; // required
     public String server; // required
     public String id; // 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 {
-      SESSION((short)1, "session"),
-      SERVER((short)2, "server"),
-      ID((short)3, "id");
+      SERVER((short)1, "server"),
+      ID((short)2, "id");
 
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -18882,11 +18861,9 @@ public class Blur {
        */
       public static _Fields findByThriftId(int fieldId) {
         switch(fieldId) {
-          case 1: // SESSION
-            return SESSION;
-          case 2: // SERVER
+          case 1: // SERVER
             return SERVER;
-          case 3: // ID
+          case 2: // ID
             return ID;
           default:
             return null;
@@ -18931,8 +18908,6 @@ public class Blur {
     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(_Fields.SESSION, new org.apache.thrift.meta_data.FieldMetaData("session", org.apache.thrift.TFieldRequirementType.DEFAULT, 
-          new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Session.class)));
       tmpMap.put(_Fields.SERVER, new org.apache.thrift.meta_data.FieldMetaData("server", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
       tmpMap.put(_Fields.ID, new org.apache.thrift.meta_data.FieldMetaData("id", org.apache.thrift.TFieldRequirementType.DEFAULT, 
@@ -18945,12 +18920,10 @@ public class Blur {
     }
 
     public cancelQuery_args(
-      Session session,
       String server,
       String id)
     {
       this();
-      this.session = session;
       this.server = server;
       this.id = id;
     }
@@ -18959,9 +18932,6 @@ public class Blur {
      * Performs a deep copy on <i>other</i>.
      */
     public cancelQuery_args(cancelQuery_args other) {
-      if (other.isSetSession()) {
-        this.session = new Session(other.session);
-      }
       if (other.isSetServer()) {
         this.server = other.server;
       }
@@ -18976,35 +18946,10 @@ public class Blur {
 
     @Override
     public void clear() {
-      this.session = null;
       this.server = null;
       this.id = null;
     }
 
-    public Session getSession() {
-      return this.session;
-    }
-
-    public cancelQuery_args setSession(Session session) {
-      this.session = session;
-      return this;
-    }
-
-    public void unsetSession() {
-      this.session = null;
-    }
-
-    /** Returns true if field session is set (has been assigned a value) and false otherwise */
-    public boolean isSetSession() {
-      return this.session != null;
-    }
-
-    public void setSessionIsSet(boolean value) {
-      if (!value) {
-        this.session = null;
-      }
-    }
-
     public String getServer() {
       return this.server;
     }
@@ -19055,14 +19000,6 @@ public class Blur {
 
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
-      case SESSION:
-        if (value == null) {
-          unsetSession();
-        } else {
-          setSession((Session)value);
-        }
-        break;
-
       case SERVER:
         if (value == null) {
           unsetServer();
@@ -19084,9 +19021,6 @@ public class Blur {
 
     public Object getFieldValue(_Fields field) {
       switch (field) {
-      case SESSION:
-        return getSession();
-
       case SERVER:
         return getServer();
 
@@ -19104,8 +19038,6 @@ public class Blur {
       }
 
       switch (field) {
-      case SESSION:
-        return isSetSession();
       case SERVER:
         return isSetServer();
       case ID:
@@ -19127,15 +19059,6 @@ public class Blur {
       if (that == null)
         return false;
 
-      boolean this_present_session = true && this.isSetSession();
-      boolean that_present_session = true && that.isSetSession();
-      if (this_present_session || that_present_session) {
-        if (!(this_present_session && that_present_session))
-          return false;
-        if (!this.session.equals(that.session))
-          return false;
-      }
-
       boolean this_present_server = true && this.isSetServer();
       boolean that_present_server = true && that.isSetServer();
       if (this_present_server || that_present_server) {
@@ -19170,16 +19093,6 @@ public class Blur {
       int lastComparison = 0;
       cancelQuery_args typedOther = (cancelQuery_args)other;
 
-      lastComparison = Boolean.valueOf(isSetSession()).compareTo(typedOther.isSetSession());
-      if (lastComparison != 0) {
-        return lastComparison;
-      }
-      if (isSetSession()) {
-        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.session, typedOther.session);
-        if (lastComparison != 0) {
-          return lastComparison;
-        }
-      }
       lastComparison = Boolean.valueOf(isSetServer()).compareTo(typedOther.isSetServer());
       if (lastComparison != 0) {
         return lastComparison;
@@ -19220,14 +19133,6 @@ public class Blur {
       StringBuilder sb = new StringBuilder("cancelQuery_args(");
       boolean first = true;
 
-      sb.append("session:");
-      if (this.session == null) {
-        sb.append("null");
-      } else {
-        sb.append(this.session);
-      }
-      first = false;
-      if (!first) sb.append(", ");
       sb.append("server:");
       if (this.server == null) {
         sb.append("null");
@@ -19250,9 +19155,6 @@ public class Blur {
     public void validate() throws org.apache.thrift.TException {
       // check for required fields
       // check for sub-struct validity
-      if (session != null) {
-        session.validate();
-      }
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -19289,16 +19191,7 @@ public class Blur {
             break;
           }
           switch (schemeField.id) {
-            case 1: // SESSION
-              if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
-                struct.session = new Session();
-                struct.session.read(iprot);
-                struct.setSessionIsSet(true);
-              } else { 
-                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
-              }
-              break;
-            case 2: // SERVER
+            case 1: // SERVER
               if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
                 struct.server = iprot.readString();
                 struct.setServerIsSet(true);
@@ -19306,7 +19199,7 @@ public class Blur {
                 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
               }
               break;
-            case 3: // ID
+            case 2: // ID
               if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
                 struct.id = iprot.readString();
                 struct.setIdIsSet(true);
@@ -19329,11 +19222,6 @@ public class Blur {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
-        if (struct.session != null) {
-          oprot.writeFieldBegin(SESSION_FIELD_DESC);
-          struct.session.write(oprot);
-          oprot.writeFieldEnd();
-        }
         if (struct.server != null) {
           oprot.writeFieldBegin(SERVER_FIELD_DESC);
           oprot.writeString(struct.server);
@@ -19362,19 +19250,13 @@ public class Blur {
       public void write(org.apache.thrift.protocol.TProtocol prot, cancelQuery_args struct) throws org.apache.thrift.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
-        if (struct.isSetSession()) {
-          optionals.set(0);
-        }
         if (struct.isSetServer()) {
-          optionals.set(1);
+          optionals.set(0);
         }
         if (struct.isSetId()) {
-          optionals.set(2);
-        }
-        oprot.writeBitSet(optionals, 3);
-        if (struct.isSetSession()) {
-          struct.session.write(oprot);
+          optionals.set(1);
         }
+        oprot.writeBitSet(optionals, 2);
         if (struct.isSetServer()) {
           oprot.writeString(struct.server);
         }
@@ -19386,17 +19268,12 @@ public class Blur {
       @Override
       public void read(org.apache.thrift.protocol.TProtocol prot, cancelQuery_args struct) throws org.apache.thrift.TException {
         TTupleProtocol iprot = (TTupleProtocol) prot;
-        BitSet incoming = iprot.readBitSet(3);
+        BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
-          struct.session = new Session();
-          struct.session.read(iprot);
-          struct.setSessionIsSet(true);
-        }
-        if (incoming.get(1)) {
           struct.server = iprot.readString();
           struct.setServerIsSet(true);
         }
-        if (incoming.get(2)) {
+        if (incoming.get(1)) {
           struct.id = iprot.readString();
           struct.setIdIsSet(true);
         }
@@ -19764,8 +19641,7 @@ public class Blur {
   public static class queryStatusIdList_args implements org.apache.thrift.TBase<queryStatusIdList_args, queryStatusIdList_args._Fields>, java.io.Serializable, Cloneable   {
     private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("queryStatusIdList_args");
 
-    private static final org.apache.thrift.protocol.TField SESSION_FIELD_DESC = new org.apache.thrift.protocol.TField("session", org.apache.thrift.protocol.TType.STRUCT, (short)1);
-    private static final org.apache.thrift.protocol.TField SERVER_FIELD_DESC = new org.apache.thrift.protocol.TField("server", org.apache.thrift.protocol.TType.STRING, (short)2);
+    private static final org.apache.thrift.protocol.TField SERVER_FIELD_DESC = new org.apache.thrift.protocol.TField("server", org.apache.thrift.protocol.TType.STRING, (short)1);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
@@ -19773,13 +19649,11 @@ public class Blur {
       schemes.put(TupleScheme.class, new queryStatusIdList_argsTupleSchemeFactory());
     }
 
-    public Session session; // required
     public String server; // 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 {
-      SESSION((short)1, "session"),
-      SERVER((short)2, "server");
+      SERVER((short)1, "server");
 
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -19794,9 +19668,7 @@ public class Blur {
        */
       public static _Fields findByThriftId(int fieldId) {
         switch(fieldId) {
-          case 1: // SESSION
-            return SESSION;
-          case 2: // SERVER
+          case 1: // SERVER
             return SERVER;
           default:
             return null;
@@ -19841,8 +19713,6 @@ public class Blur {
     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(_Fields.SESSION, new org.apache.thrift.meta_data.FieldMetaData("session", org.apache.thrift.TFieldRequirementType.DEFAULT, 
-          new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Session.class)));
       tmpMap.put(_Fields.SERVER, new org.apache.thrift.meta_data.FieldMetaData("server", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
@@ -19853,11 +19723,9 @@ public class Blur {
     }
 
     public queryStatusIdList_args(
-      Session session,
       String server)
     {
       this();
-      this.session = session;
       this.server = server;
     }
 
@@ -19865,9 +19733,6 @@ public class Blur {
      * Performs a deep copy on <i>other</i>.
      */
     public queryStatusIdList_args(queryStatusIdList_args other) {
-      if (other.isSetSession()) {
-        this.session = new Session(other.session);
-      }
       if (other.isSetServer()) {
         this.server = other.server;
       }
@@ -19879,34 +19744,9 @@ public class Blur {
 
     @Override
     public void clear() {
-      this.session = null;
       this.server = null;
     }
 
-    public Session getSession() {
-      return this.session;
-    }
-
-    public queryStatusIdList_args setSession(Session session) {
-      this.session = session;
-      return this;
-    }
-
-    public void unsetSession() {
-      this.session = null;
-    }
-
-    /** Returns true if field session is set (has been assigned a value) and false otherwise */
-    public boolean isSetSession() {
-      return this.session != null;
-    }
-
-    public void setSessionIsSet(boolean value) {
-      if (!value) {
-        this.session = null;
-      }
-    }
-
     public String getServer() {
       return this.server;
     }
@@ -19933,14 +19773,6 @@ public class Blur {
 
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
-      case SESSION:
-        if (value == null) {
-          unsetSession();
-        } else {
-          setSession((Session)value);
-        }
-        break;
-
       case SERVER:
         if (value == null) {
           unsetServer();
@@ -19954,9 +19786,6 @@ public class Blur {
 
     public Object getFieldValue(_Fields field) {
       switch (field) {
-      case SESSION:
-        return getSession();
-
       case SERVER:
         return getServer();
 
@@ -19971,8 +19800,6 @@ public class Blur {
       }
 
       switch (field) {
-      case SESSION:
-        return isSetSession();
       case SERVER:
         return isSetServer();
       }
@@ -19992,15 +19819,6 @@ public class Blur {
       if (that == null)
         return false;
 
-      boolean this_present_session = true && this.isSetSession();
-      boolean that_present_session = true && that.isSetSession();
-      if (this_present_session || that_present_session) {
-        if (!(this_present_session && that_present_session))
-          return false;
-        if (!this.session.equals(that.session))
-          return false;
-      }
-
       boolean this_present_server = true && this.isSetServer();
       boolean that_present_server = true && that.isSetServer();
       if (this_present_server || that_present_server) {
@@ -20026,16 +19844,6 @@ public class Blur {
       int lastComparison = 0;
       queryStatusIdList_args typedOther = (queryStatusIdList_args)other;
 
-      lastComparison = Boolean.valueOf(isSetSession()).compareTo(typedOther.isSetSession());
-      if (lastComparison != 0) {
-        return lastComparison;
-      }
-      if (isSetSession()) {
-        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.session, typedOther.session);
-        if (lastComparison != 0) {
-          return lastComparison;
-        }
-      }
       lastComparison = Boolean.valueOf(isSetServer()).compareTo(typedOther.isSetServer());
       if (lastComparison != 0) {
         return lastComparison;
@@ -20066,14 +19874,6 @@ public class Blur {
       StringBuilder sb = new StringBuilder("queryStatusIdList_args(");
       boolean first = true;
 
-      sb.append("session:");
-      if (this.session == null) {
-        sb.append("null");
-      } else {
-        sb.append(this.session);
-      }
-      first = false;
-      if (!first) sb.append(", ");
       sb.append("server:");
       if (this.server == null) {
         sb.append("null");
@@ -20088,9 +19888,6 @@ public class Blur {
     public void validate() throws org.apache.thrift.TException {
       // check for required fields
       // check for sub-struct validity
-      if (session != null) {
-        session.validate();
-      }
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -20127,16 +19924,7 @@ public class Blur {
             break;
           }
           switch (schemeField.id) {
-            case 1: // SESSION
-              if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
-                struct.session = new Session();
-                struct.session.read(iprot);
-                struct.setSessionIsSet(true);
-              } else { 
-                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
-              }
-              break;
-            case 2: // SERVER
+            case 1: // SERVER
               if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
                 struct.server = iprot.readString();
                 struct.setServerIsSet(true);
@@ -20159,11 +19947,6 @@ public class Blur {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
-        if (struct.session != null) {
-          oprot.writeFieldBegin(SESSION_FIELD_DESC);
-          struct.session.write(oprot);
-          oprot.writeFieldEnd();
-        }
         if (struct.server != null) {
           oprot.writeFieldBegin(SERVER_FIELD_DESC);
           oprot.writeString(struct.server);
@@ -20187,16 +19970,10 @@ public class Blur {
       public void write(org.apache.thrift.protocol.TProtocol prot, queryStatusIdList_args struct) throws org.apache.thrift.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
-        if (struct.isSetSession()) {
-          optionals.set(0);
-        }
         if (struct.isSetServer()) {
-          optionals.set(1);
-        }
-        oprot.writeBitSet(optionals, 2);
-        if (struct.isSetSession()) {
-          struct.session.write(oprot);
+          optionals.set(0);
         }
+        oprot.writeBitSet(optionals, 1);
         if (struct.isSetServer()) {
           oprot.writeString(struct.server);
         }
@@ -20205,13 +19982,8 @@ public class Blur {
       @Override
       public void read(org.apache.thrift.protocol.TProtocol prot, queryStatusIdList_args struct) throws org.apache.thrift.TException {
         TTupleProtocol iprot = (TTupleProtocol) prot;
-        BitSet incoming = iprot.readBitSet(2);
+        BitSet incoming = iprot.readBitSet(1);
         if (incoming.get(0)) {
-          struct.session = new Session();
-          struct.session.read(iprot);
-          struct.setSessionIsSet(true);
-        }
-        if (incoming.get(1)) {
           struct.server = iprot.readString();
           struct.setServerIsSet(true);
         }
@@ -20778,9 +20550,8 @@ public class Blur {
   public static class queryStatus_args implements org.apache.thrift.TBase<queryStatus_args, queryStatus_args._Fields>, java.io.Serializable, Cloneable   {
     private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("queryStatus_args");
 
-    private static final org.apache.thrift.protocol.TField SESSION_FIELD_DESC = new org.apache.thrift.protocol.TField("session", org.apache.thrift.protocol.TType.STRUCT, (short)1);
-    private static final org.apache.thrift.protocol.TField SERVER_FIELD_DESC = new org.apache.thrift.protocol.TField("server", org.apache.thrift.protocol.TType.STRING, (short)2);
-    private static final org.apache.thrift.protocol.TField ID_FIELD_DESC = new org.apache.thrift.protocol.TField("id", org.apache.thrift.protocol.TType.STRING, (short)3);
+    private static final org.apache.thrift.protocol.TField SERVER_FIELD_DESC = new org.apache.thrift.protocol.TField("server", org.apache.thrift.protocol.TType.STRING, (short)1);
+    private static final org.apache.thrift.protocol.TField ID_FIELD_DESC = new org.apache.thrift.protocol.TField("id", org.apache.thrift.protocol.TType.STRING, (short)2);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
@@ -20788,15 +20559,13 @@ public class Blur {
       schemes.put(TupleScheme.class, new queryStatus_argsTupleSchemeFactory());
     }
 
-    public Session session; // required
     public String server; // required
     public String id; // 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 {
-      SESSION((short)1, "session"),
-      SERVER((short)2, "server"),
-      ID((short)3, "id");
+      SERVER((short)1, "server"),
+      ID((short)2, "id");
 
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -20811,11 +20580,9 @@ public class Blur {
        */
       public static _Fields findByThriftId(int fieldId) {
         switch(fieldId) {
-          case 1: // SESSION
-            return SESSION;
-          case 2: // SERVER
+          case 1: // SERVER
             return SERVER;
-          case 3: // ID
+          case 2: // ID
             return ID;
           default:
             return null;
@@ -20860,8 +20627,6 @@ public class Blur {
     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(_Fields.SESSION, new org.apache.thrift.meta_data.FieldMetaData("session", org.apache.thrift.TFieldRequirementType.DEFAULT, 
-          new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Session.class)));
       tmpMap.put(_Fields.SERVER, new org.apache.thrift.meta_data.FieldMetaData("server", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
       tmpMap.put(_Fields.ID, new org.apache.thrift.meta_data.FieldMetaData("id", org.apache.thrift.TFieldRequirementType.DEFAULT, 
@@ -20874,12 +20639,10 @@ public class Blur {
     }
 
     public queryStatus_args(
-      Session session,
       String server,
       String id)
     {
       this();
-      this.session = session;
       this.server = server;
       this.id = id;
     }
@@ -20888,9 +20651,6 @@ public class Blur {
      * Performs a deep copy on <i>other</i>.
      */
     public queryStatus_args(queryStatus_args other) {
-      if (other.isSetSession()) {
-        this.session = new Session(other.session);
-      }
       if (other.isSetServer()) {
         this.server = other.server;
       }
@@ -20905,35 +20665,10 @@ public class Blur {
 
     @Override
     public void clear() {
-      this.session = null;
       this.server = null;
       this.id = null;
     }
 
-    public Session getSession() {
-      return this.session;
-    }
-
-    public queryStatus_args setSession(Session session) {
-      this.session = session;
-      return this;
-    }
-
-    public void unsetSession() {
-      this.session = null;
-    }
-
-    /** Returns true if field session is set (has been assigned a value) and false otherwise */
-    public boolean isSetSession() {
-      return this.session != null;
-    }
-
-    public void setSessionIsSet(boolean value) {
-      if (!value) {
-        this.session = null;
-      }
-    }
-
     public String getServer() {
       return this.server;
     }
@@ -20984,14 +20719,6 @@ public class Blur {
 
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
-      case SESSION:
-        if (value == null) {
-          unsetSession();
-        } else {
-          setSession((Session)value);
-        }
-        break;
-
       case SERVER:
         if (value == null) {
           unsetServer();
@@ -21013,9 +20740,6 @@ public class Blur {
 
     public Object getFieldValue(_Fields field) {
       switch (field) {
-      case SESSION:
-        return getSession();
-
       case SERVER:
         return getServer();
 
@@ -21033,8 +20757,6 @@ public class Blur {
       }
 
       switch (field) {
-      case SESSION:
-        return isSetSession();
       case SERVER:
         return isSetServer();
       case ID:
@@ -21056,15 +20778,6 @@ public class Blur {
       if (that == null)
         return false;
 
-      boolean this_present_session = true && this.isSetSession();
-      boolean that_present_session = true && that.isSetSession();
-      if (this_present_session || that_present_session) {
-        if (!(this_present_session && that_present_session))
-          return false;
-        if (!this.session.equals(that.session))
-          return false;
-      }
-
       boolean this_present_server = true && this.isSetServer();
       boolean that_present_server = true && that.isSetServer();
       if (this_present_server || that_present_server) {
@@ -21099,16 +20812,6 @@ public class Blur {
       int lastComparison = 0;
       queryStatus_args typedOther = (queryStatus_args)other;
 
-      lastComparison = Boolean.valueOf(isSetSession()).compareTo(typedOther.isSetSession());
-      if (lastComparison != 0) {
-        return lastComparison;
-      }
-      if (isSetSession()) {
-        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.session, typedOther.session);
-        if (lastComparison != 0) {
-          return lastComparison;
-        }
-      }
       lastComparison = Boolean.valueOf(isSetServer()).compareTo(typedOther.isSetServer());
       if (lastComparison != 0) {
         return lastComparison;
@@ -21149,14 +20852,6 @@ public class Blur {
       StringBuilder sb = new StringBuilder("queryStatus_args(");
       boolean first = true;
 
-      sb.append("session:");
-      if (this.session == null) {
-        sb.append("null");
-      } else {
-        sb.append(this.session);
-      }
-      first = false;
-      if (!first) sb.append(", ");
       sb.append("server:");
       if (this.server == null) {
         sb.append("null");
@@ -21179,9 +20874,6 @@ public class Blur {
     public void validate() throws org.apache.thrift.TException {
       // check for required fields
       // check for sub-struct validity
-      if (session != null) {
-        session.validate();
-      }
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -21218,16 +20910,7 @@ public class Blur {
             break;
           }
           switch (schemeField.id) {
-            case 1: // SESSION
-              if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
-                struct.session = new Session();
-                struct.session.read(iprot);
-                struct.setSessionIsSet(true);
-              } else { 
-                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
-              }
-              break;
-            case 2: // SERVER
+            case 1: // SERVER
               if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
                 struct.server = iprot.readString();
                 struct.setServerIsSet(true);
@@ -21235,7 +20918,7 @@ public class Blur {
                 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
               }
               break;
-            case 3: // ID
+            case 2: // ID
               if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
                 struct.id = iprot.readString();
                 struct.setIdIsSet(true);
@@ -21258,11 +20941,6 @@ public class Blur {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
-        if (struct.session != null) {
-          oprot.writeFieldBegin(SESSION_FIELD_DESC);
-          struct.session.write(oprot);
-          oprot.writeFieldEnd();
-        }
         if (struct.server != null) {
           oprot.writeFieldBegin(SERVER_FIELD_DESC);
           oprot.writeString(struct.server);
@@ -21291,19 +20969,13 @@ public class Blur {
       public void write(org.apache.thrift.protocol.TProtocol prot, queryStatus_args struct) throws org.apache.thrift.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
-        if (struct.isSetSession()) {
-          optionals.set(0);
-        }
         if (struct.isSetServer()) {
-          optionals.set(1);
+          optionals.set(0);
         }
         if (struct.isSetId()) {
-          optionals.set(2);
-        }
-        oprot.writeBitSet(optionals, 3);
-        if (struct.isSetSession()) {
-          struct.session.write(oprot);
+          optionals.set(1);
         }
+        oprot.writeBitSet(optionals, 2);
         if (struct.isSetServer()) {
           oprot.writeString(struct.server);
         }
@@ -21315,17 +20987,12 @@ public class Blur {
       @Override
       public void read(org.apache.thrift.protocol.TProtocol prot, queryStatus_args struct) throws org.apache.thrift.TException {
         TTupleProtocol iprot = (TTupleProtocol) prot;
-        BitSet incoming = iprot.readBitSet(3);
+        BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
-          struct.session = new Session();
-          struct.session.read(iprot);
-          struct.setSessionIsSet(true);
-        }
-        if (incoming.get(1)) {
           struct.server = iprot.readString();
           struct.setServerIsSet(true);
         }
-        if (incoming.get(2)) {
+        if (incoming.get(1)) {
           struct.id = iprot.readString();
           struct.setIdIsSet(true);
         }
@@ -21858,7 +21525,7 @@ public class Blur {
   public static class schema_args implements org.apache.thrift.TBase<schema_args, schema_args._Fields>, java.io.Serializable, Cloneable   {
     private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("schema_args");
 
-    private static final org.apache.thrift.protocol.TField SESSION_FIELD_DESC = new org.apache.thrift.protocol.TField("session", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+    private static final org.apache.thrift.protocol.TField TABLE_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tableName", org.apache.thrift.protocol.TType.STRING, (short)1);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
@@ -21866,11 +21533,11 @@ public class Blur {
       schemes.put(TupleScheme.class, new schema_argsTupleSchemeFactory());
     }
 
-    public Session session; // required
+    public String tableName; // 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 {
-      SESSION((short)1, "session");
+      TABLE_NAME((short)1, "tableName");
 
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -21885,8 +21552,8 @@ public class Blur {
        */
       public static _Fields findByThriftId(int fieldId) {
         switch(fieldId) {
-          case 1: // SESSION
-            return SESSION;
+          case 1: // TABLE_NAME
+            return TABLE_NAME;
           default:
             return null;
         }
@@ -21930,8 +21597,8 @@ public class Blur {
     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(_Fields.SESSION, new org.apache.thrift.meta_data.FieldMetaData("session", org.apache.thrift.TFieldRequirementType.DEFAULT, 
-          new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Session.class)));
+      tmpMap.put(_Fields.TABLE_NAME, new org.apache.thrift.meta_data.FieldMetaData("tableName", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
       org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(schema_args.class, metaDataMap);
     }
@@ -21940,18 +21607,18 @@ public class Blur {
     }
 
     public schema_args(
-      Session session)
+      String tableName)
     {
       this();
-      this.session = session;
+      this.tableName = tableName;
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
     public schema_args(schema_args other) {
-      if (other.isSetSession()) {
-        this.session = new Session(other.session);
+      if (other.isSetTableName()) {
+        this.tableName = other.tableName;
       }
     }
 
@@ -21961,40 +21628,40 @@ public class Blur {
 
     @Override
     public void clear() {
-      this.session = null;
+      this.tableName = null;
     }
 
-    public Session getSession() {
-      return this.session;
+    public String getTableName() {
+      return this.tableName;
     }
 
-    public schema_args setSession(Session session) {
-      this.session = session;
+    public schema_args setTableName(String tableName) {
+      this.tableName = tableName;
       return this;
     }
 
-    public void unsetSession() {
-      this.session = null;
+    public void unsetTableName() {
+      this.tableName = null;
     }
 
-    /** Returns true if field session is set (has been assigned a value) and false otherwise */
-    public boolean isSetSession() {
-      return this.session != null;
+    /** Returns true if field tableName is set (has been assigned a value) and false otherwise */
+    public boolean isSetTableName() {
+      return this.tableName != null;
     }
 
-    public void setSessionIsSet(boolean value) {
+    public void setTableNameIsSet(boolean value) {
       if (!value) {
-        this.session = null;
+        this.tableName = null;
       }
     }
 
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
-      case SESSION:
+      case TABLE_NAME:
         if (value == null) {
-          unsetSession();
+          unsetTableName();
         } else {
-          setSession((Session)value);
+          setTableName((String)value);
         }
         break;
 
@@ -22003,8 +21670,8 @@ public class Blur {
 
     public Object getFieldValue(_Fields field) {
       switch (field) {
-      case SESSION:
-        return getSession();
+      case TABLE_NAME:
+        return getTableName();
 
       }
       throw new IllegalStateException();
@@ -22017,8 +21684,8 @@ public class Blur {
       }
 
       switch (field) {
-      case SESSION:
-        return isSetSession();
+      case TABLE_NAME:
+        return isSetTableName();
       }
       throw new IllegalStateException();
     }
@@ -22036,12 +21703,12 @@ public class Blur {
       if (that == null)
         return false;
 
-      boolean this_present_session = true && this.isSetSession();
-      boolean that_present_session = true && that.isSetSession();
-      if (this_present_session || that_present_session) {
-        if (!(this_present_session && that_present_session))
+      boolean this_present_tableName = true && this.isSetTableName();
+      boolean that_present_tableName = true && that.isSetTableName();
+      if (this_present_tableName || that_present_tableName) {
+        if (!(this_present_tableName && that_present_tableName))
           return false;
-        if (!this.session.equals(that.session))
+        if (!this.tableName.equals(that.tableName))
           return false;
       }
 
@@ -22061,12 +21728,12 @@ public class Blur {
       int lastComparison = 0;
       schema_args typedOther = (schema_args)other;
 
-      lastComparison = Boolean.valueOf(isSetSession()).compareTo(typedOther.isSetSession());
+      lastComparison = Boolean.valueOf(isSetTableName()).compareTo(typedOther.isSetTableName());
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetSession()) {
-        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.session, typedOther.session);
+      if (isSetTableName()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tableName, typedOther.tableName);
         if (lastComparison != 0) {
           return lastComparison;
         }
@@ -22091,11 +21758,11 @@ public class Blur {
       StringBuilder sb = new StringBuilder("schema_args(");
       boolean first = true;
 
-      sb.append("session:");
-      if (this.session == null) {
+      sb.append("tableName:");
+      if (this.tableName == null) {
         sb.append("null");
       } else {
-        sb.append(this.session);
+        sb.append(this.tableName);
       }
       first = false;
       sb.append(")");
@@ -22105,9 +21772,6 @@ public class Blur {
     public void validate() throws org.apache.thrift.TException {
       // check for required fields
       // check for sub-struct validity
-      if (session != null) {
-        session.validate();
-      }
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -22144,11 +21808,10 @@ public class Blur {
             break;
           }
           switch (schemeField.id) {
-            case 1: // SESSION
-              if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
-                struct.session = new Session();
-                struct.session.read(iprot);
-                struct.setSessionIsSet(true);
+            case 1: // TABLE_NAME
+              if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+                struct.tableName = iprot.readString();
+                struct.setTableNameIsSet(true);
               } else { 
                 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
               }
@@ -22168,9 +21831,9 @@ public class Blur {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
-        if (struct.session != null) {
-          oprot.writeFieldBegin(SESSION_FIELD_DESC);
-          struct.session.write(oprot);
+        if (struct.tableName != null) {
+          oprot.writeFieldBegin(TABLE_NAME_FIELD_DESC);
+          oprot.writeString(struct.tableName);
           oprot.writeFieldEnd();
         }
         oprot.writeFieldStop();
@@ -22191,12 +21854,12 @@ public class Blur {
       public void write(org.apache.thrift.protocol.TProtocol prot, schema_args struct) throws org.apache.thrift.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
-        if (struct.isSetSession()) {
+        if (struct.isSetTableName()) {
           optionals.set(0);
         }
         oprot.writeBitSet(optionals, 1);
-        if (struct.isSetSession()) {
-          struct.session.write(oprot);
+        if (struct.isSetTableName()) {
+          oprot.writeString(struct.tableName);
         }
       }
 
@@ -22205,9 +21868,8 @@ public class Blur {
         TTupleProtocol iprot = (TTupleProtocol) prot;
         BitSet incoming = iprot.readBitSet(1);
         if (incoming.get(0)) {
-          struct.session = new Session();
-          struct.session.read(iprot);
-          struct.setSessionIsSet(true);
+          struct.tableName = iprot.readString();
+          struct.setTableNameIsSet(true);
         }
       }
     }

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/cf92e0ff/src/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm b/src/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
index 4be41c8..7019a94 100644
--- a/src/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
+++ b/src/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
@@ -3140,19 +3140,15 @@ sub write {
 
 package Blur::Blur_cancelQuery_args;
 use base qw(Class::Accessor);
-Blur::Blur_cancelQuery_args->mk_accessors( qw( session server id ) );
+Blur::Blur_cancelQuery_args->mk_accessors( qw( server id ) );
 
 sub new {
   my $classname = shift;
   my $self      = {};
   my $vals      = shift || {};
-  $self->{session} = undef;
   $self->{server} = undef;
   $self->{id} = undef;
   if (UNIVERSAL::isa($vals,'HASH')) {
-    if (defined $vals->{session}) {
-      $self->{session} = $vals->{session};
-    }
     if (defined $vals->{server}) {
       $self->{server} = $vals->{server};
     }
@@ -3182,20 +3178,13 @@ sub read {
     }
     SWITCH: for($fid)
     {
-      /^1$/ && do{      if ($ftype == TType::STRUCT) {
-        $self->{session} = new Blur::Session();
-        $xfer += $self->{session}->read($input);
-      } else {
-        $xfer += $input->skip($ftype);
-      }
-      last; };
-      /^2$/ && do{      if ($ftype == TType::STRING) {
+      /^1$/ && do{      if ($ftype == TType::STRING) {
         $xfer += $input->readString(\$self->{server});
       } else {
         $xfer += $input->skip($ftype);
       }
       last; };
-      /^3$/ && do{      if ($ftype == TType::STRING) {
+      /^2$/ && do{      if ($ftype == TType::STRING) {
         $xfer += $input->readString(\$self->{id});
       } else {
         $xfer += $input->skip($ftype);
@@ -3213,18 +3202,13 @@ sub write {
   my ($self, $output) = @_;
   my $xfer   = 0;
   $xfer += $output->writeStructBegin('Blur_cancelQuery_args');
-  if (defined $self->{session}) {
-    $xfer += $output->writeFieldBegin('session', TType::STRUCT, 1);
-    $xfer += $self->{session}->write($output);
-    $xfer += $output->writeFieldEnd();
-  }
   if (defined $self->{server}) {
-    $xfer += $output->writeFieldBegin('server', TType::STRING, 2);
+    $xfer += $output->writeFieldBegin('server', TType::STRING, 1);
     $xfer += $output->writeString($self->{server});
     $xfer += $output->writeFieldEnd();
   }
   if (defined $self->{id}) {
-    $xfer += $output->writeFieldBegin('id', TType::STRING, 3);
+    $xfer += $output->writeFieldBegin('id', TType::STRING, 2);
     $xfer += $output->writeString($self->{id});
     $xfer += $output->writeFieldEnd();
   }
@@ -3300,18 +3284,14 @@ sub write {
 
 package Blur::Blur_queryStatusIdList_args;
 use base qw(Class::Accessor);
-Blur::Blur_queryStatusIdList_args->mk_accessors( qw( session server ) );
+Blur::Blur_queryStatusIdList_args->mk_accessors( qw( server ) );
 
 sub new {
   my $classname = shift;
   my $self      = {};
   my $vals      = shift || {};
-  $self->{session} = undef;
   $self->{server} = undef;
   if (UNIVERSAL::isa($vals,'HASH')) {
-    if (defined $vals->{session}) {
-      $self->{session} = $vals->{session};
-    }
     if (defined $vals->{server}) {
       $self->{server} = $vals->{server};
     }
@@ -3338,14 +3318,7 @@ sub read {
     }
     SWITCH: for($fid)
     {
-      /^1$/ && do{      if ($ftype == TType::STRUCT) {
-        $self->{session} = new Blur::Session();
-        $xfer += $self->{session}->read($input);
-      } else {
-        $xfer += $input->skip($ftype);
-      }
-      last; };
-      /^2$/ && do{      if ($ftype == TType::STRING) {
+      /^1$/ && do{      if ($ftype == TType::STRING) {
         $xfer += $input->readString(\$self->{server});
       } else {
         $xfer += $input->skip($ftype);
@@ -3363,13 +3336,8 @@ sub write {
   my ($self, $output) = @_;
   my $xfer   = 0;
   $xfer += $output->writeStructBegin('Blur_queryStatusIdList_args');
-  if (defined $self->{session}) {
-    $xfer += $output->writeFieldBegin('session', TType::STRUCT, 1);
-    $xfer += $self->{session}->write($output);
-    $xfer += $output->writeFieldEnd();
-  }
   if (defined $self->{server}) {
-    $xfer += $output->writeFieldBegin('server', TType::STRING, 2);
+    $xfer += $output->writeFieldBegin('server', TType::STRING, 1);
     $xfer += $output->writeString($self->{server});
     $xfer += $output->writeFieldEnd();
   }
@@ -3506,19 +3474,15 @@ sub write {
 
 package Blur::Blur_queryStatus_args;
 use base qw(Class::Accessor);
-Blur::Blur_queryStatus_args->mk_accessors( qw( session server id ) );
+Blur::Blur_queryStatus_args->mk_accessors( qw( server id ) );
 
 sub new {
   my $classname = shift;
   my $self      = {};
   my $vals      = shift || {};
-  $self->{session} = undef;
   $self->{server} = undef;
   $self->{id} = undef;
   if (UNIVERSAL::isa($vals,'HASH')) {
-    if (defined $vals->{session}) {
-      $self->{session} = $vals->{session};
-    }
     if (defined $vals->{server}) {
       $self->{server} = $vals->{server};
     }
@@ -3548,20 +3512,13 @@ sub read {
     }
     SWITCH: for($fid)
     {
-      /^1$/ && do{      if ($ftype == TType::STRUCT) {
-        $self->{session} = new Blur::Session();
-        $xfer += $self->{session}->read($input);
-      } else {
-        $xfer += $input->skip($ftype);
-      }
-      last; };
-      /^2$/ && do{      if ($ftype == TType::STRING) {
+      /^1$/ && do{      if ($ftype == TType::STRING) {
         $xfer += $input->readString(\$self->{server});
       } else {
         $xfer += $input->skip($ftype);
       }
       last; };
-      /^3$/ && do{      if ($ftype == TType::STRING) {
+      /^2$/ && do{      if ($ftype == TType::STRING) {
         $xfer += $input->readString(\$self->{id});
       } else {
         $xfer += $input->skip($ftype);
@@ -3579,18 +3536,13 @@ sub write {
   my ($self, $output) = @_;
   my $xfer   = 0;
   $xfer += $output->writeStructBegin('Blur_queryStatus_args');
-  if (defined $self->{session}) {
-    $xfer += $output->writeFieldBegin('session', TType::STRUCT, 1);
-    $xfer += $self->{session}->write($output);
-    $xfer += $output->writeFieldEnd();
-  }
   if (defined $self->{server}) {
-    $xfer += $output->writeFieldBegin('server', TType::STRING, 2);
+    $xfer += $output->writeFieldBegin('server', TType::STRING, 1);
     $xfer += $output->writeString($self->{server});
     $xfer += $output->writeFieldEnd();
   }
   if (defined $self->{id}) {
-    $xfer += $output->writeFieldBegin('id', TType::STRING, 3);
+    $xfer += $output->writeFieldBegin('id', TType::STRING, 2);
     $xfer += $output->writeString($self->{id});
     $xfer += $output->writeFieldEnd();
   }
@@ -3707,16 +3659,16 @@ sub write {
 
 package Blur::Blur_schema_args;
 use base qw(Class::Accessor);
-Blur::Blur_schema_args->mk_accessors( qw( session ) );
+Blur::Blur_schema_args->mk_accessors( qw( tableName ) );
 
 sub new {
   my $classname = shift;
   my $self      = {};
   my $vals      = shift || {};
-  $self->{session} = undef;
+  $self->{tableName} = undef;
   if (UNIVERSAL::isa($vals,'HASH')) {
-    if (defined $vals->{session}) {
-      $self->{session} = $vals->{session};
+    if (defined $vals->{tableName}) {
+      $self->{tableName} = $vals->{tableName};
     }
   }
   return bless ($self, $classname);
@@ -3741,9 +3693,8 @@ sub read {
     }
     SWITCH: for($fid)
     {
-      /^1$/ && do{      if ($ftype == TType::STRUCT) {
-        $self->{session} = new Blur::Session();
-        $xfer += $self->{session}->read($input);
+      /^1$/ && do{      if ($ftype == TType::STRING) {
+        $xfer += $input->readString(\$self->{tableName});
       } else {
         $xfer += $input->skip($ftype);
       }
@@ -3760,9 +3711,9 @@ sub write {
   my ($self, $output) = @_;
   my $xfer   = 0;
   $xfer += $output->writeStructBegin('Blur_schema_args');
-  if (defined $self->{session}) {
-    $xfer += $output->writeFieldBegin('session', TType::STRUCT, 1);
-    $xfer += $self->{session}->write($output);
+  if (defined $self->{tableName}) {
+    $xfer += $output->writeFieldBegin('tableName', TType::STRING, 1);
+    $xfer += $output->writeString($self->{tableName});
     $xfer += $output->writeFieldEnd();
   }
   $xfer += $output->writeFieldStop();
@@ -4143,7 +4094,6 @@ sub describe{
 
 sub cancelQuery{
   my $self = shift;
-  my $session = shift;
   my $server = shift;
   my $id = shift;
 
@@ -4152,7 +4102,6 @@ sub cancelQuery{
 
 sub queryStatusIdList{
   my $self = shift;
-  my $session = shift;
   my $server = shift;
 
   die 'implement interface';
@@ -4160,7 +4109,6 @@ sub queryStatusIdList{
 
 sub queryStatus{
   my $self = shift;
-  my $session = shift;
   my $server = shift;
   my $id = shift;
 
@@ -4169,7 +4117,7 @@ sub queryStatus{
 
 sub schema{
   my $self = shift;
-  my $session = shift;
+  my $tableName = shift;
 
   die 'implement interface';
 }
@@ -4336,34 +4284,31 @@ sub describe{
 sub cancelQuery{
   my ($self, $request) = @_;
 
-  my $session = ($request->{'session'}) ? $request->{'session'} : undef;
   my $server = ($request->{'server'}) ? $request->{'server'} : undef;
   my $id = ($request->{'id'}) ? $request->{'id'} : undef;
-  return $self->{impl}->cancelQuery($session, $server, $id);
+  return $self->{impl}->cancelQuery($server, $id);
 }
 
 sub queryStatusIdList{
   my ($self, $request) = @_;
 
-  my $session = ($request->{'session'}) ? $request->{'session'} : undef;
   my $server = ($request->{'server'}) ? $request->{'server'} : undef;
-  return $self->{impl}->queryStatusIdList($session, $server);
+  return $self->{impl}->queryStatusIdList($server);
 }
 
 sub queryStatus{
   my ($self, $request) = @_;
 
-  my $session = ($request->{'session'}) ? $request->{'session'} : undef;
   my $server = ($request->{'server'}) ? $request->{'server'} : undef;
   my $id = ($request->{'id'}) ? $request->{'id'} : undef;
-  return $self->{impl}->queryStatus($session, $server, $id);
+  return $self->{impl}->queryStatus($server, $id);
 }
 
 sub schema{
   my ($self, $request) = @_;
 
-  my $session = ($request->{'session'}) ? $request->{'session'} : undef;
-  return $self->{impl}->schema($session);
+  my $tableName = ($request->{'tableName'}) ? $request->{'tableName'} : undef;
+  return $self->{impl}->schema($tableName);
 }
 
 sub tableStats{
@@ -5265,23 +5210,20 @@ sub recv_describe{
 }
 sub cancelQuery{
   my $self = shift;
-  my $session = shift;
   my $server = shift;
   my $id = shift;
 
-    $self->send_cancelQuery($session, $server, $id);
+    $self->send_cancelQuery($server, $id);
   $self->recv_cancelQuery();
 }
 
 sub send_cancelQuery{
   my $self = shift;
-  my $session = shift;
   my $server = shift;
   my $id = shift;
 
   $self->{output}->writeMessageBegin('cancelQuery', TMessageType::CALL, $self->{seqid});
   my $args = new Blur::Blur_cancelQuery_args();
-  $args->{session} = $session;
   $args->{server} = $server;
   $args->{id} = $id;
   $args->write($self->{output});
@@ -5314,21 +5256,18 @@ sub recv_cancelQuery{
 }
 sub queryStatusIdList{
   my $self = shift;
-  my $session = shift;
   my $server = shift;
 
-    $self->send_queryStatusIdList($session, $server);
+    $self->send_queryStatusIdList($server);
   return $self->recv_queryStatusIdList();
 }
 
 sub send_queryStatusIdList{
   my $self = shift;
-  my $session = shift;
   my $server = shift;
 
   $self->{output}->writeMessageBegin('queryStatusIdList', TMessageType::CALL, $self->{seqid});
   my $args = new Blur::Blur_queryStatusIdList_args();
-  $args->{session} = $session;
   $args->{server} = $server;
   $args->write($self->{output});
   $self->{output}->writeMessageEnd();
@@ -5363,23 +5302,20 @@ sub recv_queryStatusIdList{
 }
 sub queryStatus{
   my $self = shift;
-  my $session = shift;
   my $server = shift;
   my $id = shift;
 
-    $self->send_queryStatus($session, $server, $id);
+    $self->send_queryStatus($server, $id);
   return $self->recv_queryStatus();
 }
 
 sub send_queryStatus{
   my $self = shift;
-  my $session = shift;
   my $server = shift;
   my $id = shift;
 
   $self->{output}->writeMessageBegin('queryStatus', TMessageType::CALL, $self->{seqid});
   my $args = new Blur::Blur_queryStatus_args();
-  $args->{session} = $session;
   $args->{server} = $server;
   $args->{id} = $id;
   $args->write($self->{output});
@@ -5415,19 +5351,19 @@ sub recv_queryStatus{
 }
 sub schema{
   my $self = shift;
-  my $session = shift;
+  my $tableName = shift;
 
-    $self->send_schema($session);
+    $self->send_schema($tableName);
   return $self->recv_schema();
 }
 
 sub send_schema{
   my $self = shift;
-  my $session = shift;
+  my $tableName = shift;
 
   $self->{output}->writeMessageBegin('schema', TMessageType::CALL, $self->{seqid});
   my $args = new Blur::Blur_schema_args();
-  $args->{session} = $session;
+  $args->{tableName} = $tableName;
   $args->write($self->{output});
   $self->{output}->writeMessageEnd();
   $self->{output}->getTransport()->flush();
@@ -5869,7 +5805,7 @@ sub process_cancelQuery {
     $input->readMessageEnd();
     my $result = new Blur::Blur_cancelQuery_result();
     eval {
-      $self->{handler}->cancelQuery($args->session, $args->server, $args->id);
+      $self->{handler}->cancelQuery($args->server, $args->id);
     }; if( UNIVERSAL::isa($@,'Blur::BlurException') ){ 
       $result->{ex} = $@;
     }
@@ -5886,7 +5822,7 @@ sub process_queryStatusIdList {
     $input->readMessageEnd();
     my $result = new Blur::Blur_queryStatusIdList_result();
     eval {
-      $result->{success} = $self->{handler}->queryStatusIdList($args->session, $args->server);
+      $result->{success} = $self->{handler}->queryStatusIdList($args->server);
     }; if( UNIVERSAL::isa($@,'Blur::BlurException') ){ 
       $result->{ex} = $@;
     }
@@ -5903,7 +5839,7 @@ sub process_queryStatus {
     $input->readMessageEnd();
     my $result = new Blur::Blur_queryStatus_result();
     eval {
-      $result->{success} = $self->{handler}->queryStatus($args->session, $args->server, $args->id);
+      $result->{success} = $self->{handler}->queryStatus($args->server, $args->id);
     }; if( UNIVERSAL::isa($@,'Blur::BlurException') ){ 
       $result->{ex} = $@;
     }
@@ -5920,7 +5856,7 @@ sub process_schema {
     $input->readMessageEnd();
     my $result = new Blur::Blur_schema_result();
     eval {
-      $result->{success} = $self->{handler}->schema($args->session);
+      $result->{success} = $self->{handler}->schema($args->tableName);
     }; if( UNIVERSAL::isa($@,'Blur::BlurException') ){ 
       $result->{ex} = $@;
     }

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/cf92e0ff/src/distribution/src/main/scripts/interface/gen-rb/blur.rb
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/interface/gen-rb/blur.rb b/src/distribution/src/main/scripts/interface/gen-rb/blur.rb
index e700e32..54b5c0c 100644
--- a/src/distribution/src/main/scripts/interface/gen-rb/blur.rb
+++ b/src/distribution/src/main/scripts/interface/gen-rb/blur.rb
@@ -310,13 +310,13 @@ module Blur
         raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'describe failed: unknown result')
       end
 
-      def cancelQuery(session, server, id)
-        send_cancelQuery(session, server, id)
+      def cancelQuery(server, id)
+        send_cancelQuery(server, id)
         recv_cancelQuery()
       end
 
-      def send_cancelQuery(session, server, id)
-        send_message('cancelQuery', CancelQuery_args, :session => session, :server => server, :id => id)
+      def send_cancelQuery(server, id)
+        send_message('cancelQuery', CancelQuery_args, :server => server, :id => id)
       end
 
       def recv_cancelQuery()
@@ -325,13 +325,13 @@ module Blur
         return
       end
 
-      def queryStatusIdList(session, server)
-        send_queryStatusIdList(session, server)
+      def queryStatusIdList(server)
+        send_queryStatusIdList(server)
         return recv_queryStatusIdList()
       end
 
-      def send_queryStatusIdList(session, server)
-        send_message('queryStatusIdList', QueryStatusIdList_args, :session => session, :server => server)
+      def send_queryStatusIdList(server)
+        send_message('queryStatusIdList', QueryStatusIdList_args, :server => server)
       end
 
       def recv_queryStatusIdList()
@@ -341,13 +341,13 @@ module Blur
         raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'queryStatusIdList failed: unknown result')
       end
 
-      def queryStatus(session, server, id)
-        send_queryStatus(session, server, id)
+      def queryStatus(server, id)
+        send_queryStatus(server, id)
         return recv_queryStatus()
       end
 
-      def send_queryStatus(session, server, id)
-        send_message('queryStatus', QueryStatus_args, :session => session, :server => server, :id => id)
+      def send_queryStatus(server, id)
+        send_message('queryStatus', QueryStatus_args, :server => server, :id => id)
       end
 
       def recv_queryStatus()
@@ -357,13 +357,13 @@ module Blur
         raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'queryStatus failed: unknown result')
       end
 
-      def schema(session)
-        send_schema(session)
+      def schema(tableName)
+        send_schema(tableName)
         return recv_schema()
       end
 
-      def send_schema(session)
-        send_message('schema', Schema_args, :session => session)
+      def send_schema(tableName)
+        send_message('schema', Schema_args, :tableName => tableName)
       end
 
       def recv_schema()
@@ -607,7 +607,7 @@ module Blur
         args = read_args(iprot, CancelQuery_args)
         result = CancelQuery_result.new()
         begin
-          @handler.cancelQuery(args.session, args.server, args.id)
+          @handler.cancelQuery(args.server, args.id)
         rescue ::Blur::BlurException => ex
           result.ex = ex
         end
@@ -618,7 +618,7 @@ module Blur
         args = read_args(iprot, QueryStatusIdList_args)
         result = QueryStatusIdList_result.new()
         begin
-          result.success = @handler.queryStatusIdList(args.session, args.server)
+          result.success = @handler.queryStatusIdList(args.server)
         rescue ::Blur::BlurException => ex
           result.ex = ex
         end
@@ -629,7 +629,7 @@ module Blur
         args = read_args(iprot, QueryStatus_args)
         result = QueryStatus_result.new()
         begin
-          result.success = @handler.queryStatus(args.session, args.server, args.id)
+          result.success = @handler.queryStatus(args.server, args.id)
         rescue ::Blur::BlurException => ex
           result.ex = ex
         end
@@ -640,7 +640,7 @@ module Blur
         args = read_args(iprot, Schema_args)
         result = Schema_result.new()
         begin
-          result.success = @handler.schema(args.session)
+          result.success = @handler.schema(args.tableName)
         rescue ::Blur::BlurException => ex
           result.ex = ex
         end
@@ -1315,12 +1315,10 @@ module Blur
 
     class CancelQuery_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      SESSION = 1
-      SERVER = 2
-      ID = 3
+      SERVER = 1
+      ID = 2
 
       FIELDS = {
-        SESSION => {:type => ::Thrift::Types::STRUCT, :name => 'session', :class => ::Blur::Session},
         SERVER => {:type => ::Thrift::Types::STRING, :name => 'server'},
         ID => {:type => ::Thrift::Types::STRING, :name => 'id'}
       }
@@ -1351,11 +1349,9 @@ module Blur
 
     class QueryStatusIdList_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      SESSION = 1
-      SERVER = 2
+      SERVER = 1
 
       FIELDS = {
-        SESSION => {:type => ::Thrift::Types::STRUCT, :name => 'session', :class => ::Blur::Session},
         SERVER => {:type => ::Thrift::Types::STRING, :name => 'server'}
       }
 
@@ -1387,12 +1383,10 @@ module Blur
 
     class QueryStatus_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      SESSION = 1
-      SERVER = 2
-      ID = 3
+      SERVER = 1
+      ID = 2
 
       FIELDS = {
-        SESSION => {:type => ::Thrift::Types::STRUCT, :name => 'session', :class => ::Blur::Session},
         SERVER => {:type => ::Thrift::Types::STRING, :name => 'server'},
         ID => {:type => ::Thrift::Types::STRING, :name => 'id'}
       }
@@ -1425,10 +1419,10 @@ module Blur
 
     class Schema_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
-      SESSION = 1
+      TABLENAME = 1
 
       FIELDS = {
-        SESSION => {:type => ::Thrift::Types::STRUCT, :name => 'session', :class => ::Blur::Session}
+        TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName'}
       }
 
       def struct_fields; FIELDS; end


Mime
View raw message