incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [5/7] Inital commit of the top command in the blur-shell.
Date Sat, 22 Jun 2013 21:07:06 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/7137006b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java
----------------------------------------------------------------------
diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java
index defcc7d..88b8357 100644
--- a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java
+++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java
@@ -139,6 +139,16 @@ public class Blur {
     public BlurResults query(String table, BlurQuery blurQuery) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException;
 
     /**
+     * Parses the given query and return the string represents the query.
+     * @param table the table name.
+     * @param simpleQuery the query to parse.
+     * 
+     * @param table
+     * @param simpleQuery
+     */
+    public String parseQuery(String table, SimpleQuery simpleQuery) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException;
+
+    /**
      * Cancels a query that is executing against the given table with the given uuid.  Note, the cancel call maybe take some time for the query actually stops executing.
      * @param table the table name.
      * @param uuid the uuid of the query.
@@ -204,6 +214,8 @@ public class Blur {
 
     public Map<String,String> configuration() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException;
 
+    public Map<String,Metric> metrics(Set<String> metrics) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException;
+
   }
 
   public interface AsyncIface {
@@ -226,6 +238,8 @@ public class Blur {
 
     public void query(String table, BlurQuery blurQuery, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.query_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException;
 
+    public void parseQuery(String table, SimpleQuery simpleQuery, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.parseQuery_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException;
+
     public void cancelQuery(String table, long uuid, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.cancelQuery_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException;
 
     public void currentQueries(String table, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.currentQueries_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException;
@@ -264,6 +278,8 @@ public class Blur {
 
     public void configuration(org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.configuration_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException;
 
+    public void metrics(Set<String> metrics, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.metrics_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException;
+
   }
 
   public static class Client extends org.apache.blur.thirdparty.thrift_0_9_0.TServiceClient implements Iface {
@@ -518,6 +534,33 @@ public class Blur {
       throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "query failed: unknown result");
     }
 
+    public String parseQuery(String table, SimpleQuery simpleQuery) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException
+    {
+      send_parseQuery(table, simpleQuery);
+      return recv_parseQuery();
+    }
+
+    public void send_parseQuery(String table, SimpleQuery simpleQuery) throws org.apache.blur.thirdparty.thrift_0_9_0.TException
+    {
+      parseQuery_args args = new parseQuery_args();
+      args.setTable(table);
+      args.setSimpleQuery(simpleQuery);
+      sendBase("parseQuery", args);
+    }
+
+    public String recv_parseQuery() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException
+    {
+      parseQuery_result result = new parseQuery_result();
+      receiveBase(result, "parseQuery");
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.ex != null) {
+        throw result.ex;
+      }
+      throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "parseQuery failed: unknown result");
+    }
+
     public void cancelQuery(String table, long uuid) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException
     {
       send_cancelQuery(table, uuid);
@@ -999,6 +1042,32 @@ public class Blur {
       throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "configuration failed: unknown result");
     }
 
+    public Map<String,Metric> metrics(Set<String> metrics) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException
+    {
+      send_metrics(metrics);
+      return recv_metrics();
+    }
+
+    public void send_metrics(Set<String> metrics) throws org.apache.blur.thirdparty.thrift_0_9_0.TException
+    {
+      metrics_args args = new metrics_args();
+      args.setMetrics(metrics);
+      sendBase("metrics", args);
+    }
+
+    public Map<String,Metric> recv_metrics() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException
+    {
+      metrics_result result = new metrics_result();
+      receiveBase(result, "metrics");
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.ex != null) {
+        throw result.ex;
+      }
+      throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "metrics failed: unknown result");
+    }
+
   }
   public static class AsyncClient extends org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncClient implements AsyncIface {
     public static class Factory implements org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncClientFactory<AsyncClient> {
@@ -1299,6 +1368,41 @@ public class Blur {
       }
     }
 
+    public void parseQuery(String table, SimpleQuery simpleQuery, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<parseQuery_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      checkReady();
+      parseQuery_call method_call = new parseQuery_call(table, simpleQuery, resultHandler, this, ___protocolFactory, ___transport);
+      this.___currentMethod = method_call;
+      ___manager.call(method_call);
+    }
+
+    public static class parseQuery_call extends org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncMethodCall {
+      private String table;
+      private SimpleQuery simpleQuery;
+      public parseQuery_call(String table, SimpleQuery simpleQuery, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<parseQuery_call> resultHandler, org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncClient client, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolFactory protocolFactory, org.apache.blur.thirdparty.thrift_0_9_0.transport.TNonblockingTransport transport) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        super(client, protocolFactory, transport, resultHandler, false);
+        this.table = table;
+        this.simpleQuery = simpleQuery;
+      }
+
+      public void write_args(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        prot.writeMessageBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMessage("parseQuery", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMessageType.CALL, 0));
+        parseQuery_args args = new parseQuery_args();
+        args.setTable(table);
+        args.setSimpleQuery(simpleQuery);
+        args.write(prot);
+        prot.writeMessageEnd();
+      }
+
+      public String getResult() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        if (getState() != org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncMethodCall.State.RESPONSE_READ) {
+          throw new IllegalStateException("Method call not finished!");
+        }
+        org.apache.blur.thirdparty.thrift_0_9_0.transport.TMemoryInputTransport memoryTransport = new org.apache.blur.thirdparty.thrift_0_9_0.transport.TMemoryInputTransport(getFrameBuffer().array());
+        org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+        return (new Client(prot)).recv_parseQuery();
+      }
+    }
+
     public void cancelQuery(String table, long uuid, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<cancelQuery_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
       checkReady();
       cancelQuery_call method_call = new cancelQuery_call(table, uuid, resultHandler, this, ___protocolFactory, ___transport);
@@ -1940,6 +2044,38 @@ public class Blur {
       }
     }
 
+    public void metrics(Set<String> metrics, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<metrics_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      checkReady();
+      metrics_call method_call = new metrics_call(metrics, resultHandler, this, ___protocolFactory, ___transport);
+      this.___currentMethod = method_call;
+      ___manager.call(method_call);
+    }
+
+    public static class metrics_call extends org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncMethodCall {
+      private Set<String> metrics;
+      public metrics_call(Set<String> metrics, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<metrics_call> resultHandler, org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncClient client, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolFactory protocolFactory, org.apache.blur.thirdparty.thrift_0_9_0.transport.TNonblockingTransport transport) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        super(client, protocolFactory, transport, resultHandler, false);
+        this.metrics = metrics;
+      }
+
+      public void write_args(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        prot.writeMessageBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMessage("metrics", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMessageType.CALL, 0));
+        metrics_args args = new metrics_args();
+        args.setMetrics(metrics);
+        args.write(prot);
+        prot.writeMessageEnd();
+      }
+
+      public Map<String,Metric> getResult() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        if (getState() != org.apache.blur.thirdparty.thrift_0_9_0.async.TAsyncMethodCall.State.RESPONSE_READ) {
+          throw new IllegalStateException("Method call not finished!");
+        }
+        org.apache.blur.thirdparty.thrift_0_9_0.transport.TMemoryInputTransport memoryTransport = new org.apache.blur.thirdparty.thrift_0_9_0.transport.TMemoryInputTransport(getFrameBuffer().array());
+        org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
+        return (new Client(prot)).recv_metrics();
+      }
+    }
+
   }
 
   public static class Processor<I extends Iface> extends org.apache.blur.thirdparty.thrift_0_9_0.TBaseProcessor<I> implements org.apache.blur.thirdparty.thrift_0_9_0.TProcessor {
@@ -1962,6 +2098,7 @@ public class Blur {
       processMap.put("tableListByCluster", new tableListByCluster());
       processMap.put("describe", new describe());
       processMap.put("query", new query());
+      processMap.put("parseQuery", new parseQuery());
       processMap.put("cancelQuery", new cancelQuery());
       processMap.put("currentQueries", new currentQueries());
       processMap.put("queryStatusIdList", new queryStatusIdList());
@@ -1981,6 +2118,7 @@ public class Blur {
       processMap.put("optimize", new optimize());
       processMap.put("isInSafeMode", new isInSafeMode());
       processMap.put("configuration", new configuration());
+      processMap.put("metrics", new metrics());
       return processMap;
     }
 
@@ -2200,6 +2338,30 @@ public class Blur {
       }
     }
 
+    public static class parseQuery<I extends Iface> extends org.apache.blur.thirdparty.thrift_0_9_0.ProcessFunction<I, parseQuery_args> {
+      public parseQuery() {
+        super("parseQuery");
+      }
+
+      public parseQuery_args getEmptyArgsInstance() {
+        return new parseQuery_args();
+      }
+
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public parseQuery_result getResult(I iface, parseQuery_args args) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        parseQuery_result result = new parseQuery_result();
+        try {
+          result.success = iface.parseQuery(args.table, args.simpleQuery);
+        } catch (BlurException ex) {
+          result.ex = ex;
+        }
+        return result;
+      }
+    }
+
     public static class cancelQuery<I extends Iface> extends org.apache.blur.thirdparty.thrift_0_9_0.ProcessFunction<I, cancelQuery_args> {
       public cancelQuery() {
         super("cancelQuery");
@@ -2658,6 +2820,30 @@ public class Blur {
       }
     }
 
+    public static class metrics<I extends Iface> extends org.apache.blur.thirdparty.thrift_0_9_0.ProcessFunction<I, metrics_args> {
+      public metrics() {
+        super("metrics");
+      }
+
+      public metrics_args getEmptyArgsInstance() {
+        return new metrics_args();
+      }
+
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public metrics_result getResult(I iface, metrics_args args) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+        metrics_result result = new metrics_result();
+        try {
+          result.success = iface.metrics(args.metrics);
+        } catch (BlurException ex) {
+          result.ex = ex;
+        }
+        return result;
+      }
+    }
+
   }
 
   public static class shardClusterList_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<shardClusterList_args, shardClusterList_args._Fields>, java.io.Serializable, Cloneable   {
@@ -3292,13 +3478,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) {
                 {
-                  org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list176 = iprot.readListBegin();
-                  struct.success = new ArrayList<String>(_list176.size);
-                  for (int _i177 = 0; _i177 < _list176.size; ++_i177)
+                  org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list206 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list206.size);
+                  for (int _i207 = 0; _i207 < _list206.size; ++_i207)
                   {
-                    String _elem178; // required
-                    _elem178 = iprot.readString();
-                    struct.success.add(_elem178);
+                    String _elem208; // required
+                    _elem208 = iprot.readString();
+                    struct.success.add(_elem208);
                   }
                   iprot.readListEnd();
                 }
@@ -3335,9 +3521,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, struct.success.size()));
-            for (String _iter179 : struct.success)
+            for (String _iter209 : struct.success)
             {
-              oprot.writeString(_iter179);
+              oprot.writeString(_iter209);
             }
             oprot.writeListEnd();
           }
@@ -3376,9 +3562,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter180 : struct.success)
+            for (String _iter210 : struct.success)
             {
-              oprot.writeString(_iter180);
+              oprot.writeString(_iter210);
             }
           }
         }
@@ -3393,13 +3579,13 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list181 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32());
-            struct.success = new ArrayList<String>(_list181.size);
-            for (int _i182 = 0; _i182 < _list181.size; ++_i182)
+            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list211 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list211.size);
+            for (int _i212 = 0; _i212 < _list211.size; ++_i212)
             {
-              String _elem183; // required
-              _elem183 = iprot.readString();
-              struct.success.add(_elem183);
+              String _elem213; // required
+              _elem213 = iprot.readString();
+              struct.success.add(_elem213);
             }
           }
           struct.setSuccessIsSet(true);
@@ -4154,13 +4340,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) {
                 {
-                  org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list184 = iprot.readListBegin();
-                  struct.success = new ArrayList<String>(_list184.size);
-                  for (int _i185 = 0; _i185 < _list184.size; ++_i185)
+                  org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list214 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list214.size);
+                  for (int _i215 = 0; _i215 < _list214.size; ++_i215)
                   {
-                    String _elem186; // required
-                    _elem186 = iprot.readString();
-                    struct.success.add(_elem186);
+                    String _elem216; // required
+                    _elem216 = iprot.readString();
+                    struct.success.add(_elem216);
                   }
                   iprot.readListEnd();
                 }
@@ -4197,9 +4383,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, struct.success.size()));
-            for (String _iter187 : struct.success)
+            for (String _iter217 : struct.success)
             {
-              oprot.writeString(_iter187);
+              oprot.writeString(_iter217);
             }
             oprot.writeListEnd();
           }
@@ -4238,9 +4424,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter188 : struct.success)
+            for (String _iter218 : struct.success)
             {
-              oprot.writeString(_iter188);
+              oprot.writeString(_iter218);
             }
           }
         }
@@ -4255,13 +4441,13 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list189 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32());
-            struct.success = new ArrayList<String>(_list189.size);
-            for (int _i190 = 0; _i190 < _list189.size; ++_i190)
+            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list219 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list219.size);
+            for (int _i220 = 0; _i220 < _list219.size; ++_i220)
             {
-              String _elem191; // required
-              _elem191 = iprot.readString();
-              struct.success.add(_elem191);
+              String _elem221; // required
+              _elem221 = iprot.readString();
+              struct.success.add(_elem221);
             }
           }
           struct.setSuccessIsSet(true);
@@ -4908,13 +5094,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) {
                 {
-                  org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list192 = iprot.readListBegin();
-                  struct.success = new ArrayList<String>(_list192.size);
-                  for (int _i193 = 0; _i193 < _list192.size; ++_i193)
+                  org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list222 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list222.size);
+                  for (int _i223 = 0; _i223 < _list222.size; ++_i223)
                   {
-                    String _elem194; // required
-                    _elem194 = iprot.readString();
-                    struct.success.add(_elem194);
+                    String _elem224; // required
+                    _elem224 = iprot.readString();
+                    struct.success.add(_elem224);
                   }
                   iprot.readListEnd();
                 }
@@ -4951,9 +5137,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, struct.success.size()));
-            for (String _iter195 : struct.success)
+            for (String _iter225 : struct.success)
             {
-              oprot.writeString(_iter195);
+              oprot.writeString(_iter225);
             }
             oprot.writeListEnd();
           }
@@ -4992,9 +5178,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter196 : struct.success)
+            for (String _iter226 : struct.success)
             {
-              oprot.writeString(_iter196);
+              oprot.writeString(_iter226);
             }
           }
         }
@@ -5009,13 +5195,13 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list197 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32());
-            struct.success = new ArrayList<String>(_list197.size);
-            for (int _i198 = 0; _i198 < _list197.size; ++_i198)
+            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list227 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list227.size);
+            for (int _i228 = 0; _i228 < _list227.size; ++_i228)
             {
-              String _elem199; // required
-              _elem199 = iprot.readString();
-              struct.success.add(_elem199);
+              String _elem229; // required
+              _elem229 = iprot.readString();
+              struct.success.add(_elem229);
             }
           }
           struct.setSuccessIsSet(true);
@@ -5775,15 +5961,15 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP) {
                 {
-                  org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map200 = iprot.readMapBegin();
-                  struct.success = new HashMap<String,String>(2*_map200.size);
-                  for (int _i201 = 0; _i201 < _map200.size; ++_i201)
+                  org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map230 = iprot.readMapBegin();
+                  struct.success = new HashMap<String,String>(2*_map230.size);
+                  for (int _i231 = 0; _i231 < _map230.size; ++_i231)
                   {
-                    String _key202; // required
-                    String _val203; // optional
-                    _key202 = iprot.readString();
-                    _val203 = iprot.readString();
-                    struct.success.put(_key202, _val203);
+                    String _key232; // required
+                    String _val233; // optional
+                    _key232 = iprot.readString();
+                    _val233 = iprot.readString();
+                    struct.success.put(_key232, _val233);
                   }
                   iprot.readMapEnd();
                 }
@@ -5820,10 +6006,10 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, struct.success.size()));
-            for (Map.Entry<String, String> _iter204 : struct.success.entrySet())
+            for (Map.Entry<String, String> _iter234 : struct.success.entrySet())
             {
-              oprot.writeString(_iter204.getKey());
-              oprot.writeString(_iter204.getValue());
+              oprot.writeString(_iter234.getKey());
+              oprot.writeString(_iter234.getValue());
             }
             oprot.writeMapEnd();
           }
@@ -5862,10 +6048,10 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (Map.Entry<String, String> _iter205 : struct.success.entrySet())
+            for (Map.Entry<String, String> _iter235 : struct.success.entrySet())
             {
-              oprot.writeString(_iter205.getKey());
-              oprot.writeString(_iter205.getValue());
+              oprot.writeString(_iter235.getKey());
+              oprot.writeString(_iter235.getValue());
             }
           }
         }
@@ -5880,15 +6066,15 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map206 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32());
-            struct.success = new HashMap<String,String>(2*_map206.size);
-            for (int _i207 = 0; _i207 < _map206.size; ++_i207)
+            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map236 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32());
+            struct.success = new HashMap<String,String>(2*_map236.size);
+            for (int _i237 = 0; _i237 < _map236.size; ++_i237)
             {
-              String _key208; // required
-              String _val209; // optional
-              _key208 = iprot.readString();
-              _val209 = iprot.readString();
-              struct.success.put(_key208, _val209);
+              String _key238; // required
+              String _val239; // optional
+              _key238 = iprot.readString();
+              _val239 = iprot.readString();
+              struct.success.put(_key238, _val239);
             }
           }
           struct.setSuccessIsSet(true);
@@ -6661,27 +6847,27 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP) {
                 {
-                  org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map210 = iprot.readMapBegin();
-                  struct.success = new HashMap<String,Map<String,ShardState>>(2*_map210.size);
-                  for (int _i211 = 0; _i211 < _map210.size; ++_i211)
+                  org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map240 = iprot.readMapBegin();
+                  struct.success = new HashMap<String,Map<String,ShardState>>(2*_map240.size);
+                  for (int _i241 = 0; _i241 < _map240.size; ++_i241)
                   {
-                    String _key212; // required
-                    Map<String,ShardState> _val213; // optional
-                    _key212 = iprot.readString();
+                    String _key242; // required
+                    Map<String,ShardState> _val243; // optional
+                    _key242 = iprot.readString();
                     {
-                      org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map214 = iprot.readMapBegin();
-                      _val213 = new HashMap<String,ShardState>(2*_map214.size);
-                      for (int _i215 = 0; _i215 < _map214.size; ++_i215)
+                      org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map244 = iprot.readMapBegin();
+                      _val243 = new HashMap<String,ShardState>(2*_map244.size);
+                      for (int _i245 = 0; _i245 < _map244.size; ++_i245)
                       {
-                        String _key216; // required
-                        ShardState _val217; // optional
-                        _key216 = iprot.readString();
-                        _val217 = ShardState.findByValue(iprot.readI32());
-                        _val213.put(_key216, _val217);
+                        String _key246; // required
+                        ShardState _val247; // optional
+                        _key246 = iprot.readString();
+                        _val247 = ShardState.findByValue(iprot.readI32());
+                        _val243.put(_key246, _val247);
                       }
                       iprot.readMapEnd();
                     }
-                    struct.success.put(_key212, _val213);
+                    struct.success.put(_key242, _val243);
                   }
                   iprot.readMapEnd();
                 }
@@ -6718,15 +6904,15 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, struct.success.size()));
-            for (Map.Entry<String, Map<String,ShardState>> _iter218 : struct.success.entrySet())
+            for (Map.Entry<String, Map<String,ShardState>> _iter248 : struct.success.entrySet())
             {
-              oprot.writeString(_iter218.getKey());
+              oprot.writeString(_iter248.getKey());
               {
-                oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32, _iter218.getValue().size()));
-                for (Map.Entry<String, ShardState> _iter219 : _iter218.getValue().entrySet())
+                oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32, _iter248.getValue().size()));
+                for (Map.Entry<String, ShardState> _iter249 : _iter248.getValue().entrySet())
                 {
-                  oprot.writeString(_iter219.getKey());
-                  oprot.writeI32(_iter219.getValue().getValue());
+                  oprot.writeString(_iter249.getKey());
+                  oprot.writeI32(_iter249.getValue().getValue());
                 }
                 oprot.writeMapEnd();
               }
@@ -6768,15 +6954,15 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (Map.Entry<String, Map<String,ShardState>> _iter220 : struct.success.entrySet())
+            for (Map.Entry<String, Map<String,ShardState>> _iter250 : struct.success.entrySet())
             {
-              oprot.writeString(_iter220.getKey());
+              oprot.writeString(_iter250.getKey());
               {
-                oprot.writeI32(_iter220.getValue().size());
-                for (Map.Entry<String, ShardState> _iter221 : _iter220.getValue().entrySet())
+                oprot.writeI32(_iter250.getValue().size());
+                for (Map.Entry<String, ShardState> _iter251 : _iter250.getValue().entrySet())
                 {
-                  oprot.writeString(_iter221.getKey());
-                  oprot.writeI32(_iter221.getValue().getValue());
+                  oprot.writeString(_iter251.getKey());
+                  oprot.writeI32(_iter251.getValue().getValue());
                 }
               }
             }
@@ -6793,26 +6979,26 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map222 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, iprot.readI32());
-            struct.success = new HashMap<String,Map<String,ShardState>>(2*_map222.size);
-            for (int _i223 = 0; _i223 < _map222.size; ++_i223)
+            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map252 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP, iprot.readI32());
+            struct.success = new HashMap<String,Map<String,ShardState>>(2*_map252.size);
+            for (int _i253 = 0; _i253 < _map252.size; ++_i253)
             {
-              String _key224; // required
-              Map<String,ShardState> _val225; // optional
-              _key224 = iprot.readString();
+              String _key254; // required
+              Map<String,ShardState> _val255; // optional
+              _key254 = iprot.readString();
               {
-                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map226 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32, iprot.readI32());
-                _val225 = new HashMap<String,ShardState>(2*_map226.size);
-                for (int _i227 = 0; _i227 < _map226.size; ++_i227)
+                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map256 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32, iprot.readI32());
+                _val255 = new HashMap<String,ShardState>(2*_map256.size);
+                for (int _i257 = 0; _i257 < _map256.size; ++_i257)
                 {
-                  String _key228; // required
-                  ShardState _val229; // optional
-                  _key228 = iprot.readString();
-                  _val229 = ShardState.findByValue(iprot.readI32());
-                  _val225.put(_key228, _val229);
+                  String _key258; // required
+                  ShardState _val259; // optional
+                  _key258 = iprot.readString();
+                  _val259 = ShardState.findByValue(iprot.readI32());
+                  _val255.put(_key258, _val259);
                 }
               }
-              struct.success.put(_key224, _val225);
+              struct.success.put(_key254, _val255);
             }
           }
           struct.setSuccessIsSet(true);
@@ -7459,13 +7645,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) {
                 {
-                  org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list230 = iprot.readListBegin();
-                  struct.success = new ArrayList<String>(_list230.size);
-                  for (int _i231 = 0; _i231 < _list230.size; ++_i231)
+                  org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list260 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list260.size);
+                  for (int _i261 = 0; _i261 < _list260.size; ++_i261)
                   {
-                    String _elem232; // required
-                    _elem232 = iprot.readString();
-                    struct.success.add(_elem232);
+                    String _elem262; // required
+                    _elem262 = iprot.readString();
+                    struct.success.add(_elem262);
                   }
                   iprot.readListEnd();
                 }
@@ -7502,9 +7688,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, struct.success.size()));
-            for (String _iter233 : struct.success)
+            for (String _iter263 : struct.success)
             {
-              oprot.writeString(_iter233);
+              oprot.writeString(_iter263);
             }
             oprot.writeListEnd();
           }
@@ -7543,9 +7729,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter234 : struct.success)
+            for (String _iter264 : struct.success)
             {
-              oprot.writeString(_iter234);
+              oprot.writeString(_iter264);
             }
           }
         }
@@ -7560,13 +7746,13 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list235 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32());
-            struct.success = new ArrayList<String>(_list235.size);
-            for (int _i236 = 0; _i236 < _list235.size; ++_i236)
+            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list265 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list265.size);
+            for (int _i266 = 0; _i266 < _list265.size; ++_i266)
             {
-              String _elem237; // required
-              _elem237 = iprot.readString();
-              struct.success.add(_elem237);
+              String _elem267; // required
+              _elem267 = iprot.readString();
+              struct.success.add(_elem267);
             }
           }
           struct.setSuccessIsSet(true);
@@ -8321,13 +8507,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) {
                 {
-                  org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list238 = iprot.readListBegin();
-                  struct.success = new ArrayList<String>(_list238.size);
-                  for (int _i239 = 0; _i239 < _list238.size; ++_i239)
+                  org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list268 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list268.size);
+                  for (int _i269 = 0; _i269 < _list268.size; ++_i269)
                   {
-                    String _elem240; // required
-                    _elem240 = iprot.readString();
-                    struct.success.add(_elem240);
+                    String _elem270; // required
+                    _elem270 = iprot.readString();
+                    struct.success.add(_elem270);
                   }
                   iprot.readListEnd();
                 }
@@ -8364,9 +8550,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, struct.success.size()));
-            for (String _iter241 : struct.success)
+            for (String _iter271 : struct.success)
             {
-              oprot.writeString(_iter241);
+              oprot.writeString(_iter271);
             }
             oprot.writeListEnd();
           }
@@ -8405,9 +8591,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter242 : struct.success)
+            for (String _iter272 : struct.success)
             {
-              oprot.writeString(_iter242);
+              oprot.writeString(_iter272);
             }
           }
         }
@@ -8422,13 +8608,13 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list243 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32());
-            struct.success = new ArrayList<String>(_list243.size);
-            for (int _i244 = 0; _i244 < _list243.size; ++_i244)
+            org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list273 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list273.size);
+            for (int _i274 = 0; _i274 < _list273.size; ++_i274)
             {
-              String _elem245; // required
-              _elem245 = iprot.readString();
-              struct.success.add(_elem245);
+              String _elem275; // required
+              _elem275 = iprot.readString();
+              struct.success.add(_elem275);
             }
           }
           struct.setSuccessIsSet(true);
@@ -10178,25 +10364,25 @@ public class Blur {
 
   }
 
-  public static class cancelQuery_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<cancelQuery_args, cancelQuery_args._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("cancelQuery_args");
+  public static class parseQuery_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<parseQuery_args, parseQuery_args._Fields>, java.io.Serializable, Cloneable   {
+    private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("parseQuery_args");
 
     private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField TABLE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("table", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)1);
-    private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField UUID_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("uuid", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, (short)2);
+    private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField SIMPLE_QUERY_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("simpleQuery", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)2);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
-      schemes.put(StandardScheme.class, new cancelQuery_argsStandardSchemeFactory());
-      schemes.put(TupleScheme.class, new cancelQuery_argsTupleSchemeFactory());
+      schemes.put(StandardScheme.class, new parseQuery_argsStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new parseQuery_argsTupleSchemeFactory());
     }
 
     public String table; // required
-    public long uuid; // required
+    public SimpleQuery simpleQuery; // required
 
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
     public enum _Fields implements org.apache.blur.thirdparty.thrift_0_9_0.TFieldIdEnum {
       TABLE((short)1, "table"),
-      UUID((short)2, "uuid");
+      SIMPLE_QUERY((short)2, "simpleQuery");
 
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -10213,8 +10399,8 @@ public class Blur {
         switch(fieldId) {
           case 1: // TABLE
             return TABLE;
-          case 2: // UUID
-            return UUID;
+          case 2: // SIMPLE_QUERY
+            return SIMPLE_QUERY;
           default:
             return null;
         }
@@ -10255,59 +10441,56 @@ public class Blur {
     }
 
     // isset id assignments
-    private static final int __UUID_ISSET_ID = 0;
-    private byte __isset_bitfield = 0;
     public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> metaDataMap;
     static {
       Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>(_Fields.class);
       tmpMap.put(_Fields.TABLE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("table", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
           new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING)));
-      tmpMap.put(_Fields.UUID, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("uuid", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
-          new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64)));
+      tmpMap.put(_Fields.SIMPLE_QUERY, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("simpleQuery", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
+          new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.StructMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, SimpleQuery.class)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(cancelQuery_args.class, metaDataMap);
+      org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(parseQuery_args.class, metaDataMap);
     }
 
-    public cancelQuery_args() {
+    public parseQuery_args() {
     }
 
-    public cancelQuery_args(
+    public parseQuery_args(
       String table,
-      long uuid)
+      SimpleQuery simpleQuery)
     {
       this();
       this.table = table;
-      this.uuid = uuid;
-      setUuidIsSet(true);
+      this.simpleQuery = simpleQuery;
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public cancelQuery_args(cancelQuery_args other) {
-      __isset_bitfield = other.__isset_bitfield;
+    public parseQuery_args(parseQuery_args other) {
       if (other.isSetTable()) {
         this.table = other.table;
       }
-      this.uuid = other.uuid;
+      if (other.isSetSimpleQuery()) {
+        this.simpleQuery = new SimpleQuery(other.simpleQuery);
+      }
     }
 
-    public cancelQuery_args deepCopy() {
-      return new cancelQuery_args(this);
+    public parseQuery_args deepCopy() {
+      return new parseQuery_args(this);
     }
 
     @Override
     public void clear() {
       this.table = null;
-      setUuidIsSet(false);
-      this.uuid = 0;
+      this.simpleQuery = null;
     }
 
     public String getTable() {
       return this.table;
     }
 
-    public cancelQuery_args setTable(String table) {
+    public parseQuery_args setTable(String table) {
       this.table = table;
       return this;
     }
@@ -10327,27 +10510,28 @@ public class Blur {
       }
     }
 
-    public long getUuid() {
-      return this.uuid;
+    public SimpleQuery getSimpleQuery() {
+      return this.simpleQuery;
     }
 
-    public cancelQuery_args setUuid(long uuid) {
-      this.uuid = uuid;
-      setUuidIsSet(true);
+    public parseQuery_args setSimpleQuery(SimpleQuery simpleQuery) {
+      this.simpleQuery = simpleQuery;
       return this;
     }
 
-    public void unsetUuid() {
-      __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __UUID_ISSET_ID);
+    public void unsetSimpleQuery() {
+      this.simpleQuery = null;
     }
 
-    /** Returns true if field uuid is set (has been assigned a value) and false otherwise */
-    public boolean isSetUuid() {
-      return EncodingUtils.testBit(__isset_bitfield, __UUID_ISSET_ID);
+    /** Returns true if field simpleQuery is set (has been assigned a value) and false otherwise */
+    public boolean isSetSimpleQuery() {
+      return this.simpleQuery != null;
     }
 
-    public void setUuidIsSet(boolean value) {
-      __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __UUID_ISSET_ID, value);
+    public void setSimpleQueryIsSet(boolean value) {
+      if (!value) {
+        this.simpleQuery = null;
+      }
     }
 
     public void setFieldValue(_Fields field, Object value) {
@@ -10360,11 +10544,11 @@ public class Blur {
         }
         break;
 
-      case UUID:
+      case SIMPLE_QUERY:
         if (value == null) {
-          unsetUuid();
+          unsetSimpleQuery();
         } else {
-          setUuid((Long)value);
+          setSimpleQuery((SimpleQuery)value);
         }
         break;
 
@@ -10376,8 +10560,8 @@ public class Blur {
       case TABLE:
         return getTable();
 
-      case UUID:
-        return Long.valueOf(getUuid());
+      case SIMPLE_QUERY:
+        return getSimpleQuery();
 
       }
       throw new IllegalStateException();
@@ -10392,8 +10576,8 @@ public class Blur {
       switch (field) {
       case TABLE:
         return isSetTable();
-      case UUID:
-        return isSetUuid();
+      case SIMPLE_QUERY:
+        return isSetSimpleQuery();
       }
       throw new IllegalStateException();
     }
@@ -10402,12 +10586,12 @@ public class Blur {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof cancelQuery_args)
-        return this.equals((cancelQuery_args)that);
+      if (that instanceof parseQuery_args)
+        return this.equals((parseQuery_args)that);
       return false;
     }
 
-    public boolean equals(cancelQuery_args that) {
+    public boolean equals(parseQuery_args that) {
       if (that == null)
         return false;
 
@@ -10420,12 +10604,12 @@ public class Blur {
           return false;
       }
 
-      boolean this_present_uuid = true;
-      boolean that_present_uuid = true;
-      if (this_present_uuid || that_present_uuid) {
-        if (!(this_present_uuid && that_present_uuid))
+      boolean this_present_simpleQuery = true && this.isSetSimpleQuery();
+      boolean that_present_simpleQuery = true && that.isSetSimpleQuery();
+      if (this_present_simpleQuery || that_present_simpleQuery) {
+        if (!(this_present_simpleQuery && that_present_simpleQuery))
           return false;
-        if (this.uuid != that.uuid)
+        if (!this.simpleQuery.equals(that.simpleQuery))
           return false;
       }
 
@@ -10437,13 +10621,13 @@ public class Blur {
       return 0;
     }
 
-    public int compareTo(cancelQuery_args other) {
+    public int compareTo(parseQuery_args other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
-      cancelQuery_args typedOther = (cancelQuery_args)other;
+      parseQuery_args typedOther = (parseQuery_args)other;
 
       lastComparison = Boolean.valueOf(isSetTable()).compareTo(typedOther.isSetTable());
       if (lastComparison != 0) {
@@ -10455,12 +10639,12 @@ public class Blur {
           return lastComparison;
         }
       }
-      lastComparison = Boolean.valueOf(isSetUuid()).compareTo(typedOther.isSetUuid());
+      lastComparison = Boolean.valueOf(isSetSimpleQuery()).compareTo(typedOther.isSetSimpleQuery());
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetUuid()) {
-        lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.uuid, typedOther.uuid);
+      if (isSetSimpleQuery()) {
+        lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.simpleQuery, typedOther.simpleQuery);
         if (lastComparison != 0) {
           return lastComparison;
         }
@@ -10482,7 +10666,7 @@ public class Blur {
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("cancelQuery_args(");
+      StringBuilder sb = new StringBuilder("parseQuery_args(");
       boolean first = true;
 
       sb.append("table:");
@@ -10493,8 +10677,12 @@ public class Blur {
       }
       first = false;
       if (!first) sb.append(", ");
-      sb.append("uuid:");
-      sb.append(this.uuid);
+      sb.append("simpleQuery:");
+      if (this.simpleQuery == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.simpleQuery);
+      }
       first = false;
       sb.append(")");
       return sb.toString();
@@ -10503,6 +10691,9 @@ public class Blur {
     public void validate() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
       // check for required fields
       // check for sub-struct validity
+      if (simpleQuery != null) {
+        simpleQuery.validate();
+      }
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -10515,23 +10706,21 @@ public class Blur {
 
     private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
       try {
-        // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
-        __isset_bitfield = 0;
         read(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(in)));
       } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) {
         throw new java.io.IOException(te);
       }
     }
 
-    private static class cancelQuery_argsStandardSchemeFactory implements SchemeFactory {
-      public cancelQuery_argsStandardScheme getScheme() {
-        return new cancelQuery_argsStandardScheme();
+    private static class parseQuery_argsStandardSchemeFactory implements SchemeFactory {
+      public parseQuery_argsStandardScheme getScheme() {
+        return new parseQuery_argsStandardScheme();
       }
     }
 
-    private static class cancelQuery_argsStandardScheme extends StandardScheme<cancelQuery_args> {
+    private static class parseQuery_argsStandardScheme extends StandardScheme<parseQuery_args> {
 
-      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, cancelQuery_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, parseQuery_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField schemeField;
         iprot.readStructBegin();
         while (true)
@@ -10549,10 +10738,11 @@ public class Blur {
                 org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
               }
               break;
-            case 2: // UUID
-              if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64) {
-                struct.uuid = iprot.readI64();
-                struct.setUuidIsSet(true);
+            case 2: // SIMPLE_QUERY
+              if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT) {
+                struct.simpleQuery = new SimpleQuery();
+                struct.simpleQuery.read(iprot);
+                struct.setSimpleQueryIsSet(true);
               } else { 
                 org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
               }
@@ -10568,7 +10758,7 @@ public class Blur {
         struct.validate();
       }
 
-      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, cancelQuery_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, parseQuery_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
@@ -10577,44 +10767,46 @@ public class Blur {
           oprot.writeString(struct.table);
           oprot.writeFieldEnd();
         }
-        oprot.writeFieldBegin(UUID_FIELD_DESC);
-        oprot.writeI64(struct.uuid);
-        oprot.writeFieldEnd();
+        if (struct.simpleQuery != null) {
+          oprot.writeFieldBegin(SIMPLE_QUERY_FIELD_DESC);
+          struct.simpleQuery.write(oprot);
+          oprot.writeFieldEnd();
+        }
         oprot.writeFieldStop();
         oprot.writeStructEnd();
       }
 
     }
 
-    private static class cancelQuery_argsTupleSchemeFactory implements SchemeFactory {
-      public cancelQuery_argsTupleScheme getScheme() {
-        return new cancelQuery_argsTupleScheme();
+    private static class parseQuery_argsTupleSchemeFactory implements SchemeFactory {
+      public parseQuery_argsTupleScheme getScheme() {
+        return new parseQuery_argsTupleScheme();
       }
     }
 
-    private static class cancelQuery_argsTupleScheme extends TupleScheme<cancelQuery_args> {
+    private static class parseQuery_argsTupleScheme extends TupleScheme<parseQuery_args> {
 
       @Override
-      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, cancelQuery_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, parseQuery_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
         if (struct.isSetTable()) {
           optionals.set(0);
         }
-        if (struct.isSetUuid()) {
+        if (struct.isSetSimpleQuery()) {
           optionals.set(1);
         }
         oprot.writeBitSet(optionals, 2);
         if (struct.isSetTable()) {
           oprot.writeString(struct.table);
         }
-        if (struct.isSetUuid()) {
-          oprot.writeI64(struct.uuid);
+        if (struct.isSetSimpleQuery()) {
+          struct.simpleQuery.write(oprot);
         }
       }
 
       @Override
-      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, cancelQuery_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, parseQuery_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         TTupleProtocol iprot = (TTupleProtocol) prot;
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
@@ -10622,29 +10814,33 @@ public class Blur {
           struct.setTableIsSet(true);
         }
         if (incoming.get(1)) {
-          struct.uuid = iprot.readI64();
-          struct.setUuidIsSet(true);
+          struct.simpleQuery = new SimpleQuery();
+          struct.simpleQuery.read(iprot);
+          struct.setSimpleQueryIsSet(true);
         }
       }
     }
 
   }
 
-  public static class cancelQuery_result implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<cancelQuery_result, cancelQuery_result._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("cancelQuery_result");
+  public static class parseQuery_result implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<parseQuery_result, parseQuery_result._Fields>, java.io.Serializable, Cloneable   {
+    private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("parseQuery_result");
 
+    private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField SUCCESS_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("success", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)0);
     private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField EX_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("ex", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)1);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
-      schemes.put(StandardScheme.class, new cancelQuery_resultStandardSchemeFactory());
-      schemes.put(TupleScheme.class, new cancelQuery_resultTupleSchemeFactory());
+      schemes.put(StandardScheme.class, new parseQuery_resultStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new parseQuery_resultTupleSchemeFactory());
     }
 
+    public String success; // required
     public BlurException ex; // required
 
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
     public enum _Fields implements org.apache.blur.thirdparty.thrift_0_9_0.TFieldIdEnum {
+      SUCCESS((short)0, "success"),
       EX((short)1, "ex");
 
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -10660,6 +10856,8 @@ public class Blur {
        */
       public static _Fields findByThriftId(int fieldId) {
         switch(fieldId) {
+          case 0: // SUCCESS
+            return SUCCESS;
           case 1: // EX
             return EX;
           default:
@@ -10705,66 +10903,106 @@ public class Blur {
     public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> metaDataMap;
     static {
       Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>(_Fields.class);
+      tmpMap.put(_Fields.SUCCESS, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("success", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
+          new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING)));
       tmpMap.put(_Fields.EX, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("ex", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
           new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(cancelQuery_result.class, metaDataMap);
+      org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(parseQuery_result.class, metaDataMap);
     }
 
-    public cancelQuery_result() {
+    public parseQuery_result() {
     }
 
-    public cancelQuery_result(
+    public parseQuery_result(
+      String success,
       BlurException ex)
     {
       this();
+      this.success = success;
       this.ex = ex;
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public cancelQuery_result(cancelQuery_result other) {
+    public parseQuery_result(parseQuery_result other) {
+      if (other.isSetSuccess()) {
+        this.success = other.success;
+      }
       if (other.isSetEx()) {
         this.ex = new BlurException(other.ex);
       }
     }
 
-    public cancelQuery_result deepCopy() {
-      return new cancelQuery_result(this);
+    public parseQuery_result deepCopy() {
+      return new parseQuery_result(this);
     }
 
     @Override
     public void clear() {
+      this.success = null;
       this.ex = null;
     }
 
-    public BlurException getEx() {
-      return this.ex;
+    public String getSuccess() {
+      return this.success;
     }
 
-    public cancelQuery_result setEx(BlurException ex) {
-      this.ex = ex;
+    public parseQuery_result setSuccess(String success) {
+      this.success = success;
       return this;
     }
 
-    public void unsetEx() {
-      this.ex = null;
+    public void unsetSuccess() {
+      this.success = null;
     }
 
-    /** Returns true if field ex is set (has been assigned a value) and false otherwise */
-    public boolean isSetEx() {
-      return this.ex != null;
+    /** Returns true if field success is set (has been assigned a value) and false otherwise */
+    public boolean isSetSuccess() {
+      return this.success != null;
     }
 
-    public void setExIsSet(boolean value) {
+    public void setSuccessIsSet(boolean value) {
       if (!value) {
-        this.ex = null;
+        this.success = null;
       }
     }
 
-    public void setFieldValue(_Fields field, Object value) {
-      switch (field) {
+    public BlurException getEx() {
+      return this.ex;
+    }
+
+    public parseQuery_result setEx(BlurException ex) {
+      this.ex = ex;
+      return this;
+    }
+
+    public void unsetEx() {
+      this.ex = null;
+    }
+
+    /** Returns true if field ex is set (has been assigned a value) and false otherwise */
+    public boolean isSetEx() {
+      return this.ex != null;
+    }
+
+    public void setExIsSet(boolean value) {
+      if (!value) {
+        this.ex = null;
+      }
+    }
+
+    public void setFieldValue(_Fields field, Object value) {
+      switch (field) {
+      case SUCCESS:
+        if (value == null) {
+          unsetSuccess();
+        } else {
+          setSuccess((String)value);
+        }
+        break;
+
       case EX:
         if (value == null) {
           unsetEx();
@@ -10778,6 +11016,9 @@ public class Blur {
 
     public Object getFieldValue(_Fields field) {
       switch (field) {
+      case SUCCESS:
+        return getSuccess();
+
       case EX:
         return getEx();
 
@@ -10792,6 +11033,8 @@ public class Blur {
       }
 
       switch (field) {
+      case SUCCESS:
+        return isSetSuccess();
       case EX:
         return isSetEx();
       }
@@ -10802,15 +11045,24 @@ public class Blur {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof cancelQuery_result)
-        return this.equals((cancelQuery_result)that);
+      if (that instanceof parseQuery_result)
+        return this.equals((parseQuery_result)that);
       return false;
     }
 
-    public boolean equals(cancelQuery_result that) {
+    public boolean equals(parseQuery_result that) {
       if (that == null)
         return false;
 
+      boolean this_present_success = true && this.isSetSuccess();
+      boolean that_present_success = true && that.isSetSuccess();
+      if (this_present_success || that_present_success) {
+        if (!(this_present_success && that_present_success))
+          return false;
+        if (!this.success.equals(that.success))
+          return false;
+      }
+
       boolean this_present_ex = true && this.isSetEx();
       boolean that_present_ex = true && that.isSetEx();
       if (this_present_ex || that_present_ex) {
@@ -10828,14 +11080,24 @@ public class Blur {
       return 0;
     }
 
-    public int compareTo(cancelQuery_result other) {
+    public int compareTo(parseQuery_result other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
-      cancelQuery_result typedOther = (cancelQuery_result)other;
+      parseQuery_result typedOther = (parseQuery_result)other;
 
+      lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      if (isSetSuccess()) {
+        lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.success, typedOther.success);
+        if (lastComparison != 0) {
+          return lastComparison;
+        }
+      }
       lastComparison = Boolean.valueOf(isSetEx()).compareTo(typedOther.isSetEx());
       if (lastComparison != 0) {
         return lastComparison;
@@ -10863,9 +11125,17 @@ public class Blur {
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("cancelQuery_result(");
+      StringBuilder sb = new StringBuilder("parseQuery_result(");
       boolean first = true;
 
+      sb.append("success:");
+      if (this.success == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.success);
+      }
+      first = false;
+      if (!first) sb.append(", ");
       sb.append("ex:");
       if (this.ex == null) {
         sb.append("null");
@@ -10898,15 +11168,15 @@ public class Blur {
       }
     }
 
-    private static class cancelQuery_resultStandardSchemeFactory implements SchemeFactory {
-      public cancelQuery_resultStandardScheme getScheme() {
-        return new cancelQuery_resultStandardScheme();
+    private static class parseQuery_resultStandardSchemeFactory implements SchemeFactory {
+      public parseQuery_resultStandardScheme getScheme() {
+        return new parseQuery_resultStandardScheme();
       }
     }
 
-    private static class cancelQuery_resultStandardScheme extends StandardScheme<cancelQuery_result> {
+    private static class parseQuery_resultStandardScheme extends StandardScheme<parseQuery_result> {
 
-      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, cancelQuery_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, parseQuery_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField schemeField;
         iprot.readStructBegin();
         while (true)
@@ -10916,6 +11186,14 @@ public class Blur {
             break;
           }
           switch (schemeField.id) {
+            case 0: // SUCCESS
+              if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING) {
+                struct.success = iprot.readString();
+                struct.setSuccessIsSet(true);
+              } else { 
+                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
             case 1: // EX
               if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT) {
                 struct.ex = new BlurException();
@@ -10936,10 +11214,15 @@ public class Blur {
         struct.validate();
       }
 
-      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, cancelQuery_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, parseQuery_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
+        if (struct.success != null) {
+          oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+          oprot.writeString(struct.success);
+          oprot.writeFieldEnd();
+        }
         if (struct.ex != null) {
           oprot.writeFieldBegin(EX_FIELD_DESC);
           struct.ex.write(oprot);
@@ -10951,32 +11234,42 @@ public class Blur {
 
     }
 
-    private static class cancelQuery_resultTupleSchemeFactory implements SchemeFactory {
-      public cancelQuery_resultTupleScheme getScheme() {
-        return new cancelQuery_resultTupleScheme();
+    private static class parseQuery_resultTupleSchemeFactory implements SchemeFactory {
+      public parseQuery_resultTupleScheme getScheme() {
+        return new parseQuery_resultTupleScheme();
       }
     }
 
-    private static class cancelQuery_resultTupleScheme extends TupleScheme<cancelQuery_result> {
+    private static class parseQuery_resultTupleScheme extends TupleScheme<parseQuery_result> {
 
       @Override
-      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, cancelQuery_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, parseQuery_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
-        if (struct.isSetEx()) {
+        if (struct.isSetSuccess()) {
           optionals.set(0);
         }
-        oprot.writeBitSet(optionals, 1);
+        if (struct.isSetEx()) {
+          optionals.set(1);
+        }
+        oprot.writeBitSet(optionals, 2);
+        if (struct.isSetSuccess()) {
+          oprot.writeString(struct.success);
+        }
         if (struct.isSetEx()) {
           struct.ex.write(oprot);
         }
       }
 
       @Override
-      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, cancelQuery_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, parseQuery_result struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         TTupleProtocol iprot = (TTupleProtocol) prot;
-        BitSet incoming = iprot.readBitSet(1);
+        BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
+          struct.success = iprot.readString();
+          struct.setSuccessIsSet(true);
+        }
+        if (incoming.get(1)) {
           struct.ex = new BlurException();
           struct.ex.read(iprot);
           struct.setExIsSet(true);
@@ -10986,22 +11279,25 @@ public class Blur {
 
   }
 
-  public static class currentQueries_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<currentQueries_args, currentQueries_args._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("currentQueries_args");
+  public static class cancelQuery_args implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<cancelQuery_args, cancelQuery_args._Fields>, java.io.Serializable, Cloneable   {
+    private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("cancelQuery_args");
 
     private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField TABLE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("table", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)1);
+    private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField UUID_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("uuid", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, (short)2);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
-      schemes.put(StandardScheme.class, new currentQueries_argsStandardSchemeFactory());
-      schemes.put(TupleScheme.class, new currentQueries_argsTupleSchemeFactory());
+      schemes.put(StandardScheme.class, new cancelQuery_argsStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new cancelQuery_argsTupleSchemeFactory());
     }
 
     public String table; // required
+    public long uuid; // required
 
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
     public enum _Fields implements org.apache.blur.thirdparty.thrift_0_9_0.TFieldIdEnum {
-      TABLE((short)1, "table");
+      TABLE((short)1, "table"),
+      UUID((short)2, "uuid");
 
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -11018,6 +11314,8 @@ public class Blur {
         switch(fieldId) {
           case 1: // TABLE
             return TABLE;
+          case 2: // UUID
+            return UUID;
           default:
             return null;
         }
@@ -11058,48 +11356,59 @@ public class Blur {
     }
 
     // isset id assignments
+    private static final int __UUID_ISSET_ID = 0;
+    private byte __isset_bitfield = 0;
     public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> metaDataMap;
     static {
       Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>(_Fields.class);
       tmpMap.put(_Fields.TABLE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("table", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
           new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING)));
+      tmpMap.put(_Fields.UUID, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("uuid", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
+          new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(currentQueries_args.class, metaDataMap);
+      org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(cancelQuery_args.class, metaDataMap);
     }
 
-    public currentQueries_args() {
+    public cancelQuery_args() {
     }
 
-    public currentQueries_args(
-      String table)
+    public cancelQuery_args(
+      String table,
+      long uuid)
     {
       this();
       this.table = table;
+      this.uuid = uuid;
+      setUuidIsSet(true);
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public currentQueries_args(currentQueries_args other) {
+    public cancelQuery_args(cancelQuery_args other) {
+      __isset_bitfield = other.__isset_bitfield;
       if (other.isSetTable()) {
         this.table = other.table;
       }
+      this.uuid = other.uuid;
     }
 
-    public currentQueries_args deepCopy() {
-      return new currentQueries_args(this);
+    public cancelQuery_args deepCopy() {
+      return new cancelQuery_args(this);
     }
 
     @Override
     public void clear() {
       this.table = null;
+      setUuidIsSet(false);
+      this.uuid = 0;
     }
 
     public String getTable() {
       return this.table;
     }
 
-    public currentQueries_args setTable(String table) {
+    public cancelQuery_args setTable(String table) {
       this.table = table;
       return this;
     }
@@ -11119,6 +11428,29 @@ public class Blur {
       }
     }
 
+    public long getUuid() {
+      return this.uuid;
+    }
+
+    public cancelQuery_args setUuid(long uuid) {
+      this.uuid = uuid;
+      setUuidIsSet(true);
+      return this;
+    }
+
+    public void unsetUuid() {
+      __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __UUID_ISSET_ID);
+    }
+
+    /** Returns true if field uuid is set (has been assigned a value) and false otherwise */
+    public boolean isSetUuid() {
+      return EncodingUtils.testBit(__isset_bitfield, __UUID_ISSET_ID);
+    }
+
+    public void setUuidIsSet(boolean value) {
+      __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __UUID_ISSET_ID, value);
+    }
+
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
       case TABLE:
@@ -11129,6 +11461,14 @@ public class Blur {
         }
         break;
 
+      case UUID:
+        if (value == null) {
+          unsetUuid();
+        } else {
+          setUuid((Long)value);
+        }
+        break;
+
       }
     }
 
@@ -11137,6 +11477,9 @@ public class Blur {
       case TABLE:
         return getTable();
 
+      case UUID:
+        return Long.valueOf(getUuid());
+
       }
       throw new IllegalStateException();
     }
@@ -11150,6 +11493,8 @@ public class Blur {
       switch (field) {
       case TABLE:
         return isSetTable();
+      case UUID:
+        return isSetUuid();
       }
       throw new IllegalStateException();
     }
@@ -11158,12 +11503,12 @@ public class Blur {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof currentQueries_args)
-        return this.equals((currentQueries_args)that);
+      if (that instanceof cancelQuery_args)
+        return this.equals((cancelQuery_args)that);
       return false;
     }
 
-    public boolean equals(currentQueries_args that) {
+    public boolean equals(cancelQuery_args that) {
       if (that == null)
         return false;
 
@@ -11176,6 +11521,15 @@ public class Blur {
           return false;
       }
 
+      boolean this_present_uuid = true;
+      boolean that_present_uuid = true;
+      if (this_present_uuid || that_present_uuid) {
+        if (!(this_present_uuid && that_present_uuid))
+          return false;
+        if (this.uuid != that.uuid)
+          return false;
+      }
+
       return true;
     }
 
@@ -11184,13 +11538,13 @@ public class Blur {
       return 0;
     }
 
-    public int compareTo(currentQueries_args other) {
+    public int compareTo(cancelQuery_args other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
-      currentQueries_args typedOther = (currentQueries_args)other;
+      cancelQuery_args typedOther = (cancelQuery_args)other;
 
       lastComparison = Boolean.valueOf(isSetTable()).compareTo(typedOther.isSetTable());
       if (lastComparison != 0) {
@@ -11202,6 +11556,16 @@ public class Blur {
           return lastComparison;
         }
       }
+      lastComparison = Boolean.valueOf(isSetUuid()).compareTo(typedOther.isSetUuid());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      if (isSetUuid()) {
+        lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.uuid, typedOther.uuid);
+        if (lastComparison != 0) {
+          return lastComparison;
+        }
+      }
       return 0;
     }
 
@@ -11219,7 +11583,7 @@ public class Blur {
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("currentQueries_args(");
+      StringBuilder sb = new StringBuilder("cancelQuery_args(");
       boolean first = true;
 
       sb.append("table:");
@@ -11229,6 +11593,10 @@ public class Blur {
         sb.append(this.table);
       }
       first = false;
+      if (!first) sb.append(", ");
+      sb.append("uuid:");
+      sb.append(this.uuid);
+      first = false;
       sb.append(")");
       return sb.toString();
     }
@@ -11248,21 +11616,23 @@ public class Blur {
 
     private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
       try {
+        // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+        __isset_bitfield = 0;
         read(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(in)));
       } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) {
         throw new java.io.IOException(te);
       }
     }
 
-    private static class currentQueries_argsStandardSchemeFactory implements SchemeFactory {
-      public currentQueries_argsStandardScheme getScheme() {
-        return new currentQueries_argsStandardScheme();
+    private static class cancelQuery_argsStandardSchemeFactory implements SchemeFactory {
+      public cancelQuery_argsStandardScheme getScheme() {
+        return new cancelQuery_argsStandardScheme();
       }
     }
 
-    private static class currentQueries_argsStandardScheme extends StandardScheme<currentQueries_args> {
+    private static class cancelQuery_argsStandardScheme extends StandardScheme<cancelQuery_args> {
 
-      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, currentQueries_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, cancelQuery_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField schemeField;
         iprot.readStructBegin();
         while (true)
@@ -11280,6 +11650,14 @@ public class Blur {
                 org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
               }
               break;
+            case 2: // UUID
+              if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64) {
+                struct.uuid = iprot.readI64();
+                struct.setUuidIsSet(true);
+              } else { 
+                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
             default:
               org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
           }
@@ -11291,7 +11669,7 @@ public class Blur {
         struct.validate();
       }
 
-      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, currentQueries_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+      public void write(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot, cancelQuery_args struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
@@ -11300,64 +11678,74 @@ public class Blur {
           oprot.writeString(struct.table);
           oprot.writeFieldEnd();
         }
+        oprot.writeFieldBegin(UUID_FIELD_DESC);
+        oprot.writeI64(struct.uuid);
+        oprot.writeFieldEnd();
         oprot.writeFieldStop();
         oprot.writeStructEnd();
       }
 
     }
 
-    private static class currentQueries_argsTupleSchemeFactory implements SchemeFactory {
-      public currentQueries_argsTupleScheme getScheme() {
-        return new currentQueries_argsTupleScheme();
+    private static class cancelQuery_argsTupleSchemeFactory implements SchemeFactory {
+      public cancelQuery_argsTupleScheme getScheme() {
+        return new cancelQuery_argsTupleScheme();
       }
     }
 
-    private static class currentQueries_argsTupleScheme extends TupleScheme<currentQueries_args> {
+    private static class cancelQuery_argsTupleScheme extends TupleScheme<cancelQuery_args> {
 
       @Ov

<TRUNCATED>

Mime
View raw message