incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [34/50] [abbrv] git commit: Removed old Record and Row structs.
Date Wed, 07 Nov 2012 02:26:56 GMT
Removed old Record and Row structs.


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

Branch: refs/heads/0.2-dev-removing-old-thrift
Commit: be602306ac23a652240265929d703315bdf75590
Parents: 83aa59f
Author: Aaron McCurry <amccurry@gmail.com>
Authored: Tue Nov 6 17:37:01 2012 -0500
Committer: Aaron McCurry <amccurry@gmail.com>
Committed: Tue Nov 6 17:37:01 2012 -0500

----------------------------------------------------------------------
 interface/Blur.thrift                              |   38 -
 interface/gen-html/Blur.html                       |   22 -
 interface/gen-html/index.html                      |    2 -
 .../blur/thrift/generated/AnalyzerDefinition.java  |   48 +-
 .../org/apache/blur/thrift/generated/Blur.java     |  316 +++---
 .../blur/thrift/generated/BlurQueryStatus.java     |   48 +-
 .../blur/thrift/generated/ColumnDefinition.java    |   48 +-
 .../thrift/generated/ColumnFamilyDefinition.java   |   48 +-
 .../blur/thrift/generated/ColumnPreCache.java      |   32 +-
 .../org/apache/blur/thrift/generated/Document.java |   36 +-
 .../apache/blur/thrift/generated/QueryArgs.java    |   32 +-
 .../blur/thrift/generated/RecordMutation.java      |  545 --------
 .../apache/blur/thrift/generated/RowMutation.java  | 1022 ---------------
 .../org/apache/blur/thrift/generated/Schema.java   |   72 +-
 .../org/apache/blur/thrift/generated/ScoreDoc.java |   32 +-
 .../org/apache/blur/thrift/generated/Session.java  |   44 +-
 .../apache/blur/thrift/generated/ShardServer.java  |  280 ++--
 .../org/apache/blur/thrift/generated/Sort.java     |   36 +-
 .../blur/thrift/generated/TableDescriptor.java     |   32 +-
 .../apache/blur/thrift/generated/TopFieldDocs.java |   72 +-
 .../blur/thrift/generated/UpdatePackage.java       |   36 +-
 interface/gen-perl/Blur/Blur.pm                    |  180 ++--
 interface/gen-perl/Blur/ShardServer.pm             |  156 ++--
 interface/gen-perl/Blur/Types.pm                   |  595 +++------
 interface/gen-rb/blur_types.rb                     |   58 -
 .../java/org/apache/blur/manager/IndexManager.java |  287 +----
 .../apache/blur/thrift/BlurControllerServer.java   |   28 -
 .../org/apache/blur/thrift/MutationHelper.java     |   69 -
 .../main/java/org/apache/blur/utils/BlurUtil.java  |   78 --
 .../org/apache/blur/manager/IndexManagerTest.java  |  392 +------
 .../org/apache/blur/thrift/BlurClusterTest.java    |    8 -
 .../java/org/apache/blur/utils/BlurUtilsTest.java  |   28 -
 .../blur/thrift/generated/AnalyzerDefinition.java  |   48 +-
 .../org/apache/blur/thrift/generated/Blur.java     |  316 +++---
 .../blur/thrift/generated/BlurQueryStatus.java     |   48 +-
 .../blur/thrift/generated/ColumnDefinition.java    |   48 +-
 .../thrift/generated/ColumnFamilyDefinition.java   |   48 +-
 .../blur/thrift/generated/ColumnPreCache.java      |   32 +-
 .../org/apache/blur/thrift/generated/Document.java |   36 +-
 .../apache/blur/thrift/generated/QueryArgs.java    |   32 +-
 .../blur/thrift/generated/RecordMutation.java      |  545 --------
 .../apache/blur/thrift/generated/RowMutation.java  | 1022 ---------------
 .../org/apache/blur/thrift/generated/Schema.java   |   72 +-
 .../org/apache/blur/thrift/generated/ScoreDoc.java |   32 +-
 .../org/apache/blur/thrift/generated/Session.java  |   44 +-
 .../apache/blur/thrift/generated/ShardServer.java  |  280 ++--
 .../org/apache/blur/thrift/generated/Sort.java     |   36 +-
 .../blur/thrift/generated/TableDescriptor.java     |   32 +-
 .../apache/blur/thrift/generated/TopFieldDocs.java |   72 +-
 .../blur/thrift/generated/UpdatePackage.java       |   36 +-
 50 files changed, 1559 insertions(+), 5940 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/be602306/interface/Blur.thrift
