incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [3/14] git commit: More API changes, and update and delete documents are noew implemented.
Date Sun, 04 Nov 2012 02:17:15 GMT
More API changes, and update and delete documents are noew implemented.


Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/4e18a556
Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/4e18a556
Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/4e18a556

Branch: refs/heads/0.2-dev
Commit: 4e18a55638adb745bb0e9c6066021e4d6522feee
Parents: beb7527
Author: Aaron McCurry <amccurry@gmail.com>
Authored: Sat Nov 3 13:49:31 2012 -0400
Committer: Aaron McCurry <amccurry@gmail.com>
Committed: Sat Nov 3 13:49:31 2012 -0400

----------------------------------------------------------------------
 interface/Blur.thrift                              |   68 +-
 interface/gen-html/Blur.html                       |   79 +-
 interface/gen-html/index.html                      |    2 +
 .../org/apache/blur/thrift/generated/Blur.java     |  384 ++--
 .../org/apache/blur/thrift/generated/Lucene.java   | 1779 ++++++---------
 .../blur/thrift/generated/MutateOptions.java       |  691 ++++++
 .../blur/thrift/generated/UpdatePackage.java       |  564 +++++
 interface/gen-perl/Blur/Blur.pm                    |  218 +-
 interface/gen-perl/Blur/Lucene.pm                  |  479 ++---
 interface/gen-perl/Blur/Types.pm                   |  211 ++
 interface/gen-rb/blur_types.rb                     |   40 +
 interface/gen-rb/lucene.rb                         |   80 +-
 .../org/apache/blur/manager/writer/BlurIndex.java  |    5 +
 .../blur/manager/writer/BlurIndexReader.java       |   17 +
 .../apache/blur/manager/writer/BlurNRTIndex.java   |   94 +-
 .../blur/manager/writer/TransactionRecorder.java   |   24 +-
 .../org/apache/blur/thrift/BlurShardServer.java    |   96 +-
 .../org/apache/blur/thrift/lucene/Convert.java     |  420 ++++
 .../main/java/org/apache/blur/utils/BlurUtil.java  |  381 ---
 .../blur/testsuite/AddDocumentsLuceneApiTable.java |   83 +
 .../blur/testsuite/SearchLuceneApiTable.java       |  107 +
 .../org/apache/blur/thrift/generated/Blur.java     |  384 ++--
 .../org/apache/blur/thrift/generated/Lucene.java   | 1779 ++++++---------
 .../blur/thrift/generated/MutateOptions.java       |  691 ++++++
 .../blur/thrift/generated/UpdatePackage.java       |  564 +++++
 25 files changed, 5670 insertions(+), 3570 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/4e18a556/interface/Blur.thrift
----------------------------------------------------------------------
diff --git a/interface/Blur.thrift b/interface/Blur.thrift
index 6dffc8d..0e2dd0b 100644
--- a/interface/Blur.thrift
+++ b/interface/Blur.thrift
@@ -852,17 +852,77 @@ struct Term {
   2:binary bytes
 }
 
