incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [6/11] Fixes to the pom file.
Date Thu, 10 Jan 2013 19:49:57 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/0e4ecb11/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java
----------------------------------------------------------------------
diff --git a/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java b/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java
index 1ebd02e..8d2d0f3 100644
--- a/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java
+++ b/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Blur.java
@@ -236,8 +236,8 @@ public class Blur {
     /**
      * 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.
+     * @param session the Session.
+     * @param id the uuid of the query.
      * 
      * @param session
      * @param id
@@ -246,7 +246,7 @@ public class Blur {
 
     /**
      * Returns a list of the query ids of queries that have recently been executed for the given table.
-     * @param table the table name.
+     * @param session the Session.
      * @return the uuids of the query status objects.
      * 
      * @param session
@@ -255,8 +255,8 @@ public class Blur {
 
     /**
      * Returns the query status for the given table and query uuid.
-     * @param table the table name.
-     * @param uuid the uuid of the query.
+     * @param session the Session.
+     * @param id the uuid of the query.
      * @return the query status for the given.
      * 
      * @param session
@@ -264,7 +264,16 @@ public class Blur {
      */
     public QueryStatus queryStatus(Session session, long id) throws BlurException, org.apache.thrift.TException;
 
-    public LiveSchema schema(String table) throws BlurException, org.apache.thrift.TException;
+    /**
+     * Returns the the schema for the given session.
+     * @param session the Session.
+     * @param list of shard ids to fetch the schema.
+     * @return the table schema.
+     * 
+     * @param session
+     * @param shardsIds
+     */
+    public TableSchema schema(Session session, List<Integer> shardsIds) throws BlurException, org.apache.thrift.TException;
 
     public TableStats tableStats(String table) throws BlurException, org.apache.thrift.TException;
 
@@ -316,7 +325,7 @@ public class Blur {
 
     public void queryStatus(Session session, long id, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.queryStatus_call> resultHandler) throws org.apache.thrift.TException;
 
-    public void schema(String table, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.schema_call> resultHandler) throws org.apache.thrift.TException;
+    public void schema(Session session, List<Integer> shardsIds, 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;
 
@@ -902,20 +911,21 @@ public class Blur {
       throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "queryStatus failed: unknown result");
     }
 
-    public LiveSchema schema(String table) throws BlurException, org.apache.thrift.TException
+    public TableSchema schema(Session session, List<Integer> shardsIds) throws BlurException, org.apache.thrift.TException
     {
-      send_schema(table);
+      send_schema(session, shardsIds);
       return recv_schema();
     }
 
-    public void send_schema(String table) throws org.apache.thrift.TException
+    public void send_schema(Session session, List<Integer> shardsIds) throws org.apache.thrift.TException
     {
       schema_args args = new schema_args();
-      args.setTable(table);
+      args.setSession(session);
+      args.setShardsIds(shardsIds);
       sendBase("schema", args);
     }
 
-    public LiveSchema recv_schema() throws BlurException, org.apache.thrift.TException
+    public TableSchema recv_schema() throws BlurException, org.apache.thrift.TException
     {
       schema_result result = new schema_result();
       receiveBase(result, "schema");
@@ -1703,29 +1713,32 @@ public class Blur {
       }
     }
 
-    public void schema(String table, org.apache.thrift.async.AsyncMethodCallback<schema_call> resultHandler) throws org.apache.thrift.TException {
+    public void schema(Session session, List<Integer> shardsIds, org.apache.thrift.async.AsyncMethodCallback<schema_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
-      schema_call method_call = new schema_call(table, resultHandler, this, ___protocolFactory, ___transport);
+      schema_call method_call = new schema_call(session, shardsIds, resultHandler, this, ___protocolFactory, ___transport);
       this.___currentMethod = method_call;
       ___manager.call(method_call);
     }
 
     public static class schema_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      public schema_call(String table, 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 Session session;
+      private List<Integer> shardsIds;
+      public schema_call(Session session, List<Integer> shardsIds, 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.table = table;
+        this.session = session;
+        this.shardsIds = shardsIds;
       }
 
       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.setTable(table);
+        args.setSession(session);
+        args.setShardsIds(shardsIds);
         args.write(prot);
         prot.writeMessageEnd();
       }
 
-      public LiveSchema getResult() throws BlurException, org.apache.thrift.TException {
+      public TableSchema getResult() throws BlurException, org.apache.thrift.TException {
         if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
           throw new IllegalStateException("Method call not finished!");
         }
@@ -2352,7 +2365,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.table);
+          result.success = iface.schema(args.session, args.shardsIds);
         } catch (BlurException ex) {
           result.ex = ex;
         }
@@ -4051,14 +4064,14 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list128 = iprot.readListBegin();
-                  struct.success = new ArrayList<TopFieldDocs>(_list128.size);
-                  for (int _i129 = 0; _i129 < _list128.size; ++_i129)
+                  org.apache.thrift.protocol.TList _list118 = iprot.readListBegin();
+                  struct.success = new ArrayList<TopFieldDocs>(_list118.size);
+                  for (int _i119 = 0; _i119 < _list118.size; ++_i119)
                   {
-                    TopFieldDocs _elem130; // required
-                    _elem130 = new TopFieldDocs();
-                    _elem130.read(iprot);
-                    struct.success.add(_elem130);
+                    TopFieldDocs _elem120; // required
+                    _elem120 = new TopFieldDocs();
+                    _elem120.read(iprot);
+                    struct.success.add(_elem120);
                   }
                   iprot.readListEnd();
                 }
@@ -4095,9 +4108,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
-            for (TopFieldDocs _iter131 : struct.success)
+            for (TopFieldDocs _iter121 : struct.success)
             {
-              _iter131.write(oprot);
+              _iter121.write(oprot);
             }
             oprot.writeListEnd();
           }
@@ -4136,9 +4149,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (TopFieldDocs _iter132 : struct.success)
+            for (TopFieldDocs _iter122 : struct.success)
             {
-              _iter132.write(oprot);
+              _iter122.write(oprot);
             }
           }
         }
@@ -4153,14 +4166,14 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list133 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-            struct.success = new ArrayList<TopFieldDocs>(_list133.size);
-            for (int _i134 = 0; _i134 < _list133.size; ++_i134)
+            org.apache.thrift.protocol.TList _list123 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+            struct.success = new ArrayList<TopFieldDocs>(_list123.size);
+            for (int _i124 = 0; _i124 < _list123.size; ++_i124)
             {
-              TopFieldDocs _elem135; // required
-              _elem135 = new TopFieldDocs();
-              _elem135.read(iprot);
-              struct.success.add(_elem135);
+              TopFieldDocs _elem125; // required
+              _elem125 = new TopFieldDocs();
+              _elem125.read(iprot);
+              struct.success.add(_elem125);
             }
           }
           struct.setSuccessIsSet(true);
@@ -4670,13 +4683,13 @@ public class Blur {
             case 2: // DOC_LOCATIONS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list136 = iprot.readListBegin();
-                  struct.docLocations = new ArrayList<Long>(_list136.size);
-                  for (int _i137 = 0; _i137 < _list136.size; ++_i137)
+                  org.apache.thrift.protocol.TList _list126 = iprot.readListBegin();
+                  struct.docLocations = new ArrayList<Long>(_list126.size);
+                  for (int _i127 = 0; _i127 < _list126.size; ++_i127)
                   {
-                    long _elem138; // required
-                    _elem138 = iprot.readI64();
-                    struct.docLocations.add(_elem138);
+                    long _elem128; // required
+                    _elem128 = iprot.readI64();
+                    struct.docLocations.add(_elem128);
                   }
                   iprot.readListEnd();
                 }