----------------------------------------------------------------------
diff --git a/interface/Blur.thrift b/interface/Blur.thrift
index 9ca7f18..fc12e5b 100644
--- a/interface/Blur.thrift
+++ b/interface/Blur.thrift
@@ -396,44 +396,6 @@ struct BlurResults {
 /**
  *
  */
-struct RecordMutation {
-  /**
-   *
-   */
-  1:RecordMutationType recordMutationType,
-  /**
-   *
-   */
-  2:Record record
-}
-
-/**
- *
- */
-struct RowMutation {
-  /**
-   * The that that the row mutation is to act upon.
-   */
-  1:string table,
-  /**
-   * The row id that the row mutation is to act upon.
-   */
-  2:string rowId,
-  /**
-   * Write ahead log, by default all updates are written to a write ahead log before the update is applied.  That way if a failure occurs before the index is committed the WAL can be replayed to recover any data that could have been lost.
-   */
-  3:bool wal = 1,
-  4:RowMutationType rowMutationType,
-  5:list<RecordMutation> recordMutations,
-  /**
-   * On mutate waits for the mutation to be visible to queries and fetch requests.
-   */
-  6:bool waitToBeVisible = 0
-}
-
-/**
- *
- */
 struct CpuTime {
   /**
    *

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/be602306/interface/gen-html/Blur.html
----------------------------------------------------------------------
diff --git a/interface/gen-html/Blur.html b/interface/gen-html/Blur.html
index 68ee727..1e6e795 100644
--- a/interface/gen-html/Blur.html
+++ b/interface/gen-html/Blur.html
@@ -71,10 +71,8 @@
 <a href="Blur.html#Struct_QuerySession">QuerySession</a><br/>
 <a href="Blur.html#Enum_QueryState">QueryState</a><br/>
 <a href="Blur.html#Struct_Record">Record</a><br/>
-<a href="Blur.html#Struct_RecordMutation">RecordMutation</a><br/>
 <a href="Blur.html#Enum_RecordMutationType">RecordMutationType</a><br/>
 <a href="Blur.html#Struct_Row">Row</a><br/>
-<a href="Blur.html#Struct_RowMutation">RowMutation</a><br/>
 <a href="Blur.html#Enum_RowMutationType">RowMutationType</a><br/>
 <a href="Blur.html#Struct_Schema">Schema</a><br/>
 <a href="Blur.html#Struct_ScoreDoc">ScoreDoc</a><br/>
@@ -323,26 +321,6 @@ through records of a row, this count will reflect the entire row.
 <tr><td>6</td><td>query</td><td><code><a href="Blur.html#Struct_BlurQuery">BlurQuery</a></code></td><td>
 </td><td>default</td><td></td></tr>
 </table><br/><p/>
-<br/></div><div class="definition"><h3 id="Struct_RecordMutation">Struct: RecordMutation</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>recordMutationType</td><td><code><a href="Blur.html#Enum_RecordMutationType">RecordMutationType</a></code></td><td>
-</td><td>default</td><td></td></tr>
-<tr><td>2</td><td>record</td><td><code><a href="Blur.html#Struct_Record">Record</a></code></td><td>
-</td><td>default</td><td></td></tr>
-</table><br/><p/>
-<br/></div><div class="definition"><h3 id="Struct_RowMutation">Struct: RowMutation</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>The that that the row mutation is to act upon.
-</td><td>default</td><td></td></tr>
-<tr><td>2</td><td>rowId</td><td><code>string</code></td><td>The row id that the row mutation is to act upon.
-</td><td>default</td><td></td></tr>
-<tr><td>3</td><td>wal</td><td><code>bool</code></td><td>Write ahead log, by default all updates are written to a write ahead log before the update is applied.  That way if a failure occurs before the index is committed the WAL can be replayed to recover any data that could have been lost.
-</td><td>default</td><td>1</td></tr>
-<tr><td>4</td><td>rowMutationType</td><td><code><a href="Blur.html#Enum_RowMutationType">RowMutationType</a></code></td><td></td><td>default</td><td></td></tr>
-<tr><td>5</td><td>recordMutations</td><td><code>list&lt;<code><a href="Blur.html#Struct_RecordMutation">RecordMutation</a></code>&gt;</code></td><td></td><td>default</td><td></td></tr>
-<tr><td>6</td><td>waitToBeVisible</td><td><code>bool</code></td><td>On mutate waits for the mutation to be visible to queries and fetch requests.
-</td><td>default</td><td>0</td></tr>
-</table><br/><p/>
 <br/></div><div class="definition"><h3 id="Struct_CpuTime">Struct: CpuTime</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>cpuTime</td><td><code>i64</code></td><td>

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/be602306/interface/gen-html/index.html
----------------------------------------------------------------------
diff --git a/interface/gen-html/index.html b/interface/gen-html/index.html
index 8ec7aee..56bb377 100644
--- a/interface/gen-html/index.html
+++ b/interface/gen-html/index.html
@@ -67,10 +67,8 @@
 <a href="Blur.html#Struct_QuerySession">QuerySession</a><br/>
 <a href="Blur.html#Enum_QueryState">QueryState</a><br/>
 <a href="Blur.html#Struct_Record">Record</a><br/>
-<a href="Blur.html#Struct_RecordMutation">RecordMutation</a><br/>
 <a href="Blur.html#Enum_RecordMutationType">RecordMutationType</a><br/>
 <a href="Blur.html#Struct_Row">Row</a><br/>
-<a href="Blur.html#Struct_RowMutation">RowMutation</a><br/>
 <a href="Blur.html#Enum_RowMutationType">RowMutationType</a><br/>
 <a href="Blur.html#Struct_Schema">Schema</a><br/>
 <a href="Blur.html#Struct_ScoreDoc">ScoreDoc</a><br/>

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/be602306/interface/gen-java/org/apache/blur/thrift/generated/AnalyzerDefinition.java
----------------------------------------------------------------------
diff --git a/interface/gen-java/org/apache/blur/thrift/generated/AnalyzerDefinition.java b/interface/gen-java/org/apache/blur/thrift/generated/AnalyzerDefinition.java
index 9a83d30..17efabb 100644
--- a/interface/gen-java/org/apache/blur/thrift/generated/AnalyzerDefinition.java
+++ b/interface/gen-java/org/apache/blur/thrift/generated/AnalyzerDefinition.java
@@ -579,16 +579,16 @@ public class AnalyzerDefinition implements org.apache.thrift.TBase<AnalyzerDefin
           case 3: // COLUMN_FAMILY_DEFINITIONS
             if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
               {
-                org.apache.thrift.protocol.TMap _map140 = iprot.readMapBegin();
-                struct.columnFamilyDefinitions = new HashMap<String,ColumnFamilyDefinition>(2*_map140.size);
-                for (int _i141 = 0; _i141 < _map140.size; ++_i141)
+                org.apache.thrift.protocol.TMap _map132 = iprot.readMapBegin();
+                struct.columnFamilyDefinitions = new HashMap<String,ColumnFamilyDefinition>(2*_map132.size);
+                for (int _i133 = 0; _i133 < _map132.size; ++_i133)
                 {
-                  String _key142; // required
-                  ColumnFamilyDefinition _val143; // optional
-                  _key142 = iprot.readString();
-                  _val143 = new ColumnFamilyDefinition();
-                  _val143.read(iprot);
-                  struct.columnFamilyDefinitions.put(_key142, _val143);
+                  String _key134; // required
+                  ColumnFamilyDefinition _val135; // optional
+                  _key134 = iprot.readString();
+                  _val135 = new ColumnFamilyDefinition();
+                  _val135.read(iprot);
+                  struct.columnFamilyDefinitions.put(_key134, _val135);
                 }
                 iprot.readMapEnd();
               }
@@ -626,10 +626,10 @@ public class AnalyzerDefinition implements org.apache.thrift.TBase<AnalyzerDefin
         oprot.writeFieldBegin(COLUMN_FAMILY_DEFINITIONS_FIELD_DESC);
         {
           oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.columnFamilyDefinitions.size()));
-          for (Map.Entry<String, ColumnFamilyDefinition> _iter144 : struct.columnFamilyDefinitions.entrySet())
+          for (Map.Entry<String, ColumnFamilyDefinition> _iter136 : struct.columnFamilyDefinitions.entrySet())
           {
-            oprot.writeString(_iter144.getKey());
-            _iter144.getValue().write(oprot);
+            oprot.writeString(_iter136.getKey());
+            _iter136.getValue().write(oprot);
           }
           oprot.writeMapEnd();
         }
@@ -672,10 +672,10 @@ public class AnalyzerDefinition implements org.apache.thrift.TBase<AnalyzerDefin
       if (struct.isSetColumnFamilyDefinitions()) {
         {
           oprot.writeI32(struct.columnFamilyDefinitions.size());
-          for (Map.Entry<String, ColumnFamilyDefinition> _iter145 : struct.columnFamilyDefinitions.entrySet())
+          for (Map.Entry<String, ColumnFamilyDefinition> _iter137 : struct.columnFamilyDefinitions.entrySet())
           {
-            oprot.writeString(_iter145.getKey());
-            _iter145.getValue().write(oprot);
+            oprot.writeString(_iter137.getKey());
+            _iter137.getValue().write(oprot);
           }
         }
       }
@@ -696,16 +696,16 @@ public class AnalyzerDefinition implements org.apache.thrift.TBase<AnalyzerDefin
       }
       if (incoming.get(2)) {
         {
-          org.apache.thrift.protocol.TMap _map146 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-          struct.columnFamilyDefinitions = new HashMap<String,ColumnFamilyDefinition>(2*_map146.size);
-          for (int _i147 = 0; _i147 < _map146.size; ++_i147)
+          org.apache.thrift.protocol.TMap _map138 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+          struct.columnFamilyDefinitions = new HashMap<String,ColumnFamilyDefinition>(2*_map138.size);
+          for (int _i139 = 0; _i139 < _map138.size; ++_i139)
           {
-            String _key148; // required
-            ColumnFamilyDefinition _val149; // optional
-            _key148 = iprot.readString();
-            _val149 = new ColumnFamilyDefinition();
-            _val149.read(iprot);
-            struct.columnFamilyDefinitions.put(_key148, _val149);
+            String _key140; // required
+            ColumnFamilyDefinition _val141; // optional
+            _key140 = iprot.readString();
+            _val141 = new ColumnFamilyDefinition();
+            _val141.read(iprot);
+            struct.columnFamilyDefinitions.put(_key140, _val141);
           }
         }
         struct.setColumnFamilyDefinitionsIsSet(true);

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/be602306/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 9cbbe51..e6335ff 100644
--- a/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
+++ b/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
@@ -2621,13 +2621,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 _list224 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list224.size);
+                  for (int _i225 = 0; _i225 < _list224.size; ++_i225)
                   {
-                    String _elem234; // required
-                    _elem234 = iprot.readString();
-                    struct.success.add(_elem234);
+                    String _elem226; // required
+                    _elem226 = iprot.readString();
+                    struct.success.add(_elem226);
                   }
                   iprot.readListEnd();
                 }
@@ -2664,9 +2664,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 _iter227 : struct.success)
             {
-              oprot.writeString(_iter235);
+              oprot.writeString(_iter227);
             }
             oprot.writeListEnd();
           }
@@ -2705,9 +2705,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter236 : struct.success)
+            for (String _iter228 : struct.success)
             {
-              oprot.writeString(_iter236);
+              oprot.writeString(_iter228);
             }
           }
         }
@@ -2722,13 +2722,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 _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)
             {
-              String _elem239; // required
-              _elem239 = iprot.readString();
-              struct.success.add(_elem239);
+              String _elem231; // required
+              _elem231 = iprot.readString();
+              struct.success.add(_elem231);
             }
           }
           struct.setSuccessIsSet(true);
@@ -3483,13 +3483,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 _list232 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list232.size);
+                  for (int _i233 = 0; _i233 < _list232.size; ++_i233)
                   {
-                    String _elem242; // required
-                    _elem242 = iprot.readString();
-                    struct.success.add(_elem242);
+                    String _elem234; // required
+                    _elem234 = iprot.readString();
+                    struct.success.add(_elem234);
                   }
                   iprot.readListEnd();
                 }
@@ -3526,9 +3526,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 _iter235 : struct.success)
             {
-              oprot.writeString(_iter243);
+              oprot.writeString(_iter235);
             }
             oprot.writeListEnd();
           }
@@ -3567,9 +3567,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter244 : struct.success)
+            for (String _iter236 : struct.success)
             {
-              oprot.writeString(_iter244);
+              oprot.writeString(_iter236);
             }
           }
         }
@@ -3584,13 +3584,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 _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 _elem247; // required
-              _elem247 = iprot.readString();
-              struct.success.add(_elem247);
+              String _elem239; // required
+              _elem239 = iprot.readString();
+              struct.success.add(_elem239);
             }
           }
           struct.setSuccessIsSet(true);
@@ -4237,13 +4237,13 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list248 = iprot.readListBegin();
-                  struct.success = new ArrayList<String>(_list248.size);
-                  for (int _i249 = 0; _i249 < _list248.size; ++_i249)
+                  org.apache.thrift.protocol.TList _list240 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list240.size);
+                  for (int _i241 = 0; _i241 < _list240.size; ++_i241)
                   {
-                    String _elem250; // required
-                    _elem250 = iprot.readString();
-                    struct.success.add(_elem250);
+                    String _elem242; // required
+                    _elem242 = iprot.readString();
+                    struct.success.add(_elem242);
                   }
                   iprot.readListEnd();
                 }
@@ -4280,9 +4280,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 _iter251 : struct.success)
+            for (String _iter243 : struct.success)
             {
-              oprot.writeString(_iter251);
+              oprot.writeString(_iter243);
             }
             oprot.writeListEnd();
           }
@@ -4321,9 +4321,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter252 : struct.success)
+            for (String _iter244 : struct.success)
             {
-              oprot.writeString(_iter252);
+              oprot.writeString(_iter244);
             }
           }
         }
@@ -4338,13 +4338,13 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            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)
+            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 _elem255; // required
-              _elem255 = iprot.readString();
-              struct.success.add(_elem255);
+              String _elem247; // required
+              _elem247 = iprot.readString();
+              struct.success.add(_elem247);
             }
           }
           struct.setSuccessIsSet(true);
@@ -5104,15 +5104,15 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
                 {
-                  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)
+                  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)
                   {
-                    String _key258; // required
-                    String _val259; // optional
-                    _key258 = iprot.readString();
-                    _val259 = iprot.readString();
-                    struct.success.put(_key258, _val259);
+                    String _key250; // required
+                    String _val251; // optional
+                    _key250 = iprot.readString();
+                    _val251 = iprot.readString();
+                    struct.success.put(_key250, _val251);
                   }
                   iprot.readMapEnd();
                 }
@@ -5149,10 +5149,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> _iter260 : struct.success.entrySet())
+            for (Map.Entry<String, String> _iter252 : struct.success.entrySet())
             {
-              oprot.writeString(_iter260.getKey());
-              oprot.writeString(_iter260.getValue());
+              oprot.writeString(_iter252.getKey());
+              oprot.writeString(_iter252.getValue());
             }
             oprot.writeMapEnd();
           }
@@ -5191,10 +5191,10 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (Map.Entry<String, String> _iter261 : struct.success.entrySet())
+            for (Map.Entry<String, String> _iter253 : struct.success.entrySet())
             {
-              oprot.writeString(_iter261.getKey());
-              oprot.writeString(_iter261.getValue());
+              oprot.writeString(_iter253.getKey());
+              oprot.writeString(_iter253.getValue());
             }
           }
         }
@@ -5209,15 +5209,15 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            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)
+            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)
             {
-              String _key264; // required
-              String _val265; // optional
-              _key264 = iprot.readString();
-              _val265 = iprot.readString();
-              struct.success.put(_key264, _val265);
+              String _key256; // required
+              String _val257; // optional
+              _key256 = iprot.readString();
+              _val257 = iprot.readString();
+              struct.success.put(_key256, _val257);
             }
           }
           struct.setSuccessIsSet(true);
@@ -5864,13 +5864,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 _list258 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list258.size);
+                  for (int _i259 = 0; _i259 < _list258.size; ++_i259)
                   {
-                    String _elem268; // required
-                    _elem268 = iprot.readString();
-                    struct.success.add(_elem268);
+                    String _elem260; // required
+                    _elem260 = iprot.readString();
+                    struct.success.add(_elem260);
                   }
                   iprot.readListEnd();
                 }
@@ -5907,9 +5907,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 _iter261 : struct.success)
             {
-              oprot.writeString(_iter269);
+              oprot.writeString(_iter261);
             }
             oprot.writeListEnd();
           }
@@ -5948,9 +5948,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter270 : struct.success)
+            for (String _iter262 : struct.success)
             {
-              oprot.writeString(_iter270);
+              oprot.writeString(_iter262);
             }
           }
         }
@@ -5965,13 +5965,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 _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)
             {
-              String _elem273; // required
-              _elem273 = iprot.readString();
-              struct.success.add(_elem273);
+              String _elem265; // required
+              _elem265 = iprot.readString();
+              struct.success.add(_elem265);
             }
           }
           struct.setSuccessIsSet(true);
@@ -6726,13 +6726,13 @@ 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<String>(_list274.size);
-                  for (int _i275 = 0; _i275 < _list274.size; ++_i275)
+                  org.apache.thrift.protocol.TList _list266 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list266.size);
+                  for (int _i267 = 0; _i267 < _list266.size; ++_i267)
                   {
-                    String _elem276; // required
-                    _elem276 = iprot.readString();
-                    struct.success.add(_elem276);
+                    String _elem268; // required
+                    _elem268 = iprot.readString();
+                    struct.success.add(_elem268);
                   }
                   iprot.readListEnd();
                 }
@@ -6769,9 +6769,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 _iter277 : struct.success)
+            for (String _iter269 : struct.success)
             {
-              oprot.writeString(_iter277);
+              oprot.writeString(_iter269);
             }
             oprot.writeListEnd();
           }
@@ -6810,9 +6810,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (String _iter278 : struct.success)
+            for (String _iter270 : struct.success)
             {
-              oprot.writeString(_iter278);
+              oprot.writeString(_iter270);
             }
           }
         }
@@ -6827,13 +6827,13 @@ 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.STRING, iprot.readI32());
-            struct.success = new ArrayList<String>(_list279.size);
-            for (int _i280 = 0; _i280 < _list279.size; ++_i280)
+            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 _elem281; // required
-              _elem281 = iprot.readString();
-              struct.success.add(_elem281);
+              String _elem273; // required
+              _elem273 = iprot.readString();
+              struct.success.add(_elem273);
             }
           }
           struct.setSuccessIsSet(true);
@@ -9211,14 +9211,14 @@ 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<BlurQueryStatus>(_list282.size);
-                  for (int _i283 = 0; _i283 < _list282.size; ++_i283)
+                  org.apache.thrift.protocol.TList _list274 = iprot.readListBegin();
+                  struct.success = new ArrayList<BlurQueryStatus>(_list274.size);
+                  for (int _i275 = 0; _i275 < _list274.size; ++_i275)
                   {
-                    BlurQueryStatus _elem284; // required
-                    _elem284 = new BlurQueryStatus();
-                    _elem284.read(iprot);
-                    struct.success.add(_elem284);
+                    BlurQueryStatus _elem276; // required
+                    _elem276 = new BlurQueryStatus();
+                    _elem276.read(iprot);
+                    struct.success.add(_elem276);
                   }
                   iprot.readListEnd();
                 }
@@ -9255,9 +9255,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 _iter285 : struct.success)
+            for (BlurQueryStatus _iter277 : struct.success)
             {
-              _iter285.write(oprot);
+              _iter277.write(oprot);
             }
             oprot.writeListEnd();
           }
@@ -9296,9 +9296,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (BlurQueryStatus _iter286 : struct.success)
+            for (BlurQueryStatus _iter278 : struct.success)
             {
-              _iter286.write(oprot);
+              _iter278.write(oprot);
             }
           }
         }
@@ -9313,14 +9313,14 @@ 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.STRUCT, iprot.readI32());
-            struct.success = new ArrayList<BlurQueryStatus>(_list287.size);
-            for (int _i288 = 0; _i288 < _list287.size; ++_i288)
+            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)
             {
-              BlurQueryStatus _elem289; // required
-              _elem289 = new BlurQueryStatus();
-              _elem289.read(iprot);
-              struct.success.add(_elem289);
+              BlurQueryStatus _elem281; // required
+              _elem281 = new BlurQueryStatus();
+              _elem281.read(iprot);
+              struct.success.add(_elem281);
             }
           }
           struct.setSuccessIsSet(true);
@@ -10075,13 +10075,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<Long>(_list290.size);
-                  for (int _i291 = 0; _i291 < _list290.size; ++_i291)
+                  org.apache.thrift.protocol.TList _list282 = iprot.readListBegin();
+                  struct.success = new ArrayList<Long>(_list282.size);
+                  for (int _i283 = 0; _i283 < _list282.size; ++_i283)
                   {
-                    long _elem292; // required
-                    _elem292 = iprot.readI64();
-                    struct.success.add(_elem292);
+                    long _elem284; // required
+                    _elem284 = iprot.readI64();
+                    struct.success.add(_elem284);
                   }
                   iprot.readListEnd();
                 }
@@ -10118,9 +10118,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 _iter293 : struct.success)
+            for (long _iter285 : struct.success)
             {
-              oprot.writeI64(_iter293);
+              oprot.writeI64(_iter285);
             }
             oprot.writeListEnd();
           }
@@ -10159,9 +10159,9 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (long _iter294 : struct.success)
+            for (long _iter286 : struct.success)
             {
-              oprot.writeI64(_iter294);
+              oprot.writeI64(_iter286);
             }
           }
         }
@@ -10176,13 +10176,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.I64, iprot.readI32());
-            struct.success = new ArrayList<Long>(_list295.size);
-            for (int _i296 = 0; _i296 < _list295.size; ++_i296)
+            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)
             {
-              long _elem297; // required
-              _elem297 = iprot.readI64();
-              struct.success.add(_elem297);
+              long _elem289; // required
+              _elem289 = iprot.readI64();
+              struct.success.add(_elem289);
             }
           }
           struct.setSuccessIsSet(true);
@@ -18753,15 +18753,15 @@ public class Blur {
             case 0: // SUCCESS
               if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
                 {
-                  org.apache.thrift.protocol.TMap _map298 = iprot.readMapBegin();
-                  struct.success = new HashMap<String,String>(2*_map298.size);
-                  for (int _i299 = 0; _i299 < _map298.size; ++_i299)
+                  org.apache.thrift.protocol.TMap _map290 = iprot.readMapBegin();
+                  struct.success = new HashMap<String,String>(2*_map290.size);
+                  for (int _i291 = 0; _i291 < _map290.size; ++_i291)
                   {
-                    String _key300; // required
-                    String _val301; // optional
-                    _key300 = iprot.readString();
-                    _val301 = iprot.readString();
-                    struct.success.put(_key300, _val301);
+                    String _key292; // required
+                    String _val293; // optional
+                    _key292 = iprot.readString();
+                    _val293 = iprot.readString();
+                    struct.success.put(_key292, _val293);
                   }
                   iprot.readMapEnd();
                 }
@@ -18798,10 +18798,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> _iter302 : struct.success.entrySet())
+            for (Map.Entry<String, String> _iter294 : struct.success.entrySet())
             {
-              oprot.writeString(_iter302.getKey());
-              oprot.writeString(_iter302.getValue());
+              oprot.writeString(_iter294.getKey());
+              oprot.writeString(_iter294.getValue());
             }
             oprot.writeMapEnd();
           }
@@ -18840,10 +18840,10 @@ public class Blur {
         if (struct.isSetSuccess()) {
           {
             oprot.writeI32(struct.success.size());
-            for (Map.Entry<String, String> _iter303 : struct.success.entrySet())
+            for (Map.Entry<String, String> _iter295 : struct.success.entrySet())
             {
-              oprot.writeString(_iter303.getKey());
-              oprot.writeString(_iter303.getValue());
+              oprot.writeString(_iter295.getKey());
+              oprot.writeString(_iter295.getValue());
             }
           }
         }
@@ -18858,15 +18858,15 @@ public class Blur {
         BitSet incoming = iprot.readBitSet(2);
         if (incoming.get(0)) {
           {
-            org.apache.thrift.protocol.TMap _map304 = 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*_map304.size);
-            for (int _i305 = 0; _i305 < _map304.size; ++_i305)
+            org.apache.thrift.protocol.TMap _map296 = 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*_map296.size);
+            for (int _i297 = 0; _i297 < _map296.size; ++_i297)
             {
-              String _key306; // required
-              String _val307; // optional
-              _key306 = iprot.readString();
-              _val307 = iprot.readString();
-              struct.success.put(_key306, _val307);
+              String _key298; // required
+              String _val299; // optional
+              _key298 = iprot.readString();
+              _val299 = iprot.readString();
+              struct.success.put(_key298, _val299);
             }
           }
           struct.setSuccessIsSet(true);

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/be602306/interface/gen-java/org/apache/blur/thrift/generated/BlurQueryStatus.java
----------------------------------------------------------------------
diff --git a/interface/gen-java/org/apache/blur/thrift/generated/BlurQueryStatus.java b/interface/gen-java/org/apache/blur/thrift/generated/BlurQueryStatus.java
index 9a69659..e879499 100644
--- a/interface/gen-java/org/apache/blur/thrift/generated/BlurQueryStatus.java
+++ b/interface/gen-java/org/apache/blur/thrift/generated/BlurQueryStatus.java
@@ -835,16 +835,16 @@ public class BlurQueryStatus implements org.apache.thrift.TBase<BlurQueryStatus,
           case 2: // CPU_TIMES
             if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
               {
-                org.apache.thrift.protocol.TMap _map92 = iprot.readMapBegin();
-                struct.cpuTimes = new HashMap<String,CpuTime>(2*_map92.size);
-                for (int _i93 = 0; _i93 < _map92.size; ++_i93)
+                org.apache.thrift.protocol.TMap _map84 = iprot.readMapBegin();
+                struct.cpuTimes = new HashMap<String,CpuTime>(2*_map84.size);
+                for (int _i85 = 0; _i85 < _map84.size; ++_i85)
                 {
-                  String _key94; // required
-                  CpuTime _val95; // optional
-                  _key94 = iprot.readString();
-                  _val95 = new CpuTime();
-                  _val95.read(iprot);
-                  struct.cpuTimes.put(_key94, _val95);
+                  String _key86; // required
+                  CpuTime _val87; // optional
+                  _key86 = iprot.readString();
+                  _val87 = new CpuTime();
+                  _val87.read(iprot);
+                  struct.cpuTimes.put(_key86, _val87);
                 }
                 iprot.readMapEnd();
               }
@@ -909,10 +909,10 @@ public class BlurQueryStatus implements org.apache.thrift.TBase<BlurQueryStatus,
         oprot.writeFieldBegin(CPU_TIMES_FIELD_DESC);
         {
           oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.cpuTimes.size()));
-          for (Map.Entry<String, CpuTime> _iter96 : struct.cpuTimes.entrySet())
+          for (Map.Entry<String, CpuTime> _iter88 : struct.cpuTimes.entrySet())
           {
-            oprot.writeString(_iter96.getKey());
-            _iter96.getValue().write(oprot);
+            oprot.writeString(_iter88.getKey());
+            _iter88.getValue().write(oprot);
           }
           oprot.writeMapEnd();
         }
@@ -975,10 +975,10 @@ public class BlurQueryStatus implements org.apache.thrift.TBase<BlurQueryStatus,
       if (struct.isSetCpuTimes()) {
         {
           oprot.writeI32(struct.cpuTimes.size());
-          for (Map.Entry<String, CpuTime> _iter97 : struct.cpuTimes.entrySet())
+          for (Map.Entry<String, CpuTime> _iter89 : struct.cpuTimes.entrySet())
           {
-            oprot.writeString(_iter97.getKey());
-            _iter97.getValue().write(oprot);
+            oprot.writeString(_iter89.getKey());
+            _iter89.getValue().write(oprot);
           }
         }
       }
@@ -1007,16 +1007,16 @@ public class BlurQueryStatus implements org.apache.thrift.TBase<BlurQueryStatus,
       }
       if (incoming.get(1)) {
         {
-          org.apache.thrift.protocol.TMap _map98 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-          struct.cpuTimes = new HashMap<String,CpuTime>(2*_map98.size);
-          for (int _i99 = 0; _i99 < _map98.size; ++_i99)
+          org.apache.thrift.protocol.TMap _map90 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+          struct.cpuTimes = new HashMap<String,CpuTime>(2*_map90.size);
+          for (int _i91 = 0; _i91 < _map90.size; ++_i91)
           {
-            String _key100; // required
-            CpuTime _val101; // optional
-            _key100 = iprot.readString();
-            _val101 = new CpuTime();
-            _val101.read(iprot);
-            struct.cpuTimes.put(_key100, _val101);
+            String _key92; // required
+            CpuTime _val93; // optional
+            _key92 = iprot.readString();
+            _val93 = new CpuTime();
+            _val93.read(iprot);
+            struct.cpuTimes.put(_key92, _val93);
           }
         }
         struct.setCpuTimesIsSet(true);

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/be602306/interface/gen-java/org/apache/blur/thrift/generated/ColumnDefinition.java
----------------------------------------------------------------------
diff --git a/interface/gen-java/org/apache/blur/thrift/generated/ColumnDefinition.java b/interface/gen-java/org/apache/blur/thrift/generated/ColumnDefinition.java
index 9c48485..8f90490 100644
--- a/interface/gen-java/org/apache/blur/thrift/generated/ColumnDefinition.java
+++ b/interface/gen-java/org/apache/blur/thrift/generated/ColumnDefinition.java
@@ -539,16 +539,16 @@ public class ColumnDefinition implements org.apache.thrift.TBase<ColumnDefinitio
           case 3: // ALTERNATE_COLUMN_DEFINITIONS
             if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
               {
-                org.apache.thrift.protocol.TMap _map120 = iprot.readMapBegin();
-                struct.alternateColumnDefinitions = new HashMap<String,AlternateColumnDefinition>(2*_map120.size);
-                for (int _i121 = 0; _i121 < _map120.size; ++_i121)
+                org.apache.thrift.protocol.TMap _map112 = iprot.readMapBegin();
+                struct.alternateColumnDefinitions = new HashMap<String,AlternateColumnDefinition>(2*_map112.size);
+                for (int _i113 = 0; _i113 < _map112.size; ++_i113)
                 {
-                  String _key122; // required
-                  AlternateColumnDefinition _val123; // optional
-                  _key122 = iprot.readString();
-                  _val123 = new AlternateColumnDefinition();
-                  _val123.read(iprot);
-                  struct.alternateColumnDefinitions.put(_key122, _val123);
+                  String _key114; // required
+                  AlternateColumnDefinition _val115; // optional
+                  _key114 = iprot.readString();
+                  _val115 = new AlternateColumnDefinition();
+                  _val115.read(iprot);
+                  struct.alternateColumnDefinitions.put(_key114, _val115);
                 }
                 iprot.readMapEnd();
               }
@@ -584,10 +584,10 @@ public class ColumnDefinition implements org.apache.thrift.TBase<ColumnDefinitio
         oprot.writeFieldBegin(ALTERNATE_COLUMN_DEFINITIONS_FIELD_DESC);
         {
           oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.alternateColumnDefinitions.size()));
-          for (Map.Entry<String, AlternateColumnDefinition> _iter124 : struct.alternateColumnDefinitions.entrySet())
+          for (Map.Entry<String, AlternateColumnDefinition> _iter116 : struct.alternateColumnDefinitions.entrySet())
           {
-            oprot.writeString(_iter124.getKey());
-            _iter124.getValue().write(oprot);
+            oprot.writeString(_iter116.getKey());
+            _iter116.getValue().write(oprot);
           }
           oprot.writeMapEnd();
         }
@@ -630,10 +630,10 @@ public class ColumnDefinition implements org.apache.thrift.TBase<ColumnDefinitio
       if (struct.isSetAlternateColumnDefinitions()) {
         {
           oprot.writeI32(struct.alternateColumnDefinitions.size());
-          for (Map.Entry<String, AlternateColumnDefinition> _iter125 : struct.alternateColumnDefinitions.entrySet())
+          for (Map.Entry<String, AlternateColumnDefinition> _iter117 : struct.alternateColumnDefinitions.entrySet())
           {
-            oprot.writeString(_iter125.getKey());
-            _iter125.getValue().write(oprot);
+            oprot.writeString(_iter117.getKey());
+            _iter117.getValue().write(oprot);
           }
         }
       }
@@ -653,16 +653,16 @@ public class ColumnDefinition implements org.apache.thrift.TBase<ColumnDefinitio
       }
       if (incoming.get(2)) {
         {
-          org.apache.thrift.protocol.TMap _map126 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-          struct.alternateColumnDefinitions = new HashMap<String,AlternateColumnDefinition>(2*_map126.size);
-          for (int _i127 = 0; _i127 < _map126.size; ++_i127)
+          org.apache.thrift.protocol.TMap _map118 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+          struct.alternateColumnDefinitions = new HashMap<String,AlternateColumnDefinition>(2*_map118.size);
+          for (int _i119 = 0; _i119 < _map118.size; ++_i119)
           {
-            String _key128; // required
-            AlternateColumnDefinition _val129; // optional
-            _key128 = iprot.readString();
-            _val129 = new AlternateColumnDefinition();
-            _val129.read(iprot);
-            struct.alternateColumnDefinitions.put(_key128, _val129);
+            String _key120; // required
+            AlternateColumnDefinition _val121; // optional
+            _key120 = iprot.readString();
+            _val121 = new AlternateColumnDefinition();
+            _val121.read(iprot);
+            struct.alternateColumnDefinitions.put(_key120, _val121);
           }
         }
         struct.setAlternateColumnDefinitionsIsSet(true);

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/be602306/interface/gen-java/org/apache/blur/thrift/generated/ColumnFamilyDefinition.java
----------------------------------------------------------------------
diff --git a/interface/gen-java/org/apache/blur/thrift/generated/ColumnFamilyDefinition.java b/interface/gen-java/org/apache/blur/thrift/generated/ColumnFamilyDefinition.java
index 926b7a2..f6b2c8c 100644
--- a/interface/gen-java/org/apache/blur/thrift/generated/ColumnFamilyDefinition.java
+++ b/interface/gen-java/org/apache/blur/thrift/generated/ColumnFamilyDefinition.java
@@ -479,16 +479,16 @@ public class ColumnFamilyDefinition implements org.apache.thrift.TBase<ColumnFam
           case 2: // COLUMN_DEFINITIONS
             if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
               {
-                org.apache.thrift.protocol.TMap _map130 = iprot.readMapBegin();
-                struct.columnDefinitions = new HashMap<String,ColumnDefinition>(2*_map130.size);
-                for (int _i131 = 0; _i131 < _map130.size; ++_i131)
+                org.apache.thrift.protocol.TMap _map122 = iprot.readMapBegin();
+                struct.columnDefinitions = new HashMap<String,ColumnDefinition>(2*_map122.size);
+                for (int _i123 = 0; _i123 < _map122.size; ++_i123)
                 {
-                  String _key132; // required
-                  ColumnDefinition _val133; // optional
-                  _key132 = iprot.readString();
-                  _val133 = new ColumnDefinition();
-                  _val133.read(iprot);
-                  struct.columnDefinitions.put(_key132, _val133);
+                  String _key124; // required
+                  ColumnDefinition _val125; // optional
+                  _key124 = iprot.readString();
+                  _val125 = new ColumnDefinition();
+                  _val125.read(iprot);
+                  struct.columnDefinitions.put(_key124, _val125);
                 }
                 iprot.readMapEnd();
               }
@@ -521,10 +521,10 @@ public class ColumnFamilyDefinition implements org.apache.thrift.TBase<ColumnFam
         oprot.writeFieldBegin(COLUMN_DEFINITIONS_FIELD_DESC);
         {
           oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, struct.columnDefinitions.size()));
-          for (Map.Entry<String, ColumnDefinition> _iter134 : struct.columnDefinitions.entrySet())
+          for (Map.Entry<String, ColumnDefinition> _iter126 : struct.columnDefinitions.entrySet())
           {
-            oprot.writeString(_iter134.getKey());
-            _iter134.getValue().write(oprot);
+            oprot.writeString(_iter126.getKey());
+            _iter126.getValue().write(oprot);
           }
           oprot.writeMapEnd();
         }
@@ -561,10 +561,10 @@ public class ColumnFamilyDefinition implements org.apache.thrift.TBase<ColumnFam
       if (struct.isSetColumnDefinitions()) {
         {
           oprot.writeI32(struct.columnDefinitions.size());
-          for (Map.Entry<String, ColumnDefinition> _iter135 : struct.columnDefinitions.entrySet())
+          for (Map.Entry<String, ColumnDefinition> _iter127 : struct.columnDefinitions.entrySet())
           {
-            oprot.writeString(_iter135.getKey());
-            _iter135.getValue().write(oprot);
+            oprot.writeString(_iter127.getKey());
+            _iter127.getValue().write(oprot);
           }
         }
       }
@@ -581,16 +581,16 @@ public class ColumnFamilyDefinition implements org.apache.thrift.TBase<ColumnFam
       }
       if (incoming.get(1)) {
         {
-          org.apache.thrift.protocol.TMap _map136 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
-          struct.columnDefinitions = new HashMap<String,ColumnDefinition>(2*_map136.size);
-          for (int _i137 = 0; _i137 < _map136.size; ++_i137)
+          org.apache.thrift.protocol.TMap _map128 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+          struct.columnDefinitions = new HashMap<String,ColumnDefinition>(2*_map128.size);
+          for (int _i129 = 0; _i129 < _map128.size; ++_i129)
           {
-            String _key138; // required
-            ColumnDefinition _val139; // optional
-            _key138 = iprot.readString();
-            _val139 = new ColumnDefinition();
-            _val139.read(iprot);
-            struct.columnDefinitions.put(_key138, _val139);
+            String _key130; // required
+            ColumnDefinition _val131; // optional
+            _key130 = iprot.readString();
+            _val131 = new ColumnDefinition();
+            _val131.read(iprot);
+            struct.columnDefinitions.put(_key130, _val131);
           }
         }
         struct.setColumnDefinitionsIsSet(true);

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/be602306/interface/gen-java/org/apache/blur/thrift/generated/ColumnPreCache.java
----------------------------------------------------------------------
diff --git a/interface/gen-java/org/apache/blur/thrift/generated/ColumnPreCache.java b/interface/gen-java/org/apache/blur/thrift/generated/ColumnPreCache.java
index 482acfb..d271f8f 100644
--- a/interface/gen-java/org/apache/blur/thrift/generated/ColumnPreCache.java
+++ b/interface/gen-java/org/apache/blur/thrift/generated/ColumnPreCache.java
@@ -373,13 +373,13 @@ public class ColumnPreCache implements org.apache.thrift.TBase<ColumnPreCache, C
           case 1: // PRE_CACHE_COLS
             if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
               {
-                org.apache.thrift.protocol.TList _list150 = iprot.readListBegin();
-                struct.preCacheCols = new ArrayList<String>(_list150.size);
-                for (int _i151 = 0; _i151 < _list150.size; ++_i151)
+                org.apache.thrift.protocol.TList _list142 = iprot.readListBegin();
+                struct.preCacheCols = new ArrayList<String>(_list142.size);
+                for (int _i143 = 0; _i143 < _list142.size; ++_i143)
                 {
-                  String _elem152; // required
-                  _elem152 = iprot.readString();
-                  struct.preCacheCols.add(_elem152);
+                  String _elem144; // required
+                  _elem144 = iprot.readString();
+                  struct.preCacheCols.add(_elem144);
                 }
                 iprot.readListEnd();
               }
@@ -407,9 +407,9 @@ public class ColumnPreCache implements org.apache.thrift.TBase<ColumnPreCache, C
         oprot.writeFieldBegin(PRE_CACHE_COLS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.preCacheCols.size()));
-          for (String _iter153 : struct.preCacheCols)
+          for (String _iter145 : struct.preCacheCols)
           {
-            oprot.writeString(_iter153);
+            oprot.writeString(_iter145);
           }
           oprot.writeListEnd();
         }
@@ -440,9 +440,9 @@ public class ColumnPreCache implements org.apache.thrift.TBase<ColumnPreCache, C
       if (struct.isSetPreCacheCols()) {
         {
           oprot.writeI32(struct.preCacheCols.size());
-          for (String _iter154 : struct.preCacheCols)
+          for (String _iter146 : struct.preCacheCols)
           {
-            oprot.writeString(_iter154);
+            oprot.writeString(_iter146);
           }
         }
       }
@@ -454,13 +454,13 @@ public class ColumnPreCache implements org.apache.thrift.TBase<ColumnPreCache, C
       BitSet incoming = iprot.readBitSet(1);
       if (incoming.get(0)) {
         {
-          org.apache.thrift.protocol.TList _list155 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
-          struct.preCacheCols = new ArrayList<String>(_list155.size);
-          for (int _i156 = 0; _i156 < _list155.size; ++_i156)
+          org.apache.thrift.protocol.TList _list147 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+          struct.preCacheCols = new ArrayList<String>(_list147.size);
+          for (int _i148 = 0; _i148 < _list147.size; ++_i148)
           {
-            String _elem157; // required
-            _elem157 = iprot.readString();
-            struct.preCacheCols.add(_elem157);
+            String _elem149; // required
+            _elem149 = iprot.readString();
+            struct.preCacheCols.add(_elem149);
           }
         }
         struct.setPreCacheColsIsSet(true);

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/be602306/interface/gen-java/org/apache/blur/thrift/generated/Document.java
----------------------------------------------------------------------
diff --git a/interface/gen-java/org/apache/blur/thrift/generated/Document.java b/interface/gen-java/org/apache/blur/thrift/generated/Document.java
index eb58daa..fd15498 100644
--- a/interface/gen-java/org/apache/blur/thrift/generated/Document.java
+++ b/interface/gen-java/org/apache/blur/thrift/generated/Document.java
@@ -370,14 +370,14 @@ public class Document implements org.apache.thrift.TBase<Document, Document._Fie
           case 1: // FIELDS
             if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
               {
-                org.apache.thrift.protocol.TList _list216 = iprot.readListBegin();
-                struct.fields = new ArrayList<Field>(_list216.size);
-                for (int _i217 = 0; _i217 < _list216.size; ++_i217)
+                org.apache.thrift.protocol.TList _list208 = iprot.readListBegin();
+                struct.fields = new ArrayList<Field>(_list208.size);
+                for (int _i209 = 0; _i209 < _list208.size; ++_i209)
                 {
-                  Field _elem218; // required
-                  _elem218 = new Field();
-                  _elem218.read(iprot);
-                  struct.fields.add(_elem218);
+                  Field _elem210; // required
+                  _elem210 = new Field();
+                  _elem210.read(iprot);
+                  struct.fields.add(_elem210);
                 }
                 iprot.readListEnd();
               }
@@ -405,9 +405,9 @@ public class Document implements org.apache.thrift.TBase<Document, Document._Fie
         oprot.writeFieldBegin(FIELDS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.fields.size()));
-          for (Field _iter219 : struct.fields)
+          for (Field _iter211 : struct.fields)
           {
-            _iter219.write(oprot);
+            _iter211.write(oprot);
           }
           oprot.writeListEnd();
         }
@@ -438,9 +438,9 @@ public class Document implements org.apache.thrift.TBase<Document, Document._Fie
       if (struct.isSetFields()) {
         {
           oprot.writeI32(struct.fields.size());
-          for (Field _iter220 : struct.fields)
+          for (Field _iter212 : struct.fields)
           {
-            _iter220.write(oprot);
+            _iter212.write(oprot);
           }
         }
       }
@@ -452,14 +452,14 @@ public class Document implements org.apache.thrift.TBase<Document, Document._Fie
       BitSet incoming = iprot.readBitSet(1);
       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.fields = new ArrayList<Field>(_list221.size);
-          for (int _i222 = 0; _i222 < _list221.size; ++_i222)
+          org.apache.thrift.protocol.TList _list213 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+          struct.fields = new ArrayList<Field>(_list213.size);
+          for (int _i214 = 0; _i214 < _list213.size; ++_i214)
           {
-            Field _elem223; // required
-            _elem223 = new Field();
-            _elem223.read(iprot);
-            struct.fields.add(_elem223);
+            Field _elem215; // required
+            _elem215 = new Field();
+            _elem215.read(iprot);
+            struct.fields.add(_elem215);
           }
         }
         struct.setFieldsIsSet(true);

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/be602306/interface/gen-java/org/apache/blur/thrift/generated/QueryArgs.java
----------------------------------------------------------------------
diff --git a/interface/gen-java/org/apache/blur/thrift/generated/QueryArgs.java b/interface/gen-java/org/apache/blur/thrift/generated/QueryArgs.java
index 598d764..20a95cd 100644
--- a/interface/gen-java/org/apache/blur/thrift/generated/QueryArgs.java
+++ b/interface/gen-java/org/apache/blur/thrift/generated/QueryArgs.java
@@ -975,13 +975,13 @@ public class QueryArgs implements org.apache.thrift.TBase<QueryArgs, QueryArgs._
           case 8: // SHARD_INDEXES
             if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
               {
-                org.apache.thrift.protocol.TList _list192 = iprot.readListBegin();
-                struct.shardIndexes = new ArrayList<Integer>(_list192.size);
-                for (int _i193 = 0; _i193 < _list192.size; ++_i193)
+                org.apache.thrift.protocol.TList _list184 = iprot.readListBegin();
+                struct.shardIndexes = new ArrayList<Integer>(_list184.size);
+                for (int _i185 = 0; _i185 < _list184.size; ++_i185)
                 {
-                  int _elem194; // required
-                  _elem194 = iprot.readI32();
-                  struct.shardIndexes.add(_elem194);
+                  int _elem186; // required
+                  _elem186 = iprot.readI32();
+                  struct.shardIndexes.add(_elem186);
                 }
                 iprot.readListEnd();
               }
@@ -1038,9 +1038,9 @@ public class QueryArgs implements org.apache.thrift.TBase<QueryArgs, QueryArgs._
         oprot.writeFieldBegin(SHARD_INDEXES_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, struct.shardIndexes.size()));
-          for (int _iter195 : struct.shardIndexes)
+          for (int _iter187 : struct.shardIndexes)
           {
-            oprot.writeI32(_iter195);
+            oprot.writeI32(_iter187);
           }
           oprot.writeListEnd();
         }
@@ -1113,9 +1113,9 @@ public class QueryArgs implements org.apache.thrift.TBase<QueryArgs, QueryArgs._
       if (struct.isSetShardIndexes()) {
         {
           oprot.writeI32(struct.shardIndexes.size());
-          for (int _iter196 : struct.shardIndexes)
+          for (int _iter188 : struct.shardIndexes)
           {
-            oprot.writeI32(_iter196);
+            oprot.writeI32(_iter188);
           }
         }
       }
@@ -1157,13 +1157,13 @@ public class QueryArgs implements org.apache.thrift.TBase<QueryArgs, QueryArgs._
       }
       if (incoming.get(7)) {
         {
-          org.apache.thrift.protocol.TList _list197 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, iprot.readI32());
-          struct.shardIndexes = new ArrayList<Integer>(_list197.size);
-          for (int _i198 = 0; _i198 < _list197.size; ++_i198)
+          org.apache.thrift.protocol.TList _list189 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I32, iprot.readI32());
+          struct.shardIndexes = new ArrayList<Integer>(_list189.size);
+          for (int _i190 = 0; _i190 < _list189.size; ++_i190)
           {
-            int _elem199; // required
-            _elem199 = iprot.readI32();
-            struct.shardIndexes.add(_elem199);
+            int _elem191; // required
+            _elem191 = iprot.readI32();
+            struct.shardIndexes.add(_elem191);
           }
         }
         struct.setShardIndexesIsSet(true);

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/be602306/interface/gen-java/org/apache/blur/thrift/generated/RecordMutation.java
----------------------------------------------------------------------
diff --git a/interface/gen-java/org/apache/blur/thrift/generated/RecordMutation.java b/interface/gen-java/org/apache/blur/thrift/generated/RecordMutation.java
deleted file mode 100644
index 3074c75..0000000
--- a/interface/gen-java/org/apache/blur/thrift/generated/RecordMutation.java
+++ /dev/null
@@ -1,545 +0,0 @@
-/**
- * Autogenerated by Thrift Compiler (0.9.0)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- *  @generated
- */
-package org.apache.blur.thrift.generated;
-
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-
-import org.apache.thrift.scheme.IScheme;
-import org.apache.thrift.scheme.SchemeFactory;
-import org.apache.thrift.scheme.StandardScheme;
-
-import org.apache.thrift.scheme.TupleScheme;
-import org.apache.thrift.protocol.TTupleProtocol;
-import org.apache.thrift.protocol.TProtocolException;
-import org.apache.thrift.EncodingUtils;
-import org.apache.thrift.TException;
-import java.util.List;
-import java.util.ArrayList;
-import java.util.Map;
-import java.util.HashMap;
-import java.util.EnumMap;
-import java.util.Set;
-import java.util.HashSet;
-import java.util.EnumSet;
-import java.util.Collections;
-import java.util.BitSet;
-import java.nio.ByteBuffer;
-import java.util.Arrays;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * 
- */
-public class RecordMutation implements org.apache.thrift.TBase<RecordMutation, RecordMutation._Fields>, java.io.Serializable, Cloneable {
-  private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("RecordMutation");
-
-  private static final org.apache.thrift.protocol.TField RECORD_MUTATION_TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("recordMutationType", org.apache.thrift.protocol.TType.I32, (short)1);
-  private static final org.apache.thrift.protocol.TField RECORD_FIELD_DESC = new org.apache.thrift.protocol.TField("record", org.apache.thrift.protocol.TType.STRUCT, (short)2);
-
-  private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
-  static {
-    schemes.put(StandardScheme.class, new RecordMutationStandardSchemeFactory());
-    schemes.put(TupleScheme.class, new RecordMutationTupleSchemeFactory());
-  }
-
-  /**
-   * 
-   * 
-   * @see RecordMutationType
-   */
-  public RecordMutationType recordMutationType; // required
-  /**
-   * 
-   */
-  public Record record; // 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 {
-    /**
-     * 
-     * 
-     * @see RecordMutationType
-     */
-    RECORD_MUTATION_TYPE((short)1, "recordMutationType"),
-    /**
-     * 
-     */
-    RECORD((short)2, "record");
-
-    private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
-
-    static {
-      for (_Fields field : EnumSet.allOf(_Fields.class)) {
-        byName.put(field.getFieldName(), field);
-      }
-    }
-
-    /**
-     * Find the _Fields constant that matches fieldId, or null if its not found.
-     */
-    public static _Fields findByThriftId(int fieldId) {
-      switch(fieldId) {
-        case 1: // RECORD_MUTATION_TYPE
-          return RECORD_MUTATION_TYPE;
-        case 2: // RECORD
-          return RECORD;
-        default:
-          return null;
-      }
-    }
-
-    /**
-     * Find the _Fields constant that matches fieldId, throwing an exception
-     * if it is not found.
-     */
-    public static _Fields findByThriftIdOrThrow(int fieldId) {
-      _Fields fields = findByThriftId(fieldId);
-      if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
-      return fields;
-    }
-
-    /**
-     * Find the _Fields constant that matches name, or null if its not found.
-     */
-    public static _Fields findByName(String name) {
-      return byName.get(name);
-    }
-
-    private final short _thriftId;
-    private final String _fieldName;
-
-    _Fields(short thriftId, String fieldName) {
-      _thriftId = thriftId;
-      _fieldName = fieldName;
-    }
-
-    public short getThriftFieldId() {
-      return _thriftId;
-    }
-
-    public String getFieldName() {
-      return _fieldName;
-    }
-  }
-
-  // isset id assignments
-  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.RECORD_MUTATION_TYPE, new org.apache.thrift.meta_data.FieldMetaData("recordMutationType", org.apache.thrift.TFieldRequirementType.DEFAULT, 
-        new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, RecordMutationType.class)));
-    tmpMap.put(_Fields.RECORD, new org.apache.thrift.meta_data.FieldMetaData("record", org.apache.thrift.TFieldRequirementType.DEFAULT, 
-        new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Record.class)));
-    metaDataMap = Collections.unmodifiableMap(tmpMap);
-    org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(RecordMutation.class, metaDataMap);
-  }
-
-  public RecordMutation() {
-  }
-
-  public RecordMutation(
-    RecordMutationType recordMutationType,
-    Record record)
-  {
-    this();
-    this.recordMutationType = recordMutationType;
-    this.record = record;
-  }
-
-  /**
-   * Performs a deep copy on <i>other</i>.
-   */
-  public RecordMutation(RecordMutation other) {
-    if (other.isSetRecordMutationType()) {
-      this.recordMutationType = other.recordMutationType;
-    }
-    if (other.isSetRecord()) {
-      this.record = new Record(other.record);
-    }
-  }
-
-  public RecordMutation deepCopy() {
-    return new RecordMutation(this);
-  }
-
-  @Override
-  public void clear() {
-    this.recordMutationType = null;
-    this.record = null;
-  }
-
-  /**
-   * 
-   * 
-   * @see RecordMutationType
-   */
-  public RecordMutationType getRecordMutationType() {
-    return this.recordMutationType;
-  }
-
-  /**
-   * 
-   * 
-   * @see RecordMutationType
-   */
-  public RecordMutation setRecordMutationType(RecordMutationType recordMutationType) {
-    this.recordMutationType = recordMutationType;
-    return this;
-  }
-
-  public void unsetRecordMutationType() {
-    this.recordMutationType = null;
-  }
-
-  /** Returns true if field recordMutationType is set (has been assigned a value) and false otherwise */
-  public boolean isSetRecordMutationType() {
-    return this.recordMutationType != null;
-  }
-
-  public void setRecordMutationTypeIsSet(boolean value) {
-    if (!value) {
-      this.recordMutationType = null;
-    }
-  }
-
-  /**
-   * 
-   */
-  public Record getRecord() {
-    return this.record;
-  }
-
-  /**
-   * 
-   */
-  public RecordMutation setRecord(Record record) {
-    this.record = record;
-    return this;
-  }
-
-  public void unsetRecord() {
-    this.record = null;
-  }
-
-  /** Returns true if field record is set (has been assigned a value) and false otherwise */
-  public boolean isSetRecord() {
-    return this.record != null;
-  }
-
-  public void setRecordIsSet(boolean value) {
-    if (!value) {
-      this.record = null;
-    }
-  }
-
-  public void setFieldValue(_Fields field, Object value) {
-    switch (field) {
-    case RECORD_MUTATION_TYPE:
-      if (value == null) {
-        unsetRecordMutationType();
-      } else {
-        setRecordMutationType((RecordMutationType)value);
-      }
-      break;
-
-    case RECORD:
-      if (value == null) {
-        unsetRecord();
-      } else {
-        setRecord((Record)value);
-      }
-      break;
-
-    }
-  }
-
-  public Object getFieldValue(_Fields field) {
-    switch (field) {
-    case RECORD_MUTATION_TYPE:
-      return getRecordMutationType();
-
-    case RECORD:
-      return getRecord();
-
-    }
-    throw new IllegalStateException();
-  }
-
-  /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
-  public boolean isSet(_Fields field) {
-    if (field == null) {
-      throw new IllegalArgumentException();
-    }
-
-    switch (field) {
-    case RECORD_MUTATION_TYPE:
-      return isSetRecordMutationType();
-    case RECORD:
-      return isSetRecord();
-    }
-    throw new IllegalStateException();
-  }
-
-  @Override
-  public boolean equals(Object that) {
-    if (that == null)
-      return false;
-    if (that instanceof RecordMutation)
-      return this.equals((RecordMutation)that);
-    return false;
-  }
-
-  public boolean equals(RecordMutation that) {
-    if (that == null)
-      return false;
-
-    boolean this_present_recordMutationType = true && this.isSetRecordMutationType();
-    boolean that_present_recordMutationType = true && that.isSetRecordMutationType();
-    if (this_present_recordMutationType || that_present_recordMutationType) {
-      if (!(this_present_recordMutationType && that_present_recordMutationType))
-        return false;
-      if (!this.recordMutationType.equals(that.recordMutationType))
-        return false;
-    }
-
-    boolean this_present_record = true && this.isSetRecord();
-    boolean that_present_record = true && that.isSetRecord();
-    if (this_present_record || that_present_record) {
-      if (!(this_present_record && that_present_record))
-        return false;
-      if (!this.record.equals(that.record))
-        return false;
-    }
-
-    return true;
-  }
-
-  @Override
-  public int hashCode() {
-    return 0;
-  }
-
-  public int compareTo(RecordMutation other) {
-    if (!getClass().equals(other.getClass())) {
-      return getClass().getName().compareTo(other.getClass().getName());
-    }
-
-    int lastComparison = 0;
-    RecordMutation typedOther = (RecordMutation)other;
-
-    lastComparison = Boolean.valueOf(isSetRecordMutationType()).compareTo(typedOther.isSetRecordMutationType());
-    if (lastComparison != 0) {
-      return lastComparison;
-    }
-    if (isSetRecordMutationType()) {
-      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.recordMutationType, typedOther.recordMutationType);
-      if (lastComparison != 0) {
-        return lastComparison;
-      }
-    }
-    lastComparison = Boolean.valueOf(isSetRecord()).compareTo(typedOther.isSetRecord());
-    if (lastComparison != 0) {
-      return lastComparison;
-    }
-    if (isSetRecord()) {
-      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.record, typedOther.record);
-      if (lastComparison != 0) {
-        return lastComparison;
-      }
-    }
-    return 0;
-  }
-
-  public _Fields fieldForId(int fieldId) {
-    return _Fields.findByThriftId(fieldId);
-  }
-
-  public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
-    schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
-  }
-
-  public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
-    schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
-  }
-
-  @Override
-  public String toString() {
-    StringBuilder sb = new StringBuilder("RecordMutation(");
-    boolean first = true;
-
-    sb.append("recordMutationType:");
-    if (this.recordMutationType == null) {
-      sb.append("null");
-    } else {
-      sb.append(this.recordMutationType);
-    }
-    first = false;
-    if (!first) sb.append(", ");
-    sb.append("record:");
-    if (this.record == null) {
-      sb.append("null");
-    } else {
-      sb.append(this.record);
-    }
-    first = false;
-    sb.append(")");
-    return sb.toString();
-  }
-
-  public void validate() throws org.apache.thrift.TException {
-    // check for required fields
-    // check for sub-struct validity
-    if (record != null) {
-      record.validate();
-    }
-  }
-
-  private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
-    try {
-      write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
-    } catch (org.apache.thrift.TException te) {
-      throw new java.io.IOException(te);
-    }
-  }
-
-  private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
-    try {
-      read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
-    } catch (org.apache.thrift.TException te) {
-      throw new java.io.IOException(te);
-    }
-  }
-
-  private static class RecordMutationStandardSchemeFactory implements SchemeFactory {
-    public RecordMutationStandardScheme getScheme() {
-      return new RecordMutationStandardScheme();
-    }
-  }
-
-  private static class RecordMutationStandardScheme extends StandardScheme<RecordMutation> {
-
-    public void read(org.apache.thrift.protocol.TProtocol iprot, RecordMutation struct) throws org.apache.thrift.TException {
-      org.apache.thrift.protocol.TField schemeField;
-      iprot.readStructBegin();
-      while (true)
-      {
-        schemeField = iprot.readFieldBegin();
-        if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
-          break;
-        }
-        switch (schemeField.id) {
-          case 1: // RECORD_MUTATION_TYPE
-            if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
-              struct.recordMutationType = RecordMutationType.findByValue(iprot.readI32());
-              struct.setRecordMutationTypeIsSet(true);
-            } else { 
-              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
-            }
-            break;
-          case 2: // RECORD
-            if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
-              struct.record = new Record();
-              struct.record.read(iprot);
-              struct.setRecordIsSet(true);
-            } else { 
-              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
-            }
-            break;
-          default:
-            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
-        }
-        iprot.readFieldEnd();
-      }
-      iprot.readStructEnd();
-
-      // check for required fields of primitive type, which can't be checked in the validate method
-      struct.validate();
-    }
-
-    public void write(org.apache.thrift.protocol.TProtocol oprot, RecordMutation struct) throws org.apache.thrift.TException {
-      struct.validate();
-
-      oprot.writeStructBegin(STRUCT_DESC);
-      if (struct.recordMutationType != null) {
-        oprot.writeFieldBegin(RECORD_MUTATION_TYPE_FIELD_DESC);
-        oprot.writeI32(struct.recordMutationType.getValue());
-        oprot.writeFieldEnd();
-      }
-      if (struct.record != null) {
-        oprot.writeFieldBegin(RECORD_FIELD_DESC);
-        struct.record.write(oprot);
-        oprot.writeFieldEnd();
-      }
-      oprot.writeFieldStop();
-      oprot.writeStructEnd();
-    }
-
-  }
-
-  private static class RecordMutationTupleSchemeFactory implements SchemeFactory {
-    public RecordMutationTupleScheme getScheme() {
-      return new RecordMutationTupleScheme();
-    }
-  }
-
-  private static class RecordMutationTupleScheme extends TupleScheme<RecordMutation> {
-
-    @Override
-    public void write(org.apache.thrift.protocol.TProtocol prot, RecordMutation struct) throws org.apache.thrift.TException {
-      TTupleProtocol oprot = (TTupleProtocol) prot;
-      BitSet optionals = new BitSet();
-      if (struct.isSetRecordMutationType()) {
-        optionals.set(0);
-      }
-      if (struct.isSetRecord()) {
-        optionals.set(1);
-      }
-      oprot.writeBitSet(optionals, 2);
-      if (struct.isSetRecordMutationType()) {
-        oprot.writeI32(struct.recordMutationType.getValue());
-      }
-      if (struct.isSetRecord()) {
-        struct.record.write(oprot);
-      }
-    }
-
-    @Override
-    public void read(org.apache.thrift.protocol.TProtocol prot, RecordMutation struct) throws org.apache.thrift.TException {
-      TTupleProtocol iprot = (TTupleProtocol) prot;
-      BitSet incoming = iprot.readBitSet(2);
-      if (incoming.get(0)) {
-        struct.recordMutationType = RecordMutationType.findByValue(iprot.readI32());
-        struct.setRecordMutationTypeIsSet(true);
-      }
-      if (incoming.get(1)) {
-        struct.record = new Record();
-        struct.record.read(iprot);
-        struct.setRecordIsSet(true);
-      }
-    }
-  }
-
-}
-


Mime
View raw message