+struct MutateOptions {
+ 1:string table,
+ 2:i32 shardIndex,
+ 3:bool waitToBeVisible,
+ 4:bool writeAheadLog
+}
+
+struct UpdatePackage {
+ 1:Term term,
+ 2:list<Document> documents
+}
+
 service Lucene extends Blur {
 
+  /**
+   * Creating a session snapshots the readers during search and document fetching.  This provides a static view of the indexes so the document ids will remain the same during a session.
+   * @param table the table name.
+   * @return the new Session.
+   */
   Session openReadSession(1:string table) throws (1:BlurException e)
+
+  /**
+   * Runs a search with the given query arguments.  Invalid Sessions will throw a BlurException.
+   * @param session the Session.
+   * @param queryArgs the QueryArgs which contains the query, filter, sort, fetch, paging information, etc.
+   * @return the TopFieldDocs, where there is a TopFieldDocs object for each shard that was search against.
+   */
   list<TopFieldDocs> search(1:Session session, 2:QueryArgs queryArgs) throws (1:BlurException e)
+
+  /**
+   * Fetches a document based on the DocLocation list with the fields specified.
+   * @param session the Session.
+   * @param docLocations the document locations, which include shard index and document id.
+   * @param fields the field names to fetch.
+   * @return the Documents that were requested.
+   */
   list<Document> doc(1:Session session, 2:list<DocLocation> docLocations, 4:set<string> fields) throws (1:BlurException e)
+
+  /**
+   * Closes the session and allows the readers to be closed.
+   * @param session the Session.
+   */
   void closeReadSession(1:Session session) throws (1:BlurException e)
   
-  void addDocuments(1:string table, 2:i32 shardIndex, 3:list<Document> documents) throws (1:BlurException e)
-  void deleteDocumentsByQueries(1:string table, 2:i32 shardIndex, 3:list<QueryArgs> queries) throws (1:BlurException e)
-  void deleteDocuments(1:string table, 2:i32 shardIndex, 3:list<Term> terms) throws (1:BlurException e)
-  void updateDocuments(1:string table, 2:i32 shardIndex, 3:list<Term> terms, 4:list<Document> documents) throws (1:BlurException e)
+  /**
+   * Add Documents to the given table in the provided shard.  If the table or shard is not found on this shard server a BlurException will be thrown.
+   * @param options the MutateOptions provide the table name, shard index, etc.
+   * @param documents the documents to be added.  NOTE: All documents provided to be indexed in a single segment.
+   */
+  void addDocuments(1:MutateOptions options, 2:list<Document> documents) throws (1:BlurException e)
+
+  /**
+   * Delete Documents to the given table in the provided shard.  If the table or shard is not found on this shard server a BlurException will be thrown.
+   * @param options the MutateOptions provide the table name, shard index, etc.
+   * @param queries the Queries that will executed and mark there resulting documents as deleted.
+   */
+  void deleteDocumentsByQueries(1:MutateOptions options, 2:list<binary> queries) throws (1:BlurException e)
+
+  /**
+   * Delete Documents to the given table in the provided shard.  If the table or shard is not found on this shard server a BlurException will be thrown.
+   * @param options the MutateOptions provide the table name, shard index, etc.
+   * @param queries the Terms that will be found and mark deleted all the documents to be deleted.
+   */
+  void deleteDocuments(1:MutateOptions options, 2:list<Term> terms) throws (1:BlurException e)
+
+  /**
+   * Update Documents to the given table in the provided shard.  If the table or shard is not found on this shard server a BlurException will be thrown.
+   * @param options the MutateOptions provide the table name, shard index, etc.
+   * @param updatePackages the documents to be updated.  NOTE: All documents within a update document object are indexed in a single segment.
+   */
+  void updateDocuments(1:MutateOptions options, 2:list<UpdatePackage> updatePackages) throws (1:BlurException e)
   
 }
 

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/4e18a556/interface/gen-html/Blur.html
----------------------------------------------------------------------
diff --git a/interface/gen-html/Blur.html b/interface/gen-html/Blur.html
index 5ff955e..e2adce8 100644
--- a/interface/gen-html/Blur.html
+++ b/interface/gen-html/Blur.html
@@ -72,6 +72,7 @@
 <a href="Blur.html#Struct_FetchResult">FetchResult</a><br/>
 <a href="Blur.html#Struct_FetchRowResult">FetchRowResult</a><br/>
 <a href="Blur.html#Struct_Field">Field</a><br/>
+<a href="Blur.html#Struct_MutateOptions">MutateOptions</a><br/>
 <a href="Blur.html#Struct_QueryArgs">QueryArgs</a><br/>
 <a href="Blur.html#Struct_QuerySession">QuerySession</a><br/>
 <a href="Blur.html#Enum_QueryState">QueryState</a><br/>
@@ -95,6 +96,7 @@
 <a href="Blur.html#Struct_TableStats">TableStats</a><br/>
 <a href="Blur.html#Struct_Term">Term</a><br/>
 <a href="Blur.html#Struct_TopFieldDocs">TopFieldDocs</a><br/>
+<a href="Blur.html#Struct_UpdatePackage">UpdatePackage</a><br/>
 </td>
 <td></code></td>
 </tr></table>
@@ -511,6 +513,16 @@ updates through MapReduce are allowed and in fact they are only allowed if the t
 <table class="table-bordered table-striped table-condensed"><thead><th>Key</th><th>Field</th><th>Type</th><th>Description</th><th>Requiredness</th><th>Default value</th></thead>
 <tr><td>1</td><td>field</td><td><code>string</code></td><td></td><td>default</td><td></td></tr>
 <tr><td>2</td><td>bytes</td><td><code>binary</code></td><td></td><td>default</td><td></td></tr>
+</table><br/></div><div class="definition"><h3 id="Struct_MutateOptions">Struct: MutateOptions</h3>
+<table class="table-bordered table-striped table-condensed"><thead><th>Key</th><th>Field</th><th>Type</th><th>Description</th><th>Requiredness</th><th>Default value</th></thead>
+<tr><td>1</td><td>table</td><td><code>string</code></td><td></td><td>default</td><td></td></tr>
+<tr><td>2</td><td>shardIndex</td><td><code>i32</code></td><td></td><td>default</td><td></td></tr>
+<tr><td>3</td><td>waitToBeVisible</td><td><code>bool</code></td><td></td><td>default</td><td></td></tr>
+<tr><td>4</td><td>writeAheadLog</td><td><code>bool</code></td><td></td><td>default</td><td></td></tr>
+</table><br/></div><div class="definition"><h3 id="Struct_UpdatePackage">Struct: UpdatePackage</h3>
+<table class="table-bordered table-striped table-condensed"><thead><th>Key</th><th>Field</th><th>Type</th><th>Description</th><th>Requiredness</th><th>Default value</th></thead>
+<tr><td>1</td><td>term</td><td><code><a href="Blur.html#Struct_Term">Term</a></code></td><td></td><td>default</td><td></td></tr>
+<tr><td>2</td><td>documents</td><td><code>list&lt;<code><a href="Blur.html#Struct_Document">Document</a></code>&gt;</code></td><td></td><td>default</td><td></td></tr>
 </table><br/></div><hr/><h2 id="Services">Services</h2>
 <h3 id="Svc_Blur">Service: Blur</h3>
 <p/>