@@ -4688,13 +4701,13 @@ public class Blur {
             case 4: // FIELDS
               if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
                 {
-                  org.apache.thrift.protocol.TSet _set139 = iprot.readSetBegin();
-                  struct.fields = new HashSet<String>(2*_set139.size);
-                  for (int _i140 = 0; _i140 < _set139.size; ++_i140)
+                  org.apache.thrift.protocol.TSet _set129 = iprot.readSetBegin();
+                  struct.fields = new HashSet<String>(2*_set129.size);
+                  for (int _i130 = 0; _i130 < _set129.size; ++_i130)
                   {
-                    String _elem141; // required
-                    _elem141 = iprot.readString();
-                    struct.fields.add(_elem141);
+                    String _elem131; // required
+                    _elem131 = iprot.readString();
+                    struct.fields.add(_elem131);
                   }
                   iprot.readSetEnd();
                 }
@@ -4727,9 +4740,9 @@ public class Blur {
           oprot.writeFieldBegin(DOC_LOCATIONS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.docLocations.size()));
-            for (long _iter142 : struct.docLocations)
+            for (long _iter132 : struct.docLocations)
             {
-              oprot.writeI64(_iter142);
+              oprot.writeI64(_iter132);
             }
             oprot.writeListEnd();
           }
@@ -4739,9 +4752,9 @@ public class Blur {
           oprot.writeFieldBegin(FIELDS_FIELD_DESC);
           {
             oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, struct.fields.size()));
-            for (String _iter143 : struct.fields)
+            for (String _iter133 : struct.fields)
             {
-              oprot.writeString(_iter143);
+              oprot.writeString(_iter133);
             }
             oprot.writeSetEnd();
           }
@@ -4781,18 +4794,18 @@ public class Blur {
         if (struct.isSetDocLocations()) {
           {
             oprot.writeI32(struct.docLocations.size());
-            for (long _iter144 : struct.docLocations)
+            for (long _iter134 : struct.docLocations)
             {
-              oprot.writeI64(_iter144);
+              oprot.writeI64(_iter134);
             }
           }
         }
         if (struct.isSetFields()) {
           {
             oprot.writeI32(struct.fields.size());
-            for (String _iter145 : struct.fields)
+            for (String _iter135 : struct.fields)
             {
-              oprot.writeString(_iter145);
+              oprot.writeString(_iter135);
             }
           }
         }
@@ -4809,26 +4822,26 @@ public class Blur {
         }
         if (incoming.get(1)) {
           {
-            org.apache.thrift.protocol.TList _list146 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
-            struct.docLocations = new ArrayList<Long>(_list146.size);
-            for (int _i147 = 0; _i147 < _list146.size; ++_i147)
+            org.apache.thrift.protocol.TList _list136 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+            struct.docLocations = new ArrayList<Long>(_list136.size);
+            for (int _i137 = 0; _i137 < _list136.size; ++_i137)
             {
-              long _elem148; // required
-              _elem148 = iprot.readI64();
-              struct.docLocations.add(_elem148);
+              long _elem138; // required
+              _elem138 = iprot.readI64();
+              struct.docLocations.add(_elem138);
             }
           }
           struct.setDocLocationsIsSet(true);
         }
         if (incoming.get(2)) {
           {
-            org.apache.thrift.protocol.TSet _set149 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
-            struct.fields = new HashSet<String>(2*_set149.size);
-            for (int _i150 = 0; _i150 < _set149.size; ++_i150)
+            org.apache.thrift.protocol.TSet _set139 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.fields = new HashSet<String>(2*_set139.size);
+            for (int _i140 = 0; _i140 < _set139.size; ++_i140)
             {
-              String _elem151; // required
-              _elem151 = iprot.readString();
-              struct.fields.add(_elem151);
+              String _elem141; // required
+              _elem141 = iprot.readString();
+              struct.fields.add(_elem141);
             }
           }
           struct.setFieldsIsSet(true);
@@ -5224,14 +5237,14 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list152 = iprot.readListBegin();
-                  struct.success = new ArrayList<Document>(_list152.size);
-                  for (int _i153 = 0; _i153 < _list152.size; ++_i153)
+                  org.apache.thrift.protocol.TList _list142 = iprot.readListBegin();
+                  struct.success = new ArrayList<Document>(_list142.size);
+                  for (int _i143 = 0; _i143 < _list142.size; ++_i143)
                   {
-                    Document _elem154; // required
-                    _elem154 = new Document();
-                    _elem154.read(iprot);
-                    struct.success.add(_elem154);
+                    Document _elem144; // required
+                    _elem144 = new Document();
+                    _elem144.read(iprot);
+                    struct.success.add(_elem144);
                   }
                   iprot.readListEnd();
                 }
@@ -5268,9 +5281,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
-            for (Document _iter155 : struct.success)
+            for (Document _iter145 : struct.success)
             {
-              _iter155.write(oprot);
+              _iter145.write(oprot);
             }
             oprot.writeListEnd();
           }
@@ -5309,9 +5322,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (Document _iter156 : struct.success)
+            for (Document _iter146 : struct.success)
             {
-              _iter156.write(oprot);
+              _iter146.write(oprot);
             }
           }
         }
@@ -5326,14 +5339,14 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list157 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-            struct.success = new ArrayList<Document>(_list157.size);
-            for (int _i158 = 0; _i158 < _list157.size; ++_i158)
+            org.apache.thrift.protocol.TList _list147 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+            struct.success = new ArrayList<Document>(_list147.size);
+            for (int _i148 = 0; _i148 < _list147.size; ++_i148)
             {
-              Document _elem159; // required
-              _elem159 = new Document();
-              _elem159.read(iprot);
-              struct.success.add(_elem159);
+              Document _elem149; // required
+              _elem149 = new Document();
+              _elem149.read(iprot);
+              struct.success.add(_elem149);
             }
           }
           struct.setSuccessIsSet(true);
@@ -6461,14 +6474,14 @@ public class Blur {
             case 2: // DOCUMENTS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list160 = iprot.readListBegin();
-                  struct.documents = new ArrayList<Document>(_list160.size);
-                  for (int _i161 = 0; _i161 < _list160.size; ++_i161)
+                  org.apache.thrift.protocol.TList _list150 = iprot.readListBegin();
+                  struct.documents = new ArrayList<Document>(_list150.size);
+                  for (int _i151 = 0; _i151 < _list150.size; ++_i151)
                   {
-                    Document _elem162; // required
-                    _elem162 = new Document();
-                    _elem162.read(iprot);
-                    struct.documents.add(_elem162);
+                    Document _elem152; // required
+                    _elem152 = new Document();
+                    _elem152.read(iprot);
+                    struct.documents.add(_elem152);
                   }
                   iprot.readListEnd();
                 }
@@ -6501,9 +6514,9 @@ public class Blur {
           oprot.writeFieldBegin(DOCUMENTS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.documents.size()));
-            for (Document _iter163 : struct.documents)
+            for (Document _iter153 : struct.documents)
             {
-              _iter163.write(oprot);
+              _iter153.write(oprot);
             }
             oprot.writeListEnd();
           }
@@ -6540,9 +6553,9 @@ public class Blur {
         if (struct.isSetDocuments()) {
           {
             oprot.writeI32(struct.documents.size());
-            for (Document _iter164 : struct.documents)
+            for (Document _iter154 : struct.documents)
             {
-              _iter164.write(oprot);
+              _iter154.write(oprot);
             }
           }
         }
@@ -6559,14 +6572,14 @@ public class Blur {
         }
         if (incoming.get(1)) {
           {
-            org.apache.thrift.protocol.TList _list165 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-            struct.documents = new ArrayList<Document>(_list165.size);
-            for (int _i166 = 0; _i166 < _list165.size; ++_i166)
+            org.apache.thrift.protocol.TList _list155 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+            struct.documents = new ArrayList<Document>(_list155.size);
+            for (int _i156 = 0; _i156 < _list155.size; ++_i156)
             {
-              Document _elem167; // required
-              _elem167 = new Document();
-              _elem167.read(iprot);
-              struct.documents.add(_elem167);
+              Document _elem157; // required
+              _elem157 = new Document();
+              _elem157.read(iprot);
+              struct.documents.add(_elem157);
             }
           }
           struct.setDocumentsIsSet(true);
@@ -6962,14 +6975,14 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list168 = iprot.readListBegin();
-                  struct.success = new ArrayList<Generation>(_list168.size);
-                  for (int _i169 = 0; _i169 < _list168.size; ++_i169)
+                  org.apache.thrift.protocol.TList _list158 = iprot.readListBegin();
+                  struct.success = new ArrayList<Generation>(_list158.size);
+                  for (int _i159 = 0; _i159 < _list158.size; ++_i159)
                   {
-                    Generation _elem170; // required
-                    _elem170 = new Generation();
-                    _elem170.read(iprot);
-                    struct.success.add(_elem170);
+                    Generation _elem160; // required
+                    _elem160 = new Generation();
+                    _elem160.read(iprot);
+                    struct.success.add(_elem160);
                   }
                   iprot.readListEnd();
                 }
@@ -7006,9 +7019,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
-            for (Generation _iter171 : struct.success)
+            for (Generation _iter161 : struct.success)
             {
-              _iter171.write(oprot);
+              _iter161.write(oprot);
             }
             oprot.writeListEnd();
           }
@@ -7047,9 +7060,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (Generation _iter172 : struct.success)
+            for (Generation _iter162 : struct.success)
             {
-              _iter172.write(oprot);
+              _iter162.write(oprot);
             }
           }
         }
@@ -7064,14 +7077,14 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list173 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-            struct.success = new ArrayList<Generation>(_list173.size);
-            for (int _i174 = 0; _i174 < _list173.size; ++_i174)
+            org.apache.thrift.protocol.TList _list163 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+            struct.success = new ArrayList<Generation>(_list163.size);
+            for (int _i164 = 0; _i164 < _list163.size; ++_i164)
             {
-              Generation _elem175; // required
-              _elem175 = new Generation();
-              _elem175.read(iprot);
-              struct.success.add(_elem175);
+              Generation _elem165; // required
+              _elem165 = new Generation();
+              _elem165.read(iprot);
+              struct.success.add(_elem165);
             }
           }
           struct.setSuccessIsSet(true);
@@ -7484,14 +7497,14 @@ public class Blur {
             case 2: // QUERIES
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list176 = iprot.readListBegin();
-                  struct.queries = new ArrayList<Query>(_list176.size);
-                  for (int _i177 = 0; _i177 < _list176.size; ++_i177)
+                  org.apache.thrift.protocol.TList _list166 = iprot.readListBegin();
+                  struct.queries = new ArrayList<Query>(_list166.size);
+                  for (int _i167 = 0; _i167 < _list166.size; ++_i167)
                   {
-                    Query _elem178; // required
-                    _elem178 = new Query();
-                    _elem178.read(iprot);
-                    struct.queries.add(_elem178);
+                    Query _elem168; // required
+                    _elem168 = new Query();
+                    _elem168.read(iprot);
+                    struct.queries.add(_elem168);
                   }
                   iprot.readListEnd();
                 }
@@ -7524,9 +7537,9 @@ public class Blur {
           oprot.writeFieldBegin(QUERIES_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.queries.size()));
-            for (Query _iter179 : struct.queries)
+            for (Query _iter169 : struct.queries)
             {
-              _iter179.write(oprot);
+              _iter169.write(oprot);
             }
             oprot.writeListEnd();
           }
@@ -7563,9 +7576,9 @@ public class Blur {
         if (struct.isSetQueries()) {
           {
             oprot.writeI32(struct.queries.size());
-            for (Query _iter180 : struct.queries)
+            for (Query _iter170 : struct.queries)
             {
-              _iter180.write(oprot);
+              _iter170.write(oprot);
             }
           }
         }
@@ -7582,14 +7595,14 @@ public class Blur {
         }
         if (incoming.get(1)) {
           {
-            org.apache.thrift.protocol.TList _list181 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-            struct.queries = new ArrayList<Query>(_list181.size);
-            for (int _i182 = 0; _i182 < _list181.size; ++_i182)
+            org.apache.thrift.protocol.TList _list171 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+            struct.queries = new ArrayList<Query>(_list171.size);
+            for (int _i172 = 0; _i172 < _list171.size; ++_i172)
             {
-              Query _elem183; // required
-              _elem183 = new Query();
-              _elem183.read(iprot);
-              struct.queries.add(_elem183);
+              Query _elem173; // required
+              _elem173 = new Query();
+              _elem173.read(iprot);
+              struct.queries.add(_elem173);
             }
           }
           struct.setQueriesIsSet(true);
@@ -7985,14 +7998,14 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list184 = iprot.readListBegin();
-                  struct.success = new ArrayList<Generation>(_list184.size);
-                  for (int _i185 = 0; _i185 < _list184.size; ++_i185)
+                  org.apache.thrift.protocol.TList _list174 = iprot.readListBegin();
+                  struct.success = new ArrayList<Generation>(_list174.size);
+                  for (int _i175 = 0; _i175 < _list174.size; ++_i175)
                   {
-                    Generation _elem186; // required
-                    _elem186 = new Generation();
-                    _elem186.read(iprot);
-                    struct.success.add(_elem186);
+                    Generation _elem176; // required
+                    _elem176 = new Generation();
+                    _elem176.read(iprot);
+                    struct.success.add(_elem176);
                   }
                   iprot.readListEnd();
                 }
@@ -8029,9 +8042,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
-            for (Generation _iter187 : struct.success)
+            for (Generation _iter177 : struct.success)
             {
-              _iter187.write(oprot);
+              _iter177.write(oprot);
             }
             oprot.writeListEnd();
           }
@@ -8070,9 +8083,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (Generation _iter188 : struct.success)
+            for (Generation _iter178 : struct.success)
             {
-              _iter188.write(oprot);
+              _iter178.write(oprot);
             }
           }
         }
@@ -8087,14 +8100,14 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list189 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-            struct.success = new ArrayList<Generation>(_list189.size);
-            for (int _i190 = 0; _i190 < _list189.size; ++_i190)
+            org.apache.thrift.protocol.TList _list179 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+            struct.success = new ArrayList<Generation>(_list179.size);
+            for (int _i180 = 0; _i180 < _list179.size; ++_i180)
             {
-              Generation _elem191; // required
-              _elem191 = new Generation();
-              _elem191.read(iprot);
-              struct.success.add(_elem191);
+              Generation _elem181; // required
+              _elem181 = new Generation();
+              _elem181.read(iprot);
+              struct.success.add(_elem181);
             }
           }
           struct.setSuccessIsSet(true);
@@ -8507,14 +8520,14 @@ public class Blur {
             case 2: // TERMS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list192 = iprot.readListBegin();
-                  struct.terms = new ArrayList<Term>(_list192.size);
-                  for (int _i193 = 0; _i193 < _list192.size; ++_i193)
+                  org.apache.thrift.protocol.TList _list182 = iprot.readListBegin();
+                  struct.terms = new ArrayList<Term>(_list182.size);
+                  for (int _i183 = 0; _i183 < _list182.size; ++_i183)
                   {
-                    Term _elem194; // required
-                    _elem194 = new Term();
-                    _elem194.read(iprot);
-                    struct.terms.add(_elem194);
+                    Term _elem184; // required
+                    _elem184 = new Term();
+                    _elem184.read(iprot);
+                    struct.terms.add(_elem184);
                   }
                   iprot.readListEnd();
                 }