@@ -637,37 +649,58 @@ updates through MapReduce are allowed and in fact they are only allowed if the t
 <div class="definition"><h4 id="Fn_Lucene_openReadSession">Function: Lucene.openReadSession</h4>
 <pre><code><a href="Blur.html#Struct_Session">Session</a></code> openReadSession(<code>string</code> table)
     throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>
-</pre></div><div class="definition"><h4 id="Fn_Lucene_search">Function: Lucene.search</h4>
+</pre>Creating a session snapshots the readers during search and document fetching.  This provides a static view of the indexes so the document ids will remain the same during a session.
+@param table the table name.
+@return the new Session.
+<br/></div><div class="definition"><h4 id="Fn_Lucene_search">Function: Lucene.search</h4>
 <pre><code>list&lt;<code><a href="Blur.html#Struct_TopFieldDocs">TopFieldDocs</a></code>&gt;</code> search(<code><a href="Blur.html#Struct_Session">Session</a></code> session,
                           <code><a href="Blur.html#Struct_QueryArgs">QueryArgs</a></code> queryArgs)
     throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>
-</pre></div><div class="definition"><h4 id="Fn_Lucene_doc">Function: Lucene.doc</h4>
+</pre>Runs a search with the given query arguments.  Invalid Sessions will throw a BlurException.
+@param session the Session.
+@param queryArgs the QueryArgs which contains the query, filter, sort, fetch, paging information, etc.
+@return the TopFieldDocs, where there is a TopFieldDocs object for each shard that was search against.
+<br/></div><div class="definition"><h4 id="Fn_Lucene_doc">Function: Lucene.doc</h4>
 <pre><code>list&lt;<code><a href="Blur.html#Struct_Document">Document</a></code>&gt;</code> doc(<code><a href="Blur.html#Struct_Session">Session</a></code> session,
                    <code>list&lt;<code><a href="Blur.html#Struct_DocLocation">DocLocation</a></code>&gt;</code> docLocations,
                    <code>set&lt;<code>string</code>&gt;</code> fields)
     throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>
-</pre></div><div class="definition"><h4 id="Fn_Lucene_closeReadSession">Function: Lucene.closeReadSession</h4>
+</pre>Fetches a document based on the DocLocation list with the fields specified.
+@param session the Session.
+@param docLocations the document locations, which include shard index and document id.
+@param fields the field names to fetch.
+@return the Documents that were requested.
+<br/></div><div class="definition"><h4 id="Fn_Lucene_closeReadSession">Function: Lucene.closeReadSession</h4>
 <pre><code>void</code> closeReadSession(<code><a href="Blur.html#Struct_Session">Session</a></code> session)
     throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>
-</pre></div><div class="definition"><h4 id="Fn_Lucene_addDocuments">Function: Lucene.addDocuments</h4>
-<pre><code>void</code> addDocuments(<code>string</code> table,
-                  <code>i32</code> shardIndex,
-                  <code>list&lt;<code><a href="Blur.html#Struct_Document">Document</a></code>&gt;</code> document)
-    throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>
-</pre></div><div class="definition"><h4 id="Fn_Lucene_deleteDocumentsByQueries">Function: Lucene.deleteDocumentsByQueries</h4>
-<pre><code>void</code> deleteDocumentsByQueries(<code>string</code> table,
-                              <code>i32</code> shardIndex,
-                              <code>list&lt;<code><a href="Blur.html#Struct_QueryArgs">QueryArgs</a></code>&gt;</code> queries)
-    throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>
-</pre></div><div class="definition"><h4 id="Fn_Lucene_deleteDocuments">Function: Lucene.deleteDocuments</h4>
-<pre><code>void</code> deleteDocuments(<code>string</code> table,
-                     <code>i32</code> shardIndex,
+</pre>Closes the session and allows the readers to be closed.
+@param session the Session.
+<br/></div><div class="definition"><h4 id="Fn_Lucene_addDocuments">Function: Lucene.addDocuments</h4>
+<pre><code>void</code> addDocuments(<code><a href="Blur.html#Struct_MutateOptions">MutateOptions</a></code> options,
+                  <code>list&lt;<code><a href="Blur.html#Struct_Document">Document</a></code>&gt;</code> documents)
+    throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>
+</pre>Add Documents to the given table in the provided shard.  If the table or shard is not found on this shard server a BlurException will be thrown.
+@param options the MutateOptions provide the table name, shard index, etc.
+@param documents the documents to be added.  NOTE: All documents provided to be indexed in a single segment.
+<br/></div><div class="definition"><h4 id="Fn_Lucene_deleteDocumentsByQueries">Function: Lucene.deleteDocumentsByQueries</h4>
+<pre><code>void</code> deleteDocumentsByQueries(<code><a href="Blur.html#Struct_MutateOptions">MutateOptions</a></code> options,
+                              <code>list&lt;<code>binary</code>&gt;</code> queries)
+    throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>
+</pre>Delete Documents to the given table in the provided shard.  If the table or shard is not found on this shard server a BlurException will be thrown.
+@param options the MutateOptions provide the table name, shard index, etc.
+@param queries the Queries that will executed and mark there resulting documents as deleted.
+<br/></div><div class="definition"><h4 id="Fn_Lucene_deleteDocuments">Function: Lucene.deleteDocuments</h4>
+<pre><code>void</code> deleteDocuments(<code><a href="Blur.html#Struct_MutateOptions">MutateOptions</a></code> options,
                      <code>list&lt;<code><a href="Blur.html#Struct_Term">Term</a></code>&gt;</code> terms)
     throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>
-</pre></div><div class="definition"><h4 id="Fn_Lucene_updateDocuments">Function: Lucene.updateDocuments</h4>
-<pre><code>void</code> updateDocuments(<code>string</code> table,
-                     <code>i32</code> shardIndex,
-                     <code>list&lt;<code><a href="Blur.html#Struct_Term">Term</a></code>&gt;</code> terms,
-                     <code>list&lt;<code><a href="Blur.html#Struct_Document">Document</a></code>&gt;</code> document)
-    throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>
-</pre></div></div></body></html>
+</pre>Delete Documents to the given table in the provided shard.  If the table or shard is not found on this shard server a BlurException will be thrown.
+@param options the MutateOptions provide the table name, shard index, etc.
+@param queries the Terms that will be found and mark deleted all the documents to be deleted.
+<br/></div><div class="definition"><h4 id="Fn_Lucene_updateDocuments">Function: Lucene.updateDocuments</h4>
+<pre><code>void</code> updateDocuments(<code><a href="Blur.html#Struct_MutateOptions">MutateOptions</a></code> options,
+                     <code>list&lt;<code><a href="Blur.html#Struct_UpdatePackage">UpdatePackage</a></code>&gt;</code> updatePackages)
+    throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>
+</pre>Update Documents to the given table in the provided shard.  If the table or shard is not found on this shard server a BlurException will be thrown.
+@param options the MutateOptions provide the table name, shard index, etc.
+@param updatePackages the documents to be updated.  NOTE: All documents within a update document object are indexed in a single segment.
+<br/></div></div></body></html>

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/4e18a556/interface/gen-html/index.html
----------------------------------------------------------------------
diff --git a/interface/gen-html/index.html b/interface/gen-html/index.html
index 109981c..7c7bfb8 100644
--- a/interface/gen-html/index.html
+++ b/interface/gen-html/index.html
@@ -68,6 +68,7 @@
 <a href="Blur.html#Struct_FetchResult">FetchResult</a><br/>
 <a href="Blur.html#Struct_FetchRowResult">FetchRowResult</a><br/>
 <a href="Blur.html#Struct_Field">Field</a><br/>
+<a href="Blur.html#Struct_MutateOptions">MutateOptions</a><br/>
 <a href="Blur.html#Struct_QueryArgs">QueryArgs</a><br/>
 <a href="Blur.html#Struct_QuerySession">QuerySession</a><br/>
 <a href="Blur.html#Enum_QueryState">QueryState</a><br/>
@@ -91,6 +92,7 @@
 <a href="Blur.html#Struct_TableStats">TableStats</a><br/>
 <a href="Blur.html#Struct_Term">Term</a><br/>
 <a href="Blur.html#Struct_TopFieldDocs">TopFieldDocs</a><br/>
+<a href="Blur.html#Struct_UpdatePackage">UpdatePackage</a><br/>
 </td>
 <td></code></td>
 </tr></table>

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/4e18a556/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
----------------------------------------------------------------------
diff --git a/interface/gen-java/org/apache/blur/thrift/generated/Blur.java b/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
index 4ea4c5f..d8e51a7 100644
--- a/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
+++ b/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
@@ -3182,13 +3182,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list224 = iprot.readListBegin();
-                  struct.success = new ArrayList<String>(_list224.size);
-                  for (int _i225 = 0; _i225 < _list224.size; ++_i225)
+                  org.apache.thrift.protocol.TList _list232 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list232.size);
+                  for (int _i233 = 0; _i233 < _list232.size; ++_i233)
                   {
-                    String _elem226; // required
-                    _elem226 = iprot.readString();
-                    struct.success.add(_elem226);
+                    String _elem234; // required
+                    _elem234 = iprot.readString();
+                    struct.success.add(_elem234);
                   }
                   iprot.readListEnd();
                 }
@@ -3225,9 +3225,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 _iter227 : struct.success)
+            for (String _iter235 : struct.success)
             {
-              oprot.writeString(_iter227);
+              oprot.writeString(_iter235);
             }
             oprot.writeListEnd();
           }
@@ -3266,9 +3266,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter228 : struct.success)
+            for (String _iter236 : struct.success)
             {
-              oprot.writeString(_iter228);
+              oprot.writeString(_iter236);
             }
           }
         }