@@ -8547,9 +8560,9 @@ public class Blur {
           oprot.writeFieldBegin(TERMS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.terms.size()));
-            for (Term _iter195 : struct.terms)
+            for (Term _iter185 : struct.terms)
             {
-              _iter195.write(oprot);
+              _iter185.write(oprot);
             }
             oprot.writeListEnd();
           }
@@ -8586,9 +8599,9 @@ public class Blur {
         if (struct.isSetTerms()) {
           {
             oprot.writeI32(struct.terms.size());
-            for (Term _iter196 : struct.terms)
+            for (Term _iter186 : struct.terms)
             {
-              _iter196.write(oprot);
+              _iter186.write(oprot);
             }
           }
         }
@@ -8605,14 +8618,14 @@ public class Blur {
         }
         if (incoming.get(1)) {
           {
-            org.apache.thrift.protocol.TList _list197 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-            struct.terms = new ArrayList<Term>(_list197.size);
-            for (int _i198 = 0; _i198 < _list197.size; ++_i198)
+            org.apache.thrift.protocol.TList _list187 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+            struct.terms = new ArrayList<Term>(_list187.size);
+            for (int _i188 = 0; _i188 < _list187.size; ++_i188)
             {
-              Term _elem199; // required
-              _elem199 = new Term();
-              _elem199.read(iprot);
-              struct.terms.add(_elem199);
+              Term _elem189; // required
+              _elem189 = new Term();
+              _elem189.read(iprot);
+              struct.terms.add(_elem189);
             }
           }
           struct.setTermsIsSet(true);
@@ -9008,14 +9021,14 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list200 = iprot.readListBegin();
-                  struct.success = new ArrayList<Generation>(_list200.size);
-                  for (int _i201 = 0; _i201 < _list200.size; ++_i201)
+                  org.apache.thrift.protocol.TList _list190 = iprot.readListBegin();
+                  struct.success = new ArrayList<Generation>(_list190.size);
+                  for (int _i191 = 0; _i191 < _list190.size; ++_i191)
                   {
-                    Generation _elem202; // required
-                    _elem202 = new Generation();
-                    _elem202.read(iprot);
-                    struct.success.add(_elem202);
+                    Generation _elem192; // required
+                    _elem192 = new Generation();
+                    _elem192.read(iprot);
+                    struct.success.add(_elem192);
                   }
                   iprot.readListEnd();
                 }
@@ -9052,9 +9065,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
-            for (Generation _iter203 : struct.success)
+            for (Generation _iter193 : struct.success)
             {
-              _iter203.write(oprot);
+              _iter193.write(oprot);
             }
             oprot.writeListEnd();
           }
@@ -9093,9 +9106,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (Generation _iter204 : struct.success)
+            for (Generation _iter194 : struct.success)
             {
-              _iter204.write(oprot);
+              _iter194.write(oprot);
             }
           }
         }
@@ -9110,14 +9123,14 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list205 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-            struct.success = new ArrayList<Generation>(_list205.size);
-            for (int _i206 = 0; _i206 < _list205.size; ++_i206)
+            org.apache.thrift.protocol.TList _list195 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+            struct.success = new ArrayList<Generation>(_list195.size);
+            for (int _i196 = 0; _i196 < _list195.size; ++_i196)
             {
-              Generation _elem207; // required
-              _elem207 = new Generation();
-              _elem207.read(iprot);
-              struct.success.add(_elem207);
+              Generation _elem197; // required
+              _elem197 = new Generation();
+              _elem197.read(iprot);
+              struct.success.add(_elem197);
             }
           }
           struct.setSuccessIsSet(true);
@@ -9530,14 +9543,14 @@ public class Blur {
             case 2: // UPDATE_PACKAGES
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list208 = iprot.readListBegin();
-                  struct.updatePackages = new ArrayList<UpdatePackage>(_list208.size);
-                  for (int _i209 = 0; _i209 < _list208.size; ++_i209)
+                  org.apache.thrift.protocol.TList _list198 = iprot.readListBegin();
+                  struct.updatePackages = new ArrayList<UpdatePackage>(_list198.size);
+                  for (int _i199 = 0; _i199 < _list198.size; ++_i199)
                   {
-                    UpdatePackage _elem210; // required
-                    _elem210 = new UpdatePackage();
-                    _elem210.read(iprot);
-                    struct.updatePackages.add(_elem210);
+                    UpdatePackage _elem200; // required
+                    _elem200 = new UpdatePackage();
+                    _elem200.read(iprot);
+                    struct.updatePackages.add(_elem200);
                   }
                   iprot.readListEnd();
                 }
@@ -9570,9 +9583,9 @@ public class Blur {
           oprot.writeFieldBegin(UPDATE_PACKAGES_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.updatePackages.size()));
-            for (UpdatePackage _iter211 : struct.updatePackages)
+            for (UpdatePackage _iter201 : struct.updatePackages)
             {
-              _iter211.write(oprot);
+              _iter201.write(oprot);
             }
             oprot.writeListEnd();
           }
@@ -9609,9 +9622,9 @@ public class Blur {
         if (struct.isSetUpdatePackages()) {
           {
             oprot.writeI32(struct.updatePackages.size());
-            for (UpdatePackage _iter212 : struct.updatePackages)
+            for (UpdatePackage _iter202 : struct.updatePackages)
             {
-              _iter212.write(oprot);
+              _iter202.write(oprot);
             }
           }
         }
@@ -9628,14 +9641,14 @@ public class Blur {
         }
         if (incoming.get(1)) {
           {
-            org.apache.thrift.protocol.TList _list213 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-            struct.updatePackages = new ArrayList<UpdatePackage>(_list213.size);
-            for (int _i214 = 0; _i214 < _list213.size; ++_i214)
+            org.apache.thrift.protocol.TList _list203 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+            struct.updatePackages = new ArrayList<UpdatePackage>(_list203.size);
+            for (int _i204 = 0; _i204 < _list203.size; ++_i204)
             {
-              UpdatePackage _elem215; // required
-              _elem215 = new UpdatePackage();
-              _elem215.read(iprot);
-              struct.updatePackages.add(_elem215);
+              UpdatePackage _elem205; // required
+              _elem205 = new UpdatePackage();
+              _elem205.read(iprot);
+              struct.updatePackages.add(_elem205);
             }
           }
           struct.setUpdatePackagesIsSet(true);
@@ -10031,14 +10044,14 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list216 = iprot.readListBegin();
-                  struct.success = new ArrayList<Generation>(_list216.size);
-                  for (int _i217 = 0; _i217 < _list216.size; ++_i217)
+                  org.apache.thrift.protocol.TList _list206 = iprot.readListBegin();
+                  struct.success = new ArrayList<Generation>(_list206.size);
+                  for (int _i207 = 0; _i207 < _list206.size; ++_i207)
                   {
-                    Generation _elem218; // required
-                    _elem218 = new Generation();
-                    _elem218.read(iprot);
-                    struct.success.add(_elem218);
+                    Generation _elem208; // required
+                    _elem208 = new Generation();
+                    _elem208.read(iprot);
+                    struct.success.add(_elem208);
                   }
                   iprot.readListEnd();
                 }
@@ -10075,9 +10088,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
-            for (Generation _iter219 : struct.success)
+            for (Generation _iter209 : struct.success)
             {
-              _iter219.write(oprot);
+              _iter209.write(oprot);
             }
             oprot.writeListEnd();
           }