@@ -3283,13 +3283,13 @@ 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.STRING, iprot.readI32());
-            struct.success = new ArrayList<String>(_list229.size);
-            for (int _i230 = 0; _i230 < _list229.size; ++_i230)
+            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)
             {
-              String _elem231; // required
-              _elem231 = iprot.readString();
-              struct.success.add(_elem231);
+              String _elem239; // required
+              _elem239 = iprot.readString();
+              struct.success.add(_elem239);
             }
           }
           struct.setSuccessIsSet(true);
@@ -4044,13 +4044,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 _list240 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list240.size);
+                  for (int _i241 = 0; _i241 < _list240.size; ++_i241)
                   {
-                    String _elem234; // required
-                    _elem234 = iprot.readString();
-                    struct.success.add(_elem234);
+                    String _elem242; // required
+                    _elem242 = iprot.readString();
+                    struct.success.add(_elem242);
                   }
                   iprot.readListEnd();
                 }
@@ -4087,9 +4087,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 _iter243 : struct.success)
             {
-              oprot.writeString(_iter235);
+              oprot.writeString(_iter243);
             }
             oprot.writeListEnd();
           }
@@ -4128,9 +4128,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter236 : struct.success)
+            for (String _iter244 : struct.success)
             {
-              oprot.writeString(_iter236);
+              oprot.writeString(_iter244);
             }
           }
         }
@@ -4145,13 +4145,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 _list245 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list245.size);
+            for (int _i246 = 0; _i246 < _list245.size; ++_i246)
             {
-              String _elem239; // required
-              _elem239 = iprot.readString();
-              struct.success.add(_elem239);
+              String _elem247; // required
+              _elem247 = iprot.readString();
+              struct.success.add(_elem247);
             }
           }
           struct.setSuccessIsSet(true);
@@ -4798,13 +4798,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<String>(_list240.size);
-                  for (int _i241 = 0; _i241 < _list240.size; ++_i241)
+                  org.apache.thrift.protocol.TList _list248 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list248.size);
+                  for (int _i249 = 0; _i249 < _list248.size; ++_i249)
                   {
-                    String _elem242; // required
-                    _elem242 = iprot.readString();
-                    struct.success.add(_elem242);
+                    String _elem250; // required
+                    _elem250 = iprot.readString();
+                    struct.success.add(_elem250);
                   }
                   iprot.readListEnd();
                 }
@@ -4841,9 +4841,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 _iter243 : struct.success)
+            for (String _iter251 : struct.success)
             {
-              oprot.writeString(_iter243);
+              oprot.writeString(_iter251);
             }
             oprot.writeListEnd();
           }
@@ -4882,9 +4882,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter244 : struct.success)
+            for (String _iter252 : struct.success)
             {
-              oprot.writeString(_iter244);
+              oprot.writeString(_iter252);
             }
           }
         }
@@ -4899,13 +4899,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.STRING, iprot.readI32());
-            struct.success = new ArrayList<String>(_list245.size);
-            for (int _i246 = 0; _i246 < _list245.size; ++_i246)
+            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 _elem247; // required
-              _elem247 = iprot.readString();
-              struct.success.add(_elem247);
+              String _elem255; // required
+              _elem255 = iprot.readString();
+              struct.success.add(_elem255);
             }
           }
           struct.setSuccessIsSet(true);
@@ -5665,15 +5665,15 @@ 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,String>(2*_map248.size);
-                  for (int _i249 = 0; _i249 < _map248.size; ++_i249)
+                  org.apache.thrift.protocol.TMap _map256 = iprot.readMapBegin();
+                  struct.success = new HashMap<String,String>(2*_map256.size);
+                  for (int _i257 = 0; _i257 < _map256.size; ++_i257)
                   {
-                    String _key250; // required
-                    String _val251; // optional
-                    _key250 = iprot.readString();
-                    _val251 = iprot.readString();
-                    struct.success.put(_key250, _val251);
+                    String _key258; // required
+                    String _val259; // optional
+                    _key258 = iprot.readString();
+                    _val259 = iprot.readString();
+                    struct.success.put(_key258, _val259);
                   }
                   iprot.readMapEnd();
                 }
@@ -5710,10 +5710,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.STRING, struct.success.size()));
-            for (Map.Entry<String, String> _iter252 : struct.success.entrySet())
+            for (Map.Entry<String, String> _iter260 : struct.success.entrySet())
             {
-              oprot.writeString(_iter252.getKey());
-              oprot.writeString(_iter252.getValue());
+              oprot.writeString(_iter260.getKey());
+              oprot.writeString(_iter260.getValue());
             }
             oprot.writeMapEnd();
           }
@@ -5752,10 +5752,10 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (Map.Entry<String, String> _iter253 : struct.success.entrySet())
+            for (Map.Entry<String, String> _iter261 : struct.success.entrySet())
             {
-              oprot.writeString(_iter253.getKey());
-              oprot.writeString(_iter253.getValue());
+              oprot.writeString(_iter261.getKey());
+              oprot.writeString(_iter261.getValue());
             }
           }
         }
@@ -5770,15 +5770,15 @@ 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.STRING, iprot.readI32());
-            struct.success = new HashMap<String,String>(2*_map254.size);
-            for (int _i255 = 0; _i255 < _map254.size; ++_i255)
+            org.apache.thrift.protocol.TMap _map262 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.success = new HashMap<String,String>(2*_map262.size);
+            for (int _i263 = 0; _i263 < _map262.size; ++_i263)
             {
-              String _key256; // required
-              String _val257; // optional
-              _key256 = iprot.readString();
-              _val257 = iprot.readString();
-              struct.success.put(_key256, _val257);
+              String _key264; // required
+              String _val265; // optional
+              _key264 = iprot.readString();
+              _val265 = iprot.readString();
+              struct.success.put(_key264, _val265);
             }
           }
           struct.setSuccessIsSet(true);
@@ -6425,13 +6425,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 _list266 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list266.size);
+                  for (int _i267 = 0; _i267 < _list266.size; ++_i267)
                   {
-                    String _elem260; // required
-                    _elem260 = iprot.readString();
-                    struct.success.add(_elem260);
+                    String _elem268; // required
+                    _elem268 = iprot.readString();
+                    struct.success.add(_elem268);
                   }
                   iprot.readListEnd();
                 }
@@ -6468,9 +6468,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 _iter269 : struct.success)
             {
-              oprot.writeString(_iter261);
+              oprot.writeString(_iter269);
             }
             oprot.writeListEnd();
           }
@@ -6509,9 +6509,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter262 : struct.success)
+            for (String _iter270 : struct.success)
             {
-              oprot.writeString(_iter262);
+              oprot.writeString(_iter270);
             }
           }
         }
@@ -6526,13 +6526,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 _list271 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list271.size);
+            for (int _i272 = 0; _i272 < _list271.size; ++_i272)
             {
-              String _elem265; // required
-              _elem265 = iprot.readString();
-              struct.success.add(_elem265);
+              String _elem273; // required
+              _elem273 = iprot.readString();
+              struct.success.add(_elem273);
             }
           }
           struct.setSuccessIsSet(true);
@@ -7287,13 +7287,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<String>(_list266.size);
-                  for (int _i267 = 0; _i267 < _list266.size; ++_i267)
+                  org.apache.thrift.protocol.TList _list274 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list274.size);
+                  for (int _i275 = 0; _i275 < _list274.size; ++_i275)
                   {
-                    String _elem268; // required
-                    _elem268 = iprot.readString();
-                    struct.success.add(_elem268);
+                    String _elem276; // required
+                    _elem276 = iprot.readString();
+                    struct.success.add(_elem276);
                   }
                   iprot.readListEnd();
                 }
@@ -7330,9 +7330,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 _iter269 : struct.success)
+            for (String _iter277 : struct.success)
             {
-              oprot.writeString(_iter269);
+              oprot.writeString(_iter277);
             }
             oprot.writeListEnd();
           }
@@ -7371,9 +7371,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter270 : struct.success)
+            for (String _iter278 : struct.success)
             {
-              oprot.writeString(_iter270);
+              oprot.writeString(_iter278);
             }
           }
         }
@@ -7388,13 +7388,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.STRING, iprot.readI32());
-            struct.success = new ArrayList<String>(_list271.size);
-            for (int _i272 = 0; _i272 < _list271.size; ++_i272)
+            org.apache.thrift.protocol.TList _list279 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list279.size);
+            for (int _i280 = 0; _i280 < _list279.size; ++_i280)
             {
-              String _elem273; // required
-              _elem273 = iprot.readString();
-              struct.success.add(_elem273);
+              String _elem281; // required
+              _elem281 = iprot.readString();
+              struct.success.add(_elem281);
             }
           }
           struct.setSuccessIsSet(true);
@@ -10692,14 +10692,14 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list274 = iprot.readListBegin();
-                  struct.success = new ArrayList<BlurQueryStatus>(_list274.size);
-                  for (int _i275 = 0; _i275 < _list274.size; ++_i275)
+                  org.apache.thrift.protocol.TList _list282 = iprot.readListBegin();
+                  struct.success = new ArrayList<BlurQueryStatus>(_list282.size);
+                  for (int _i283 = 0; _i283 < _list282.size; ++_i283)
                   {
-                    BlurQueryStatus _elem276; // required
-                    _elem276 = new BlurQueryStatus();
-                    _elem276.read(iprot);
-                    struct.success.add(_elem276);
+                    BlurQueryStatus _elem284; // required
+                    _elem284 = new BlurQueryStatus();
+                    _elem284.read(iprot);
+                    struct.success.add(_elem284);
                   }
                   iprot.readListEnd();
                 }
@@ -10736,9 +10736,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 (BlurQueryStatus _iter277 : struct.success)
+            for (BlurQueryStatus _iter285 : struct.success)
             {
-              _iter277.write(oprot);
+              _iter285.write(oprot);
             }
             oprot.writeListEnd();
           }