@@ -10116,9 +10129,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (Generation _iter220 : struct.success)
+            for (Generation _iter210 : struct.success)
             {
-              _iter220.write(oprot);
+              _iter210.write(oprot);
             }
           }
         }
@@ -10133,14 +10146,14 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list221 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-            struct.success = new ArrayList<Generation>(_list221.size);
-            for (int _i222 = 0; _i222 < _list221.size; ++_i222)
+            org.apache.thrift.protocol.TList _list211 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+            struct.success = new ArrayList<Generation>(_list211.size);
+            for (int _i212 = 0; _i212 < _list211.size; ++_i212)
             {
-              Generation _elem223; // required
-              _elem223 = new Generation();
-              _elem223.read(iprot);
-              struct.success.add(_elem223);
+              Generation _elem213; // required
+              _elem213 = new Generation();
+              _elem213.read(iprot);
+              struct.success.add(_elem213);
             }
           }
           struct.setSuccessIsSet(true);
@@ -10541,14 +10554,14 @@ public class Blur {
             case 1: // GENERATIONS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list224 = iprot.readListBegin();
-                  struct.generations = new ArrayList<Generation>(_list224.size);
-                  for (int _i225 = 0; _i225 < _list224.size; ++_i225)
+                  org.apache.thrift.protocol.TList _list214 = iprot.readListBegin();
+                  struct.generations = new ArrayList<Generation>(_list214.size);
+                  for (int _i215 = 0; _i215 < _list214.size; ++_i215)
                   {
-                    Generation _elem226; // required
-                    _elem226 = new Generation();
-                    _elem226.read(iprot);
-                    struct.generations.add(_elem226);
+                    Generation _elem216; // required
+                    _elem216 = new Generation();
+                    _elem216.read(iprot);
+                    struct.generations.add(_elem216);
                   }
                   iprot.readListEnd();
                 }
@@ -10584,9 +10597,9 @@ public class Blur {
           oprot.writeFieldBegin(GENERATIONS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.generations.size()));
-            for (Generation _iter227 : struct.generations)
+            for (Generation _iter217 : struct.generations)
             {
-              _iter227.write(oprot);
+              _iter217.write(oprot);
             }
             oprot.writeListEnd();
           }
@@ -10623,9 +10636,9 @@ public class Blur {
         if (struct.isSetGenerations()) {
           {
             oprot.writeI32(struct.generations.size());
-            for (Generation _iter228 : struct.generations)
+            for (Generation _iter218 : struct.generations)
             {
-              _iter228.write(oprot);
+              _iter218.write(oprot);
             }
           }
         }
@@ -10640,14 +10653,14 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list229 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-            struct.generations = new ArrayList<Generation>(_list229.size);
-            for (int _i230 = 0; _i230 < _list229.size; ++_i230)
+            org.apache.thrift.protocol.TList _list219 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+            struct.generations = new ArrayList<Generation>(_list219.size);
+            for (int _i220 = 0; _i220 < _list219.size; ++_i220)
             {
-              Generation _elem231; // required
-              _elem231 = new Generation();
-              _elem231.read(iprot);
-              struct.generations.add(_elem231);
+              Generation _elem221; // required
+              _elem221 = new Generation();
+              _elem221.read(iprot);
+              struct.generations.add(_elem221);
             }
           }
           struct.setGenerationsIsSet(true);
@@ -11649,13 +11662,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list232 = iprot.readListBegin();
-                  struct.success = new ArrayList<String>(_list232.size);
-                  for (int _i233 = 0; _i233 < _list232.size; ++_i233)
+                  org.apache.thrift.protocol.TList _list222 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list222.size);
+                  for (int _i223 = 0; _i223 < _list222.size; ++_i223)
                   {
-                    String _elem234; // required
-                    _elem234 = iprot.readString();
-                    struct.success.add(_elem234);
+                    String _elem224; // required
+                    _elem224 = iprot.readString();
+                    struct.success.add(_elem224);
                   }
                   iprot.readListEnd();
                 }
@@ -11692,9 +11705,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
-            for (String _iter235 : struct.success)
+            for (String _iter225 : struct.success)
             {
-              oprot.writeString(_iter235);
+              oprot.writeString(_iter225);
             }
             oprot.writeListEnd();
           }
@@ -11733,9 +11746,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter236 : struct.success)
+            for (String _iter226 : struct.success)
             {
-              oprot.writeString(_iter236);
+              oprot.writeString(_iter226);
             }
           }
         }
@@ -11750,13 +11763,13 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list237 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
-            struct.success = new ArrayList<String>(_list237.size);
-            for (int _i238 = 0; _i238 < _list237.size; ++_i238)
+            org.apache.thrift.protocol.TList _list227 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list227.size);
+            for (int _i228 = 0; _i228 < _list227.size; ++_i228)
             {
-              String _elem239; // required
-              _elem239 = iprot.readString();
-              struct.success.add(_elem239);
+              String _elem229; // required
+              _elem229 = iprot.readString();
+              struct.success.add(_elem229);
             }
           }
           struct.setSuccessIsSet(true);
@@ -12611,13 +12624,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list240 = iprot.readListBegin();
-                  struct.success = new ArrayList<Integer>(_list240.size);
-                  for (int _i241 = 0; _i241 < _list240.size; ++_i241)
+                  org.apache.thrift.protocol.TList _list230 = iprot.readListBegin();
+                  struct.success = new ArrayList<Integer>(_list230.size);
+                  for (int _i231 = 0; _i231 < _list230.size; ++_i231)
                   {
-                    int _elem242; // required
-                    _elem242 = iprot.readI32();
-                    struct.success.add(_elem242);
+                    int _elem232; // required
+                    _elem232 = iprot.readI32();
+                    struct.success.add(_elem232);
                   }
                   iprot.readListEnd();
                 }
@@ -12654,9 +12667,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, struct.success.size()));
-            for (int _iter243 : struct.success)
+            for (int _iter233 : struct.success)
             {
-              oprot.writeI32(_iter243);
+              oprot.writeI32(_iter233);
             }
             oprot.writeListEnd();
           }
@@ -12695,9 +12708,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (int _iter244 : struct.success)
+            for (int _iter234 : struct.success)
             {
-              oprot.writeI32(_iter244);
+              oprot.writeI32(_iter234);
             }
           }
         }
@@ -12712,13 +12725,13 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list245 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, iprot.readI32());
-            struct.success = new ArrayList<Integer>(_list245.size);
-            for (int _i246 = 0; _i246 < _list245.size; ++_i246)
+            org.apache.thrift.protocol.TList _list235 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, iprot.readI32());
+            struct.success = new ArrayList<Integer>(_list235.size);
+            for (int _i236 = 0; _i236 < _list235.size; ++_i236)
             {
-              int _elem247; // required
-              _elem247 = iprot.readI32();
-              struct.success.add(_elem247);
+              int _elem237; // required
+              _elem237 = iprot.readI32();
+              struct.success.add(_elem237);
             }
           }
           struct.setSuccessIsSet(true);
@@ -13478,16 +13491,16 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
                 {
-                  org.apache.thrift.protocol.TMap _map248 = iprot.readMapBegin();
-                  struct.success = new HashMap<String,ShardLayout>(2*_map248.size);
-                  for (int _i249 = 0; _i249 < _map248.size; ++_i249)
+                  org.apache.thrift.protocol.TMap _map238 = iprot.readMapBegin();
+                  struct.success = new HashMap<String,ShardLayout>(2*_map238.size);
+                  for (int _i239 = 0; _i239 < _map238.size; ++_i239)
                   {
-                    String _key250; // required
-                    ShardLayout _val251; // optional
-                    _key250 = iprot.readString();
-                    _val251 = new ShardLayout();
-                    _val251.read(iprot);
-                    struct.success.put(_key250, _val251);
+                    String _key240; // required
+                    ShardLayout _val241; // optional
+                    _key240 = iprot.readString();
+                    _val241 = new ShardLayout();
+                    _val241.read(iprot);
+                    struct.success.put(_key240, _val241);
                   }
                   iprot.readMapEnd();
                 }