@@ -10777,9 +10777,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (BlurQueryStatus _iter278 : struct.success)
+            for (BlurQueryStatus _iter286 : struct.success)
             {
-              _iter278.write(oprot);
+              _iter286.write(oprot);
             }
           }
         }
@@ -10794,14 +10794,14 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list279 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-            struct.success = new ArrayList<BlurQueryStatus>(_list279.size);
-            for (int _i280 = 0; _i280 < _list279.size; ++_i280)
+            org.apache.thrift.protocol.TList _list287 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+            struct.success = new ArrayList<BlurQueryStatus>(_list287.size);
+            for (int _i288 = 0; _i288 < _list287.size; ++_i288)
             {
-              BlurQueryStatus _elem281; // required
-              _elem281 = new BlurQueryStatus();
-              _elem281.read(iprot);
-              struct.success.add(_elem281);
+              BlurQueryStatus _elem289; // required
+              _elem289 = new BlurQueryStatus();
+              _elem289.read(iprot);
+              struct.success.add(_elem289);
             }
           }
           struct.setSuccessIsSet(true);
@@ -11556,13 +11556,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list282 = iprot.readListBegin();
-                  struct.success = new ArrayList<Long>(_list282.size);
-                  for (int _i283 = 0; _i283 < _list282.size; ++_i283)
+                  org.apache.thrift.protocol.TList _list290 = iprot.readListBegin();
+                  struct.success = new ArrayList<Long>(_list290.size);
+                  for (int _i291 = 0; _i291 < _list290.size; ++_i291)
                   {
-                    long _elem284; // required
-                    _elem284 = iprot.readI64();
-                    struct.success.add(_elem284);
+                    long _elem292; // required
+                    _elem292 = iprot.readI64();
+                    struct.success.add(_elem292);
                   }
                   iprot.readListEnd();
                 }
@@ -11599,9 +11599,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 _iter285 : struct.success)
+            for (long _iter293 : struct.success)
             {
-              oprot.writeI64(_iter285);
+              oprot.writeI64(_iter293);
             }
             oprot.writeListEnd();
           }
@@ -11640,9 +11640,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (long _iter286 : struct.success)
+            for (long _iter294 : struct.success)
             {
-              oprot.writeI64(_iter286);
+              oprot.writeI64(_iter294);
             }
           }
         }
@@ -11657,13 +11657,13 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list287 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
-            struct.success = new ArrayList<Long>(_list287.size);
-            for (int _i288 = 0; _i288 < _list287.size; ++_i288)
+            org.apache.thrift.protocol.TList _list295 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+            struct.success = new ArrayList<Long>(_list295.size);
+            for (int _i296 = 0; _i296 < _list295.size; ++_i296)
             {
-              long _elem289; // required
-              _elem289 = iprot.readI64();
-              struct.success.add(_elem289);
+              long _elem297; // required
+              _elem297 = iprot.readI64();
+              struct.success.add(_elem297);
             }
           }
           struct.setSuccessIsSet(true);
@@ -16174,13 +16174,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list290 = iprot.readListBegin();
-                  struct.success = new ArrayList<String>(_list290.size);
-                  for (int _i291 = 0; _i291 < _list290.size; ++_i291)
+                  org.apache.thrift.protocol.TList _list298 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list298.size);
+                  for (int _i299 = 0; _i299 < _list298.size; ++_i299)
                   {
-                    String _elem292; // required
-                    _elem292 = iprot.readString();
-                    struct.success.add(_elem292);
+                    String _elem300; // required
+                    _elem300 = iprot.readString();
+                    struct.success.add(_elem300);
                   }
                   iprot.readListEnd();
                 }
@@ -16217,9 +16217,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 _iter293 : struct.success)
+            for (String _iter301 : struct.success)
             {
-              oprot.writeString(_iter293);
+              oprot.writeString(_iter301);
             }
             oprot.writeListEnd();
           }
@@ -16258,9 +16258,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter294 : struct.success)
+            for (String _iter302 : struct.success)
             {
-              oprot.writeString(_iter294);
+              oprot.writeString(_iter302);
             }
           }
         }
@@ -16275,13 +16275,13 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list295 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
-            struct.success = new ArrayList<String>(_list295.size);
-            for (int _i296 = 0; _i296 < _list295.size; ++_i296)
+            org.apache.thrift.protocol.TList _list303 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list303.size);
+            for (int _i304 = 0; _i304 < _list303.size; ++_i304)
             {
-              String _elem297; // required
-              _elem297 = iprot.readString();
-              struct.success.add(_elem297);
+              String _elem305; // required
+              _elem305 = iprot.readString();
+              struct.success.add(_elem305);
             }
           }
           struct.setSuccessIsSet(true);