@@ -13524,10 +13537,10 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.success.size()));
-            for (Map.Entry<String, ShardLayout> _iter252 : struct.success.entrySet())
+            for (Map.Entry<String, ShardLayout> _iter242 : struct.success.entrySet())
             {
-              oprot.writeString(_iter252.getKey());
-              _iter252.getValue().write(oprot);
+              oprot.writeString(_iter242.getKey());
+              _iter242.getValue().write(oprot);
             }
             oprot.writeMapEnd();
           }
@@ -13566,10 +13579,10 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (Map.Entry<String, ShardLayout> _iter253 : struct.success.entrySet())
+            for (Map.Entry<String, ShardLayout> _iter243 : struct.success.entrySet())
             {
-              oprot.writeString(_iter253.getKey());
-              _iter253.getValue().write(oprot);
+              oprot.writeString(_iter243.getKey());
+              _iter243.getValue().write(oprot);
             }
           }
         }
@@ -13584,16 +13597,16 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TMap _map254 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-            struct.success = new HashMap<String,ShardLayout>(2*_map254.size);
-            for (int _i255 = 0; _i255 < _map254.size; ++_i255)
+            org.apache.thrift.protocol.TMap _map244 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+            struct.success = new HashMap<String,ShardLayout>(2*_map244.size);
+            for (int _i245 = 0; _i245 < _map244.size; ++_i245)
             {
-              String _key256; // required
-              ShardLayout _val257; // optional
-              _key256 = iprot.readString();
-              _val257 = new ShardLayout();
-              _val257.read(iprot);
-              struct.success.put(_key256, _val257);
+              String _key246; // required
+              ShardLayout _val247; // optional
+              _key246 = iprot.readString();
+              _val247 = new ShardLayout();
+              _val247.read(iprot);
+              struct.success.put(_key246, _val247);
             }
           }
           struct.setSuccessIsSet(true);
@@ -14240,13 +14253,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list258 = iprot.readListBegin();
-                  struct.success = new ArrayList<String>(_list258.size);
-                  for (int _i259 = 0; _i259 < _list258.size; ++_i259)
+                  org.apache.thrift.protocol.TList _list248 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list248.size);
+                  for (int _i249 = 0; _i249 < _list248.size; ++_i249)
                   {
-                    String _elem260; // required
-                    _elem260 = iprot.readString();
-                    struct.success.add(_elem260);
+                    String _elem250; // required
+                    _elem250 = iprot.readString();
+                    struct.success.add(_elem250);
                   }
                   iprot.readListEnd();
                 }
@@ -14283,9 +14296,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
-            for (String _iter261 : struct.success)
+            for (String _iter251 : struct.success)
             {
-              oprot.writeString(_iter261);
+              oprot.writeString(_iter251);
             }
             oprot.writeListEnd();
           }
@@ -14324,9 +14337,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter262 : struct.success)
+            for (String _iter252 : struct.success)
             {
-              oprot.writeString(_iter262);
+              oprot.writeString(_iter252);
             }
           }
         }
@@ -14341,13 +14354,13 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list263 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
-            struct.success = new ArrayList<String>(_list263.size);
-            for (int _i264 = 0; _i264 < _list263.size; ++_i264)
+            org.apache.thrift.protocol.TList _list253 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list253.size);
+            for (int _i254 = 0; _i254 < _list253.size; ++_i254)
             {
-              String _elem265; // required
-              _elem265 = iprot.readString();
-              struct.success.add(_elem265);
+              String _elem255; // required
+              _elem255 = iprot.readString();
+              struct.success.add(_elem255);
             }
           }
           struct.setSuccessIsSet(true);
@@ -20380,13 +20393,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list266 = iprot.readListBegin();
-                  struct.success = new ArrayList<Long>(_list266.size);
-                  for (int _i267 = 0; _i267 < _list266.size; ++_i267)
+                  org.apache.thrift.protocol.TList _list256 = iprot.readListBegin();
+                  struct.success = new ArrayList<Long>(_list256.size);
+                  for (int _i257 = 0; _i257 < _list256.size; ++_i257)
                   {
-                    long _elem268; // required
-                    _elem268 = iprot.readI64();
-                    struct.success.add(_elem268);
+                    long _elem258; // required
+                    _elem258 = iprot.readI64();
+                    struct.success.add(_elem258);
                   }
                   iprot.readListEnd();
                 }
@@ -20423,9 +20436,9 @@ public class Blur {
           oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.success.size()));
-            for (long _iter269 : struct.success)
+            for (long _iter259 : struct.success)
             {
-              oprot.writeI64(_iter269);
+              oprot.writeI64(_iter259);
             }
             oprot.writeListEnd();
           }
@@ -20464,9 +20477,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (long _iter270 : struct.success)
+            for (long _iter260 : struct.success)
             {
-              oprot.writeI64(_iter270);
+              oprot.writeI64(_iter260);
             }
           }
         }
@@ -20481,13 +20494,13 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list271 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
-            struct.success = new ArrayList<Long>(_list271.size);
-            for (int _i272 = 0; _i272 < _list271.size; ++_i272)
+            org.apache.thrift.protocol.TList _list261 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+            struct.success = new ArrayList<Long>(_list261.size);
+            for (int _i262 = 0; _i262 < _list261.size; ++_i262)
             {
-              long _elem273; // required
-              _elem273 = iprot.readI64();
-              struct.success.add(_elem273);
+              long _elem263; // required
+              _elem263 = iprot.readI64();
+              struct.success.add(_elem263);
             }
           }
           struct.setSuccessIsSet(true);
@@ -21423,7 +21436,8 @@ 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 TABLE_FIELD_DESC = new org.apache.thrift.protocol.TField("table", org.apache.thrift.protocol.TType.STRING, (short)1);
+    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 SHARDS_IDS_FIELD_DESC = new org.apache.thrift.protocol.TField("shardsIds", org.apache.thrift.protocol.TType.LIST, (short)2);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
@@ -21431,11 +21445,13 @@ public class Blur {
       schemes.put(TupleScheme.class, new schema_argsTupleSchemeFactory());
     }
 
-    public String table; // required
+    public Session session; // required
+    public List<Integer> shardsIds; // 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 {
-      TABLE((short)1, "table");
+      SESSION((short)1, "session"),
+      SHARDS_IDS((short)2, "shardsIds");
 
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -21450,8 +21466,10 @@ public class Blur {
        */
       public static _Fields findByThriftId(int fieldId) {
         switch(fieldId) {
-          case 1: // TABLE
-            return TABLE;
+          case 1: // SESSION
+            return SESSION;
+          case 2: // SHARDS_IDS
+            return SHARDS_IDS;
           default:
             return null;
         }
@@ -21495,8 +21513,11 @@ 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.TABLE, new org.apache.thrift.meta_data.FieldMetaData("table", org.apache.thrift.TFieldRequirementType.DEFAULT, 
-          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+      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.SHARDS_IDS, new org.apache.thrift.meta_data.FieldMetaData("shardsIds", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+          new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, 
+              new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
       org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(schema_args.class, metaDataMap);
     }
@@ -21505,18 +21526,27 @@ public class Blur {
     }
 
     public schema_args(
-      String table)
+      Session session,
+      List<Integer> shardsIds)
     {
       this();
-      this.table = table;
+      this.session = session;
+      this.shardsIds = shardsIds;
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
     public schema_args(schema_args other) {
-      if (other.isSetTable()) {
-        this.table = other.table;
+      if (other.isSetSession()) {
+        this.session = new Session(other.session);
+      }
+      if (other.isSetShardsIds()) {
+        List<Integer> __this__shardsIds = new ArrayList<Integer>();
+        for (Integer other_element : other.shardsIds) {
+          __this__shardsIds.add(other_element);
+        }
+        this.shardsIds = __this__shardsIds;
       }
     }
 
@@ -21526,40 +21556,88 @@ public class Blur {
 
     @Override
     public void clear() {
-      this.table = null;
+      this.session = null;
+      this.shardsIds = null;
     }
 
-    public String getTable() {
-      return this.table;
+    public Session getSession() {
+      return this.session;
     }
 
-    public schema_args setTable(String table) {
-      this.table = table;
+    public schema_args setSession(Session session) {
+      this.session = session;
       return this;
     }
 
-    public void unsetTable() {
-      this.table = null;
+    public void unsetSession() {
+      this.session = null;
     }
 
-    /** Returns true if field table is set (has been assigned a value) and false otherwise */
-    public boolean isSetTable() {
-      return this.table != 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 setTableIsSet(boolean value) {
+    public void setSessionIsSet(boolean value) {
       if (!value) {
-        this.table = null;
+        this.session = null;
+      }
+    }
+
+    public int getShardsIdsSize() {
+      return (this.shardsIds == null) ? 0 : this.shardsIds.size();
+    }
+
+    public java.util.Iterator<Integer> getShardsIdsIterator() {
+      return (this.shardsIds == null) ? null : this.shardsIds.iterator();
+    }
+
+    public void addToShardsIds(int elem) {
+      if (this.shardsIds == null) {
+        this.shardsIds = new ArrayList<Integer>();
+      }
+      this.shardsIds.add(elem);
+    }
+
+    public List<Integer> getShardsIds() {
+      return this.shardsIds;
+    }
+
+    public schema_args setShardsIds(List<Integer> shardsIds) {
+      this.shardsIds = shardsIds;
+      return this;
+    }
+
+    public void unsetShardsIds() {
+      this.shardsIds = null;
+    }
+
+    /** Returns true if field shardsIds is set (has been assigned a value) and false otherwise */
+    public boolean isSetShardsIds() {
+      return this.shardsIds != null;
+    }
+
+    public void setShardsIdsIsSet(boolean value) {
+      if (!value) {
+        this.shardsIds = null;
       }
     }
 
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
-      case TABLE:
+      case SESSION:
         if (value == null) {
-          unsetTable();
+          unsetSession();
         } else {
-          setTable((String)value);
+          setSession((Session)value);
+        }
+        break;
+
+      case SHARDS_IDS:
+        if (value == null) {
+          unsetShardsIds();
+        } else {
+          setShardsIds((List<Integer>)value);
         }
         break;
 
@@ -21568,8 +21646,11 @@ public class Blur {
 
     public Object getFieldValue(_Fields field) {
       switch (field) {
-      case TABLE:
-        return getTable();
+      case SESSION:
+        return getSession();
+
+      case SHARDS_IDS:
+        return getShardsIds();
 
       }
       throw new IllegalStateException();
@@ -21582,8 +21663,10 @@ public class Blur {
       }
 
       switch (field) {
-      case TABLE:
-        return isSetTable();
+      case SESSION:
+        return isSetSession();
+      case SHARDS_IDS:
+        return isSetShardsIds();
       }
       throw new IllegalStateException();
     }
@@ -21601,12 +21684,21 @@ public class Blur {
       if (that == null)
         return false;
 
-      boolean this_present_table = true && this.isSetTable();
-      boolean that_present_table = true && that.isSetTable();
-      if (this_present_table || that_present_table) {
-        if (!(this_present_table && that_present_table))
+      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.table.equals(that.table))
+        if (!this.session.equals(that.session))
+          return false;
+      }
+
+      boolean this_present_shardsIds = true && this.isSetShardsIds();
+      boolean that_present_shardsIds = true && that.isSetShardsIds();
+      if (this_present_shardsIds || that_present_shardsIds) {
+        if (!(this_present_shardsIds && that_present_shardsIds))
+          return false;
+        if (!this.shardsIds.equals(that.shardsIds))
           return false;
       }
 
@@ -21626,12 +21718,22 @@ public class Blur {
       int lastComparison = 0;
       schema_args typedOther = (schema_args)other;
 
-      lastComparison = Boolean.valueOf(isSetTable()).compareTo(typedOther.isSetTable());
+      lastComparison = Boolean.valueOf(isSetSession()).compareTo(typedOther.isSetSession());
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetTable()) {
-        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.table, typedOther.table);
+      if (isSetSession()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.session, typedOther.session);
+        if (lastComparison != 0) {
+          return lastComparison;
+        }
+      }
+      lastComparison = Boolean.valueOf(isSetShardsIds()).compareTo(typedOther.isSetShardsIds());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      if (isSetShardsIds()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.shardsIds, typedOther.shardsIds);
         if (lastComparison != 0) {
           return lastComparison;
         }
@@ -21656,11 +21758,19 @@ public class Blur {
       StringBuilder sb = new StringBuilder("schema_args(");
       boolean first = true;
 
-      sb.append("table:");
-      if (this.table == null) {
+      sb.append("session:");
+      if (this.session == null) {
         sb.append("null");
       } else {
-        sb.append(this.table);
+        sb.append(this.session);
+      }
+      first = false;
+      if (!first) sb.append(", ");
+      sb.append("shardsIds:");
+      if (this.shardsIds == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.shardsIds);
       }
       first = false;
       sb.append(")");
@@ -21670,6 +21780,9 @@ 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 {
@@ -21706,10 +21819,29 @@ public class Blur {
             break;
           }
           switch (schemeField.id) {
-            case 1: // TABLE
-              if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
-                struct.table = iprot.readString();
-                struct.setTableIsSet(true);
+            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: // SHARDS_IDS
+              if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+                {
+                  org.apache.thrift.protocol.TList _list264 = iprot.readListBegin();
+                  struct.shardsIds = new ArrayList<Integer>(_list264.size);
+                  for (int _i265 = 0; _i265 < _list264.size; ++_i265)
+                  {
+                    int _elem266; // required
+                    _elem266 = iprot.readI32();
+                    struct.shardsIds.add(_elem266);
+                  }
+                  iprot.readListEnd();
+                }
+                struct.setShardsIdsIsSet(true);
               } else { 
                 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
               }
@@ -21729,9 +21861,21 @@ public class Blur {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
-        if (struct.table != null) {
-          oprot.writeFieldBegin(TABLE_FIELD_DESC);
-          oprot.writeString(struct.table);
+        if (struct.session != null) {
+          oprot.writeFieldBegin(SESSION_FIELD_DESC);
+          struct.session.write(oprot);
+          oprot.writeFieldEnd();
+        }
+        if (struct.shardsIds != null) {
+          oprot.writeFieldBegin(SHARDS_IDS_FIELD_DESC);
+          {
+            oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, struct.shardsIds.size()));
+            for (int _iter267 : struct.shardsIds)
+            {
+              oprot.writeI32(_iter267);
+            }
+            oprot.writeListEnd();
+          }
           oprot.writeFieldEnd();
         }
         oprot.writeFieldStop();
@@ -21752,22 +21896,48 @@ 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.isSetTable()) {
+        if (struct.isSetSession()) {
           optionals.set(0);
         }
-        oprot.writeBitSet(optionals, 1);
-        if (struct.isSetTable()) {
-          oprot.writeString(struct.table);
+        if (struct.isSetShardsIds()) {
+          optionals.set(1);
+        }
+        oprot.writeBitSet(optionals, 2);
+        if (struct.isSetSession()) {
+          struct.session.write(oprot);
+        }
+        if (struct.isSetShardsIds()) {
+          {
+            oprot.writeI32(struct.shardsIds.size());
+            for (int _iter268 : struct.shardsIds)
+            {
+              oprot.writeI32(_iter268);
+            }
+          }
         }
       }
 
       @Override
       public void read(org.apache.thrift.protocol.TProtocol prot, schema_args struct) throws org.apache.thrift.TException {
         TTupleProtocol iprot = (TTupleProtocol) prot;
-        BitSet incoming = iprot.readBitSet(1);
+        BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
-          struct.table = iprot.readString();
-          struct.setTableIsSet(true);
+          struct.session = new Session();
+          struct.session.read(iprot);
+          struct.setSessionIsSet(true);
+        }
+        if (incoming.get(1)) {
+          {
+            org.apache.thrift.protocol.TList _list269 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, iprot.readI32());
+            struct.shardsIds = new ArrayList<Integer>(_list269.size);
+            for (int _i270 = 0; _i270 < _list269.size; ++_i270)
+            {
+              int _elem271; // required
+              _elem271 = iprot.readI32();
+              struct.shardsIds.add(_elem271);
+            }
+          }
+          struct.setShardsIdsIsSet(true);
         }
       }
     }
@@ -21786,7 +21956,7 @@ public class Blur {
       schemes.put(TupleScheme.class, new schema_resultTupleSchemeFactory());
     }
 
-    public LiveSchema success; // required
+    public TableSchema success; // required
     public BlurException ex; // required
 
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
@@ -21855,7 +22025,7 @@ public class Blur {
     static {
       Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
       tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT, 
-          new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, LiveSchema.class)));
+          new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TableSchema.class)));
       tmpMap.put(_Fields.EX, new org.apache.thrift.meta_data.FieldMetaData("ex", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
@@ -21866,7 +22036,7 @@ public class Blur {
     }
 
     public schema_result(
-      LiveSchema success,
+      TableSchema success,
       BlurException ex)
     {
       this();
@@ -21879,7 +22049,7 @@ public class Blur {
      */
     public schema_result(schema_result other) {
       if (other.isSetSuccess()) {
-        this.success = new LiveSchema(other.success);
+        this.success = new TableSchema(other.success);
       }
       if (other.isSetEx()) {
         this.ex = new BlurException(other.ex);
@@ -21896,11 +22066,11 @@ public class Blur {
       this.ex = null;
     }
 
-    public LiveSchema getSuccess() {
+    public TableSchema getSuccess() {
       return this.success;
     }
 
-    public schema_result setSuccess(LiveSchema success) {
+    public schema_result setSuccess(TableSchema success) {
       this.success = success;
       return this;
     }
@@ -21950,7 +22120,7 @@ public class Blur {
         if (value == null) {
           unsetSuccess();
         } else {
-          setSuccess((LiveSchema)value);
+          setSuccess((TableSchema)value);
         }
         break;
 
@@ -22142,7 +22312,7 @@ public class Blur {
           switch (schemeField.id) {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
-                struct.success = new LiveSchema();
+                struct.success = new TableSchema();
                 struct.success.read(iprot);
                 struct.setSuccessIsSet(true);
               } else { 
@@ -22221,7 +22391,7 @@ public class Blur {
         TTupleProtocol iprot = (TTupleProtocol) prot;
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
-          struct.success = new LiveSchema();
+          struct.success = new TableSchema();
           struct.success.read(iprot);
           struct.setSuccessIsSet(true);
         }

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/0e4ecb11/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/ClassDefinition.java
----------------------------------------------------------------------
diff --git a/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/ClassDefinition.java b/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/ClassDefinition.java
index 2801749..446578b 100644
--- a/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/ClassDefinition.java
+++ b/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/ClassDefinition.java
@@ -449,15 +449,15 @@ public class ClassDefinition implements org.apache.thrift.TBase<ClassDefinition,
           case 2: // ARGUMENTS
             if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
               {
-                org.apache.thrift.protocol.TMap _map28 = iprot.readMapBegin();
-                struct.arguments = new HashMap<String,ByteBuffer>(2*_map28.size);
-                for (int _i29 = 0; _i29 < _map28.size; ++_i29)
+                org.apache.thrift.protocol.TMap _map18 = iprot.readMapBegin();
+                struct.arguments = new HashMap<String,ByteBuffer>(2*_map18.size);
+                for (int _i19 = 0; _i19 < _map18.size; ++_i19)
                 {
-                  String _key30; // required
-                  ByteBuffer _val31; // optional
-                  _key30 = iprot.readString();
-                  _val31 = iprot.readBinary();
-                  struct.arguments.put(_key30, _val31);
+                  String _key20; // required
+                  ByteBuffer _val21; // optional
+                  _key20 = iprot.readString();
+                  _val21 = iprot.readBinary();
+                  struct.arguments.put(_key20, _val21);
                 }
                 iprot.readMapEnd();
               }
@@ -490,10 +490,10 @@ public class ClassDefinition implements org.apache.thrift.TBase<ClassDefinition,
         oprot.writeFieldBegin(ARGUMENTS_FIELD_DESC);
         {
           oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.arguments.size()));
-          for (Map.Entry<String, ByteBuffer> _iter32 : struct.arguments.entrySet())
+          for (Map.Entry<String, ByteBuffer> _iter22 : struct.arguments.entrySet())
           {
-            oprot.writeString(_iter32.getKey());
-            oprot.writeBinary(_iter32.getValue());
+            oprot.writeString(_iter22.getKey());
+            oprot.writeBinary(_iter22.getValue());
           }
           oprot.writeMapEnd();
         }
@@ -530,10 +530,10 @@ public class ClassDefinition implements org.apache.thrift.TBase<ClassDefinition,
       if (struct.isSetArguments()) {
         {
           oprot.writeI32(struct.arguments.size());
-          for (Map.Entry<String, ByteBuffer> _iter33 : struct.arguments.entrySet())
+          for (Map.Entry<String, ByteBuffer> _iter23 : struct.arguments.entrySet())
           {
-            oprot.writeString(_iter33.getKey());
-            oprot.writeBinary(_iter33.getValue());
+            oprot.writeString(_iter23.getKey());
+            oprot.writeBinary(_iter23.getValue());
           }
         }
       }
@@ -549,15 +549,15 @@ public class ClassDefinition implements org.apache.thrift.TBase<ClassDefinition,
       }
       if (incoming.get(1)) {
         {
-          org.apache.thrift.protocol.TMap _map34 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
-          struct.arguments = new HashMap<String,ByteBuffer>(2*_map34.size);
-          for (int _i35 = 0; _i35 < _map34.size; ++_i35)
+          org.apache.thrift.protocol.TMap _map24 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+          struct.arguments = new HashMap<String,ByteBuffer>(2*_map24.size);
+          for (int _i25 = 0; _i25 < _map24.size; ++_i25)
           {
-            String _key36; // required
-            ByteBuffer _val37; // optional
-            _key36 = iprot.readString();
-            _val37 = iprot.readBinary();
-            struct.arguments.put(_key36, _val37);
+            String _key26; // required
+            ByteBuffer _val27; // optional
+            _key26 = iprot.readString();
+            _val27 = iprot.readBinary();
+            struct.arguments.put(_key26, _val27);
           }
         }
         struct.setArgumentsIsSet(true);


Mime
View raw message