@@ -19350,14 +19350,14 @@ public class Blur {
             case 1: // MUTATIONS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list298 = iprot.readListBegin();
-                  struct.mutations = new ArrayList<RowMutation>(_list298.size);
-                  for (int _i299 = 0; _i299 < _list298.size; ++_i299)
+                  org.apache.thrift.protocol.TList _list306 = iprot.readListBegin();
+                  struct.mutations = new ArrayList<RowMutation>(_list306.size);
+                  for (int _i307 = 0; _i307 < _list306.size; ++_i307)
                   {
-                    RowMutation _elem300; // required
-                    _elem300 = new RowMutation();
-                    _elem300.read(iprot);
-                    struct.mutations.add(_elem300);
+                    RowMutation _elem308; // required
+                    _elem308 = new RowMutation();
+                    _elem308.read(iprot);
+                    struct.mutations.add(_elem308);
                   }
                   iprot.readListEnd();
                 }
@@ -19385,9 +19385,9 @@ public class Blur {
           oprot.writeFieldBegin(MUTATIONS_FIELD_DESC);
           {
             oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.mutations.size()));
-            for (RowMutation _iter301 : struct.mutations)
+            for (RowMutation _iter309 : struct.mutations)
             {
-              _iter301.write(oprot);
+              _iter309.write(oprot);
             }
             oprot.writeListEnd();
           }
@@ -19418,9 +19418,9 @@ public class Blur {
         if (struct.isSetMutations()) {
           {
             oprot.writeI32(struct.mutations.size());
-            for (RowMutation _iter302 : struct.mutations)
+            for (RowMutation _iter310 : struct.mutations)
             {
-              _iter302.write(oprot);
+              _iter310.write(oprot);
             }
           }
         }
@@ -19432,14 +19432,14 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(1);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TList _list303 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-            struct.mutations = new ArrayList<RowMutation>(_list303.size);
-            for (int _i304 = 0; _i304 < _list303.size; ++_i304)
+            org.apache.thrift.protocol.TList _list311 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+            struct.mutations = new ArrayList<RowMutation>(_list311.size);
+            for (int _i312 = 0; _i312 < _list311.size; ++_i312)
             {
-              RowMutation _elem305; // required
-              _elem305 = new RowMutation();
-              _elem305.read(iprot);
-              struct.mutations.add(_elem305);
+              RowMutation _elem313; // required
+              _elem313 = new RowMutation();
+              _elem313.read(iprot);
+              struct.mutations.add(_elem313);
             }
           }
           struct.setMutationsIsSet(true);
@@ -25003,15 +25003,15 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
                 {
-                  org.apache.thrift.protocol.TMap _map306 = iprot.readMapBegin();
-                  struct.success = new HashMap<String,String>(2*_map306.size);
-                  for (int _i307 = 0; _i307 < _map306.size; ++_i307)
+                  org.apache.thrift.protocol.TMap _map314 = iprot.readMapBegin();
+                  struct.success = new HashMap<String,String>(2*_map314.size);
+                  for (int _i315 = 0; _i315 < _map314.size; ++_i315)
                   {
-                    String _key308; // required
-                    String _val309; // optional
-                    _key308 = iprot.readString();
-                    _val309 = iprot.readString();
-                    struct.success.put(_key308, _val309);
+                    String _key316; // required
+                    String _val317; // optional
+                    _key316 = iprot.readString();
+                    _val317 = iprot.readString();
+                    struct.success.put(_key316, _val317);
                   }
                   iprot.readMapEnd();
                 }
@@ -25048,10 +25048,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.STRING, struct.success.size()));
-            for (Map.Entry<String, String> _iter310 : struct.success.entrySet())
+            for (Map.Entry<String, String> _iter318 : struct.success.entrySet())
             {
-              oprot.writeString(_iter310.getKey());
-              oprot.writeString(_iter310.getValue());
+              oprot.writeString(_iter318.getKey());
+              oprot.writeString(_iter318.getValue());
             }
             oprot.writeMapEnd();
           }
@@ -25090,10 +25090,10 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (Map.Entry<String, String> _iter311 : struct.success.entrySet())
+            for (Map.Entry<String, String> _iter319 : struct.success.entrySet())
             {
-              oprot.writeString(_iter311.getKey());
-              oprot.writeString(_iter311.getValue());
+              oprot.writeString(_iter319.getKey());
+              oprot.writeString(_iter319.getValue());
             }
           }
         }
@@ -25108,15 +25108,15 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TMap _map312 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
-            struct.success = new HashMap<String,String>(2*_map312.size);
-            for (int _i313 = 0; _i313 < _map312.size; ++_i313)
+            org.apache.thrift.protocol.TMap _map320 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.success = new HashMap<String,String>(2*_map320.size);
+            for (int _i321 = 0; _i321 < _map320.size; ++_i321)
             {
-              String _key314; // required
-              String _val315; // optional
-              _key314 = iprot.readString();
-              _val315 = iprot.readString();
-              struct.success.put(_key314, _val315);
+              String _key322; // required
+              String _val323; // optional
+              _key322 = iprot.readString();
+              _val323 = iprot.readString();
+              struct.success.put(_key322, _val323);
             }
           }
           struct.setSuccessIsSet(true);


Mime
View raw message