incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [23/28] Made some small API changes to the Row (removed recordCount because it did not work as documented). Added totalRecords to FetchRowResult that will take the place of recordCount in Row. Also removed the WAL and wait for visibility on the row mut
Date Wed, 15 Jan 2014 22:03:46 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/da6c233c/blur-thrift/src/main/java/org/apache/blur/thrift/generated/BlurResults.java
----------------------------------------------------------------------
diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/BlurResults.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/BlurResults.java
index 1d2cca8..e516cf1 100644
--- a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/BlurResults.java
+++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/BlurResults.java
@@ -896,15 +896,15 @@ public class BlurResults implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
           case 2: // SHARD_INFO
             if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP) {
               {
-                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map50 = iprot.readMapBegin();
-                struct.shardInfo = new HashMap<String,Long>(2*_map50.size);
-                for (int _i51 = 0; _i51 < _map50.size; ++_i51)
+                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map58 = iprot.readMapBegin();
+                struct.shardInfo = new HashMap<String,Long>(2*_map58.size);
+                for (int _i59 = 0; _i59 < _map58.size; ++_i59)
                 {
-                  String _key52; // optional
-                  long _val53; // required
-                  _key52 = iprot.readString();
-                  _val53 = iprot.readI64();
-                  struct.shardInfo.put(_key52, _val53);
+                  String _key60; // optional
+                  long _val61; // required
+                  _key60 = iprot.readString();
+                  _val61 = iprot.readI64();
+                  struct.shardInfo.put(_key60, _val61);
                 }
                 iprot.readMapEnd();
               }
@@ -916,14 +916,14 @@ public class BlurResults implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
           case 3: // RESULTS
             if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) {
               {
-                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list54 = iprot.readListBegin();
-                struct.results = new ArrayList<BlurResult>(_list54.size);
-                for (int _i55 = 0; _i55 < _list54.size; ++_i55)
+                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list62 = iprot.readListBegin();
+                struct.results = new ArrayList<BlurResult>(_list62.size);
+                for (int _i63 = 0; _i63 < _list62.size; ++_i63)
                 {
-                  BlurResult _elem56; // required
-                  _elem56 = new BlurResult();
-                  _elem56.read(iprot);
-                  struct.results.add(_elem56);
+                  BlurResult _elem64; // required
+                  _elem64 = new BlurResult();
+                  _elem64.read(iprot);
+                  struct.results.add(_elem64);
                 }
                 iprot.readListEnd();
               }
@@ -935,13 +935,13 @@ public class BlurResults implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
           case 4: // FACET_COUNTS
             if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) {
               {
-                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list57 = iprot.readListBegin();
-                struct.facetCounts = new ArrayList<Long>(_list57.size);
-                for (int _i58 = 0; _i58 < _list57.size; ++_i58)
+                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list65 = iprot.readListBegin();
+                struct.facetCounts = new ArrayList<Long>(_list65.size);
+                for (int _i66 = 0; _i66 < _list65.size; ++_i66)
                 {
-                  long _elem59; // required
-                  _elem59 = iprot.readI64();
-                  struct.facetCounts.add(_elem59);
+                  long _elem67; // required
+                  _elem67 = iprot.readI64();
+                  struct.facetCounts.add(_elem67);
                 }
                 iprot.readListEnd();
               }
@@ -953,14 +953,14 @@ public class BlurResults implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
           case 5: // EXCEPTIONS
             if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) {
               {
-                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list60 = iprot.readListBegin();
-                struct.exceptions = new ArrayList<BlurException>(_list60.size);
-                for (int _i61 = 0; _i61 < _list60.size; ++_i61)
+                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list68 = iprot.readListBegin();
+                struct.exceptions = new ArrayList<BlurException>(_list68.size);
+                for (int _i69 = 0; _i69 < _list68.size; ++_i69)
                 {
-                  BlurException _elem62; // required
-                  _elem62 = new BlurException();
-                  _elem62.read(iprot);
-                  struct.exceptions.add(_elem62);
+                  BlurException _elem70; // required
+                  _elem70 = new BlurException();
+                  _elem70.read(iprot);
+                  struct.exceptions.add(_elem70);
                 }
                 iprot.readListEnd();
               }
@@ -1000,10 +1000,10 @@ public class BlurResults implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
         oprot.writeFieldBegin(SHARD_INFO_FIELD_DESC);
         {
           oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, struct.shardInfo.size()));
-          for (Map.Entry<String, Long> _iter63 : struct.shardInfo.entrySet())
+          for (Map.Entry<String, Long> _iter71 : struct.shardInfo.entrySet())
           {
-            oprot.writeString(_iter63.getKey());
-            oprot.writeI64(_iter63.getValue());
+            oprot.writeString(_iter71.getKey());
+            oprot.writeI64(_iter71.getValue());
           }
           oprot.writeMapEnd();
         }
@@ -1013,9 +1013,9 @@ public class BlurResults implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
         oprot.writeFieldBegin(RESULTS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, struct.results.size()));
-          for (BlurResult _iter64 : struct.results)
+          for (BlurResult _iter72 : struct.results)
           {
-            _iter64.write(oprot);
+            _iter72.write(oprot);
           }
           oprot.writeListEnd();
         }
@@ -1025,9 +1025,9 @@ public class BlurResults implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
         oprot.writeFieldBegin(FACET_COUNTS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, struct.facetCounts.size()));
-          for (long _iter65 : struct.facetCounts)
+          for (long _iter73 : struct.facetCounts)
           {
-            oprot.writeI64(_iter65);
+            oprot.writeI64(_iter73);
           }
           oprot.writeListEnd();
         }
@@ -1037,9 +1037,9 @@ public class BlurResults implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
         oprot.writeFieldBegin(EXCEPTIONS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, struct.exceptions.size()));
-          for (BlurException _iter66 : struct.exceptions)
+          for (BlurException _iter74 : struct.exceptions)
           {
-            _iter66.write(oprot);
+            _iter74.write(oprot);
           }
           oprot.writeListEnd();
         }
@@ -1093,37 +1093,37 @@ public class BlurResults implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
       if (struct.isSetShardInfo()) {
         {
           oprot.writeI32(struct.shardInfo.size());
-          for (Map.Entry<String, Long> _iter67 : struct.shardInfo.entrySet())
+          for (Map.Entry<String, Long> _iter75 : struct.shardInfo.entrySet())
           {
-            oprot.writeString(_iter67.getKey());
-            oprot.writeI64(_iter67.getValue());
+            oprot.writeString(_iter75.getKey());
+            oprot.writeI64(_iter75.getValue());
           }
         }
       }
       if (struct.isSetResults()) {
         {
           oprot.writeI32(struct.results.size());
-          for (BlurResult _iter68 : struct.results)
+          for (BlurResult _iter76 : struct.results)
           {
-            _iter68.write(oprot);
+            _iter76.write(oprot);
           }
         }
       }
       if (struct.isSetFacetCounts()) {
         {
           oprot.writeI32(struct.facetCounts.size());
-          for (long _iter69 : struct.facetCounts)
+          for (long _iter77 : struct.facetCounts)
           {
-            oprot.writeI64(_iter69);
+            oprot.writeI64(_iter77);
           }
         }
       }
       if (struct.isSetExceptions()) {
         {
           oprot.writeI32(struct.exceptions.size());
-          for (BlurException _iter70 : struct.exceptions)
+          for (BlurException _iter78 : struct.exceptions)
           {
-            _iter70.write(oprot);
+            _iter78.write(oprot);
           }
         }
       }
@@ -1142,56 +1142,56 @@ public class BlurResults implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
       }
       if (incoming.get(1)) {
         {
-          org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map71 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, iprot.readI32());
-          struct.shardInfo = new HashMap<String,Long>(2*_map71.size);
-          for (int _i72 = 0; _i72 < _map71.size; ++_i72)
+          org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map79 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, iprot.readI32());
+          struct.shardInfo = new HashMap<String,Long>(2*_map79.size);
+          for (int _i80 = 0; _i80 < _map79.size; ++_i80)
           {
-            String _key73; // optional
-            long _val74; // required
-            _key73 = iprot.readString();
-            _val74 = iprot.readI64();
-            struct.shardInfo.put(_key73, _val74);
+            String _key81; // optional
+            long _val82; // required
+            _key81 = iprot.readString();
+            _val82 = iprot.readI64();
+            struct.shardInfo.put(_key81, _val82);
           }
         }
         struct.setShardInfoIsSet(true);
       }
       if (incoming.get(2)) {
         {
-          org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list75 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, iprot.readI32());
-          struct.results = new ArrayList<BlurResult>(_list75.size);
-          for (int _i76 = 0; _i76 < _list75.size; ++_i76)
+          org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list83 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, iprot.readI32());
+          struct.results = new ArrayList<BlurResult>(_list83.size);
+          for (int _i84 = 0; _i84 < _list83.size; ++_i84)
           {
-            BlurResult _elem77; // required
-            _elem77 = new BlurResult();
-            _elem77.read(iprot);
-            struct.results.add(_elem77);
+            BlurResult _elem85; // required
+            _elem85 = new BlurResult();
+            _elem85.read(iprot);
+            struct.results.add(_elem85);
           }
         }
         struct.setResultsIsSet(true);
       }
       if (incoming.get(3)) {
         {
-          org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list78 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, iprot.readI32());
-          struct.facetCounts = new ArrayList<Long>(_list78.size);
-          for (int _i79 = 0; _i79 < _list78.size; ++_i79)
+          org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list86 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, iprot.readI32());
+          struct.facetCounts = new ArrayList<Long>(_list86.size);
+          for (int _i87 = 0; _i87 < _list86.size; ++_i87)
           {
-            long _elem80; // required
-            _elem80 = iprot.readI64();
-            struct.facetCounts.add(_elem80);
+            long _elem88; // required
+            _elem88 = iprot.readI64();
+            struct.facetCounts.add(_elem88);
           }
         }
         struct.setFacetCountsIsSet(true);
       }
       if (incoming.get(4)) {
         {
-          org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list81 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, iprot.readI32());
-          struct.exceptions = new ArrayList<BlurException>(_list81.size);
-          for (int _i82 = 0; _i82 < _list81.size; ++_i82)
+          org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list89 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, iprot.readI32());
+          struct.exceptions = new ArrayList<BlurException>(_list89.size);
+          for (int _i90 = 0; _i90 < _list89.size; ++_i90)
           {
-            BlurException _elem83; // required
-            _elem83 = new BlurException();
-            _elem83.read(iprot);
-            struct.exceptions.add(_elem83);
+            BlurException _elem91; // required
+            _elem91 = new BlurException();
+            _elem91.read(iprot);
+            struct.exceptions.add(_elem91);
           }
         }
         struct.setExceptionsIsSet(true);

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/da6c233c/blur-thrift/src/main/java/org/apache/blur/thrift/generated/ColumnDefinition.java
----------------------------------------------------------------------
diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/ColumnDefinition.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/ColumnDefinition.java
index 9b0b2ad..1780e4e 100644
--- a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/ColumnDefinition.java
+++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/ColumnDefinition.java
@@ -903,15 +903,15 @@ public class ColumnDefinition implements org.apache.blur.thirdparty.thrift_0_9_0
           case 6: // PROPERTIES
             if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP) {
               {
-                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map102 = iprot.readMapBegin();
-                struct.properties = new HashMap<String,String>(2*_map102.size);
-                for (int _i103 = 0; _i103 < _map102.size; ++_i103)
+                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map110 = iprot.readMapBegin();
+                struct.properties = new HashMap<String,String>(2*_map110.size);
+                for (int _i111 = 0; _i111 < _map110.size; ++_i111)
                 {
-                  String _key104; // optional
-                  String _val105; // required
-                  _key104 = iprot.readString();
-                  _val105 = iprot.readString();
-                  struct.properties.put(_key104, _val105);
+                  String _key112; // optional
+                  String _val113; // required
+                  _key112 = iprot.readString();
+                  _val113 = iprot.readString();
+                  struct.properties.put(_key112, _val113);
                 }
                 iprot.readMapEnd();
               }
@@ -962,10 +962,10 @@ public class ColumnDefinition implements org.apache.blur.thirdparty.thrift_0_9_0
         oprot.writeFieldBegin(PROPERTIES_FIELD_DESC);
         {
           oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, struct.properties.size()));
-          for (Map.Entry<String, String> _iter106 : struct.properties.entrySet())
+          for (Map.Entry<String, String> _iter114 : struct.properties.entrySet())
           {
-            oprot.writeString(_iter106.getKey());
-            oprot.writeString(_iter106.getValue());
+            oprot.writeString(_iter114.getKey());
+            oprot.writeString(_iter114.getValue());
           }
           oprot.writeMapEnd();
         }
@@ -1026,10 +1026,10 @@ public class ColumnDefinition implements org.apache.blur.thirdparty.thrift_0_9_0
       if (struct.isSetProperties()) {
         {
           oprot.writeI32(struct.properties.size());
-          for (Map.Entry<String, String> _iter107 : struct.properties.entrySet())
+          for (Map.Entry<String, String> _iter115 : struct.properties.entrySet())
           {
-            oprot.writeString(_iter107.getKey());
-            oprot.writeString(_iter107.getValue());
+            oprot.writeString(_iter115.getKey());
+            oprot.writeString(_iter115.getValue());
           }
         }
       }
@@ -1061,15 +1061,15 @@ public class ColumnDefinition implements org.apache.blur.thirdparty.thrift_0_9_0
       }
       if (incoming.get(5)) {
         {
-          org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map108 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32());
-          struct.properties = new HashMap<String,String>(2*_map108.size);
-          for (int _i109 = 0; _i109 < _map108.size; ++_i109)
+          org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map116 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32());
+          struct.properties = new HashMap<String,String>(2*_map116.size);
+          for (int _i117 = 0; _i117 < _map116.size; ++_i117)
           {
-            String _key110; // optional
-            String _val111; // required
-            _key110 = iprot.readString();
-            _val111 = iprot.readString();
-            struct.properties.put(_key110, _val111);
+            String _key118; // optional
+            String _val119; // required
+            _key118 = iprot.readString();
+            _val119 = iprot.readString();
+            struct.properties.put(_key118, _val119);
           }
         }
         struct.setPropertiesIsSet(true);

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/da6c233c/blur-thrift/src/main/java/org/apache/blur/thrift/generated/FetchRowResult.java
----------------------------------------------------------------------
diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/FetchRowResult.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/FetchRowResult.java
index b87a9da..9f6403f 100644
--- a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/FetchRowResult.java
+++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/FetchRowResult.java
@@ -59,6 +59,7 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
   private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField START_RECORD_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("startRecord", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32, (short)2);
   private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField MAX_RECORDS_TO_FETCH_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("maxRecordsToFetch", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32, (short)3);
   private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField MORE_RECORDS_TO_FETCH_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("moreRecordsToFetch", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.BOOL, (short)4);
+  private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField TOTAL_RECORDS_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("totalRecords", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32, (short)5);
 
   private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
   static {
@@ -82,6 +83,10 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
    * Are there more Records to fetch based on the Selector provided.
    */
   public boolean moreRecordsToFetch; // required
+  /**
+   * The total number of records the Selector found.
+   */
+  public int totalRecords; // required
 
   /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
   public enum _Fields implements org.apache.blur.thirdparty.thrift_0_9_0.TFieldIdEnum {
@@ -100,7 +105,11 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
     /**
      * Are there more Records to fetch based on the Selector provided.
      */
-    MORE_RECORDS_TO_FETCH((short)4, "moreRecordsToFetch");
+    MORE_RECORDS_TO_FETCH((short)4, "moreRecordsToFetch"),
+    /**
+     * The total number of records the Selector found.
+     */
+    TOTAL_RECORDS((short)5, "totalRecords");
 
     private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -123,6 +132,8 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
           return MAX_RECORDS_TO_FETCH;
         case 4: // MORE_RECORDS_TO_FETCH
           return MORE_RECORDS_TO_FETCH;
+        case 5: // TOTAL_RECORDS
+          return TOTAL_RECORDS;
         default:
           return null;
       }
@@ -166,6 +177,7 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
   private static final int __STARTRECORD_ISSET_ID = 0;
   private static final int __MAXRECORDSTOFETCH_ISSET_ID = 1;
   private static final int __MORERECORDSTOFETCH_ISSET_ID = 2;
+  private static final int __TOTALRECORDS_ISSET_ID = 3;
   private byte __isset_bitfield = 0;
   public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> metaDataMap;
   static {
@@ -178,6 +190,8 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
         new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32)));
     tmpMap.put(_Fields.MORE_RECORDS_TO_FETCH, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("moreRecordsToFetch", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
         new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.BOOL)));
+    tmpMap.put(_Fields.TOTAL_RECORDS, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("totalRecords", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
+        new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32)));
     metaDataMap = Collections.unmodifiableMap(tmpMap);
     org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(FetchRowResult.class, metaDataMap);
   }
@@ -195,7 +209,8 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
     Row row,
     int startRecord,
     int maxRecordsToFetch,
-    boolean moreRecordsToFetch)
+    boolean moreRecordsToFetch,
+    int totalRecords)
   {
     this();
     this.row = row;
@@ -205,6 +220,8 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
     setMaxRecordsToFetchIsSet(true);
     this.moreRecordsToFetch = moreRecordsToFetch;
     setMoreRecordsToFetchIsSet(true);
+    this.totalRecords = totalRecords;
+    setTotalRecordsIsSet(true);
   }
 
   /**
@@ -218,6 +235,7 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
     this.startRecord = other.startRecord;
     this.maxRecordsToFetch = other.maxRecordsToFetch;
     this.moreRecordsToFetch = other.moreRecordsToFetch;
+    this.totalRecords = other.totalRecords;
   }
 
   public FetchRowResult deepCopy() {
@@ -233,6 +251,8 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
 
     this.moreRecordsToFetch = false;
 
+    setTotalRecordsIsSet(false);
+    this.totalRecords = 0;
   }
 
   /**
@@ -352,6 +372,35 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
     __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MORERECORDSTOFETCH_ISSET_ID, value);
   }
 
+  /**
+   * The total number of records the Selector found.
+   */
+  public int getTotalRecords() {
+    return this.totalRecords;
+  }
+
+  /**
+   * The total number of records the Selector found.
+   */
+  public FetchRowResult setTotalRecords(int totalRecords) {
+    this.totalRecords = totalRecords;
+    setTotalRecordsIsSet(true);
+    return this;
+  }
+
+  public void unsetTotalRecords() {
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TOTALRECORDS_ISSET_ID);
+  }
+
+  /** Returns true if field totalRecords is set (has been assigned a value) and false otherwise */
+  public boolean isSetTotalRecords() {
+    return EncodingUtils.testBit(__isset_bitfield, __TOTALRECORDS_ISSET_ID);
+  }
+
+  public void setTotalRecordsIsSet(boolean value) {
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TOTALRECORDS_ISSET_ID, value);
+  }
+
   public void setFieldValue(_Fields field, Object value) {
     switch (field) {
     case ROW:
@@ -386,6 +435,14 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
       }
       break;
 
+    case TOTAL_RECORDS:
+      if (value == null) {
+        unsetTotalRecords();
+      } else {
+        setTotalRecords((Integer)value);
+      }
+      break;
+
     }
   }
 
@@ -403,6 +460,9 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
     case MORE_RECORDS_TO_FETCH:
       return Boolean.valueOf(isMoreRecordsToFetch());
 
+    case TOTAL_RECORDS:
+      return Integer.valueOf(getTotalRecords());
+
     }
     throw new IllegalStateException();
   }
@@ -422,6 +482,8 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
       return isSetMaxRecordsToFetch();
     case MORE_RECORDS_TO_FETCH:
       return isSetMoreRecordsToFetch();
+    case TOTAL_RECORDS:
+      return isSetTotalRecords();
     }
     throw new IllegalStateException();
   }
@@ -475,6 +537,15 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
         return false;
     }
 
+    boolean this_present_totalRecords = true;
+    boolean that_present_totalRecords = true;
+    if (this_present_totalRecords || that_present_totalRecords) {
+      if (!(this_present_totalRecords && that_present_totalRecords))
+        return false;
+      if (this.totalRecords != that.totalRecords)
+        return false;
+    }
+
     return true;
   }
 
@@ -531,6 +602,16 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
         return lastComparison;
       }
     }
+    lastComparison = Boolean.valueOf(isSetTotalRecords()).compareTo(typedOther.isSetTotalRecords());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetTotalRecords()) {
+      lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.totalRecords, typedOther.totalRecords);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
     return 0;
   }
 
@@ -570,6 +651,10 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
     sb.append("moreRecordsToFetch:");
     sb.append(this.moreRecordsToFetch);
     first = false;
+    if (!first) sb.append(", ");
+    sb.append("totalRecords:");
+    sb.append(this.totalRecords);
+    first = false;
     sb.append(")");
     return sb.toString();
   }
@@ -651,6 +736,14 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
               org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
             }
             break;
+          case 5: // TOTAL_RECORDS
+            if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32) {
+              struct.totalRecords = iprot.readI32();
+              struct.setTotalRecordsIsSet(true);
+            } else { 
+              org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
           default:
             org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
         }
@@ -680,6 +773,9 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
       oprot.writeFieldBegin(MORE_RECORDS_TO_FETCH_FIELD_DESC);
       oprot.writeBool(struct.moreRecordsToFetch);
       oprot.writeFieldEnd();
+      oprot.writeFieldBegin(TOTAL_RECORDS_FIELD_DESC);
+      oprot.writeI32(struct.totalRecords);
+      oprot.writeFieldEnd();
       oprot.writeFieldStop();
       oprot.writeStructEnd();
     }
@@ -710,7 +806,10 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
       if (struct.isSetMoreRecordsToFetch()) {
         optionals.set(3);
       }
-      oprot.writeBitSet(optionals, 4);
+      if (struct.isSetTotalRecords()) {
+        optionals.set(4);
+      }
+      oprot.writeBitSet(optionals, 5);
       if (struct.isSetRow()) {
         struct.row.write(oprot);
       }
@@ -723,12 +822,15 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
       if (struct.isSetMoreRecordsToFetch()) {
         oprot.writeBool(struct.moreRecordsToFetch);
       }
+      if (struct.isSetTotalRecords()) {
+        oprot.writeI32(struct.totalRecords);
+      }
     }
 
     @Override
     public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, FetchRowResult struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
       TTupleProtocol iprot = (TTupleProtocol) prot;
-      BitSet incoming = iprot.readBitSet(4);
+      BitSet incoming = iprot.readBitSet(5);
       if (incoming.get(0)) {
         struct.row = new Row();
         struct.row.read(iprot);
@@ -746,6 +848,10 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
         struct.moreRecordsToFetch = iprot.readBool();
         struct.setMoreRecordsToFetchIsSet(true);
       }
+      if (incoming.get(4)) {
+        struct.totalRecords = iprot.readI32();
+        struct.setTotalRecordsIsSet(true);
+      }
     }
   }
 

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/da6c233c/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Metric.java
----------------------------------------------------------------------
diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Metric.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Metric.java
index ce9b7d6..f2f0814 100644
--- a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Metric.java
+++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Metric.java
@@ -703,15 +703,15 @@ public class Metric implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Met
           case 2: // STR_MAP
             if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP) {
               {
-                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map168 = iprot.readMapBegin();
-                struct.strMap = new HashMap<String,String>(2*_map168.size);
-                for (int _i169 = 0; _i169 < _map168.size; ++_i169)
+                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map176 = iprot.readMapBegin();
+                struct.strMap = new HashMap<String,String>(2*_map176.size);
+                for (int _i177 = 0; _i177 < _map176.size; ++_i177)
                 {
-                  String _key170; // optional
-                  String _val171; // required
-                  _key170 = iprot.readString();
-                  _val171 = iprot.readString();
-                  struct.strMap.put(_key170, _val171);
+                  String _key178; // optional
+                  String _val179; // required
+                  _key178 = iprot.readString();
+                  _val179 = iprot.readString();
+                  struct.strMap.put(_key178, _val179);
                 }
                 iprot.readMapEnd();
               }
@@ -723,15 +723,15 @@ public class Metric implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Met
           case 3: // LONG_MAP
             if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP) {
               {
-                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map172 = iprot.readMapBegin();
-                struct.longMap = new HashMap<String,Long>(2*_map172.size);
-                for (int _i173 = 0; _i173 < _map172.size; ++_i173)
+                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map180 = iprot.readMapBegin();
+                struct.longMap = new HashMap<String,Long>(2*_map180.size);
+                for (int _i181 = 0; _i181 < _map180.size; ++_i181)
                 {
-                  String _key174; // optional
-                  long _val175; // required
-                  _key174 = iprot.readString();
-                  _val175 = iprot.readI64();
-                  struct.longMap.put(_key174, _val175);
+                  String _key182; // optional
+                  long _val183; // required
+                  _key182 = iprot.readString();
+                  _val183 = iprot.readI64();
+                  struct.longMap.put(_key182, _val183);
                 }
                 iprot.readMapEnd();
               }
@@ -743,15 +743,15 @@ public class Metric implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Met
           case 4: // DOUBLE_MAP
             if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.MAP) {
               {
-                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map176 = iprot.readMapBegin();
-                struct.doubleMap = new HashMap<String,Double>(2*_map176.size);
-                for (int _i177 = 0; _i177 < _map176.size; ++_i177)
+                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map184 = iprot.readMapBegin();
+                struct.doubleMap = new HashMap<String,Double>(2*_map184.size);
+                for (int _i185 = 0; _i185 < _map184.size; ++_i185)
                 {
-                  String _key178; // optional
-                  double _val179; // required
-                  _key178 = iprot.readString();
-                  _val179 = iprot.readDouble();
-                  struct.doubleMap.put(_key178, _val179);
+                  String _key186; // optional
+                  double _val187; // required
+                  _key186 = iprot.readString();
+                  _val187 = iprot.readDouble();
+                  struct.doubleMap.put(_key186, _val187);
                 }
                 iprot.readMapEnd();
               }
@@ -784,10 +784,10 @@ public class Metric implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Met
         oprot.writeFieldBegin(STR_MAP_FIELD_DESC);
         {
           oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, struct.strMap.size()));
-          for (Map.Entry<String, String> _iter180 : struct.strMap.entrySet())
+          for (Map.Entry<String, String> _iter188 : struct.strMap.entrySet())
           {
-            oprot.writeString(_iter180.getKey());
-            oprot.writeString(_iter180.getValue());
+            oprot.writeString(_iter188.getKey());
+            oprot.writeString(_iter188.getValue());
           }
           oprot.writeMapEnd();
         }
@@ -797,10 +797,10 @@ public class Metric implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Met
         oprot.writeFieldBegin(LONG_MAP_FIELD_DESC);
         {
           oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, struct.longMap.size()));
-          for (Map.Entry<String, Long> _iter181 : struct.longMap.entrySet())
+          for (Map.Entry<String, Long> _iter189 : struct.longMap.entrySet())
           {
-            oprot.writeString(_iter181.getKey());
-            oprot.writeI64(_iter181.getValue());
+            oprot.writeString(_iter189.getKey());
+            oprot.writeI64(_iter189.getValue());
           }
           oprot.writeMapEnd();
         }
@@ -810,10 +810,10 @@ public class Metric implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Met
         oprot.writeFieldBegin(DOUBLE_MAP_FIELD_DESC);
         {
           oprot.writeMapBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.DOUBLE, struct.doubleMap.size()));
-          for (Map.Entry<String, Double> _iter182 : struct.doubleMap.entrySet())
+          for (Map.Entry<String, Double> _iter190 : struct.doubleMap.entrySet())
           {
-            oprot.writeString(_iter182.getKey());
-            oprot.writeDouble(_iter182.getValue());
+            oprot.writeString(_iter190.getKey());
+            oprot.writeDouble(_iter190.getValue());
           }
           oprot.writeMapEnd();
         }
@@ -856,30 +856,30 @@ public class Metric implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Met
       if (struct.isSetStrMap()) {
         {
           oprot.writeI32(struct.strMap.size());
-          for (Map.Entry<String, String> _iter183 : struct.strMap.entrySet())
+          for (Map.Entry<String, String> _iter191 : struct.strMap.entrySet())
           {
-            oprot.writeString(_iter183.getKey());
-            oprot.writeString(_iter183.getValue());
+            oprot.writeString(_iter191.getKey());
+            oprot.writeString(_iter191.getValue());
           }
         }
       }
       if (struct.isSetLongMap()) {
         {
           oprot.writeI32(struct.longMap.size());
-          for (Map.Entry<String, Long> _iter184 : struct.longMap.entrySet())
+          for (Map.Entry<String, Long> _iter192 : struct.longMap.entrySet())
           {
-            oprot.writeString(_iter184.getKey());
-            oprot.writeI64(_iter184.getValue());
+            oprot.writeString(_iter192.getKey());
+            oprot.writeI64(_iter192.getValue());
           }
         }
       }
       if (struct.isSetDoubleMap()) {
         {
           oprot.writeI32(struct.doubleMap.size());
-          for (Map.Entry<String, Double> _iter185 : struct.doubleMap.entrySet())
+          for (Map.Entry<String, Double> _iter193 : struct.doubleMap.entrySet())
           {
-            oprot.writeString(_iter185.getKey());
-            oprot.writeDouble(_iter185.getValue());
+            oprot.writeString(_iter193.getKey());
+            oprot.writeDouble(_iter193.getValue());
           }
         }
       }
@@ -895,45 +895,45 @@ public class Metric implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Met
       }
       if (incoming.get(1)) {
         {
-          org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map186 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32());
-          struct.strMap = new HashMap<String,String>(2*_map186.size);
-          for (int _i187 = 0; _i187 < _map186.size; ++_i187)
+          org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map194 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, iprot.readI32());
+          struct.strMap = new HashMap<String,String>(2*_map194.size);
+          for (int _i195 = 0; _i195 < _map194.size; ++_i195)
           {
-            String _key188; // optional
-            String _val189; // required
-            _key188 = iprot.readString();
-            _val189 = iprot.readString();
-            struct.strMap.put(_key188, _val189);
+            String _key196; // optional
+            String _val197; // required
+            _key196 = iprot.readString();
+            _val197 = iprot.readString();
+            struct.strMap.put(_key196, _val197);
           }
         }
         struct.setStrMapIsSet(true);
       }
       if (incoming.get(2)) {
         {
-          org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map190 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, iprot.readI32());
-          struct.longMap = new HashMap<String,Long>(2*_map190.size);
-          for (int _i191 = 0; _i191 < _map190.size; ++_i191)
+          org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map198 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I64, iprot.readI32());
+          struct.longMap = new HashMap<String,Long>(2*_map198.size);
+          for (int _i199 = 0; _i199 < _map198.size; ++_i199)
           {
-            String _key192; // optional
-            long _val193; // required
-            _key192 = iprot.readString();
-            _val193 = iprot.readI64();
-            struct.longMap.put(_key192, _val193);
+            String _key200; // optional
+            long _val201; // required
+            _key200 = iprot.readString();
+            _val201 = iprot.readI64();
+            struct.longMap.put(_key200, _val201);
           }
         }
         struct.setLongMapIsSet(true);
       }
       if (incoming.get(3)) {
         {
-          org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map194 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.DOUBLE, iprot.readI32());
-          struct.doubleMap = new HashMap<String,Double>(2*_map194.size);
-          for (int _i195 = 0; _i195 < _map194.size; ++_i195)
+          org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap _map202 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TMap(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.DOUBLE, iprot.readI32());
+          struct.doubleMap = new HashMap<String,Double>(2*_map202.size);
+          for (int _i203 = 0; _i203 < _map202.size; ++_i203)
           {
-            String _key196; // optional
-            double _val197; // required
-            _key196 = iprot.readString();
-            _val197 = iprot.readDouble();
-            struct.doubleMap.put(_key196, _val197);
+            String _key204; // optional
+            double _val205; // required
+            _key204 = iprot.readString();
+            _val205 = iprot.readDouble();
+            struct.doubleMap.put(_key204, _val205);
           }
         }
         struct.setDoubleMapIsSet(true);

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/da6c233c/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Row.java
----------------------------------------------------------------------
diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Row.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Row.java
index c983db5..413d57e 100644
--- a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Row.java
+++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Row.java
@@ -57,7 +57,6 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
 
   private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField ID_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("id", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)1);
   private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField RECORDS_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("records", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, (short)2);
-  private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField RECORD_COUNT_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("recordCount", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32, (short)3);
 
   private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
   static {
@@ -74,11 +73,6 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
    * reflect the paged records from the selector.
    */
   public List<Record> records; // required
-  /**
-   * The total record count for the row.  If paging is used in a selector to page
-   * through records of a row, this count will reflect the entire row.
-   */
-  public int recordCount; // required
 
   /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
   public enum _Fields implements org.apache.blur.thirdparty.thrift_0_9_0.TFieldIdEnum {
@@ -90,12 +84,7 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
      * The list records within the row.  If paging is used this list will only
      * reflect the paged records from the selector.
      */
-    RECORDS((short)2, "records"),
-    /**
-     * The total record count for the row.  If paging is used in a selector to page
-     * through records of a row, this count will reflect the entire row.
-     */
-    RECORD_COUNT((short)3, "recordCount");
+    RECORDS((short)2, "records");
 
     private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -114,8 +103,6 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
           return ID;
         case 2: // RECORDS
           return RECORDS;
-        case 3: // RECORD_COUNT
-          return RECORD_COUNT;
         default:
           return null;
       }
@@ -156,8 +143,6 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
   }
 
   // isset id assignments
-  private static final int __RECORDCOUNT_ISSET_ID = 0;
-  private byte __isset_bitfield = 0;
   public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> metaDataMap;
   static {
     Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>(_Fields.class);
@@ -166,8 +151,6 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
     tmpMap.put(_Fields.RECORDS, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("records", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
         new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.ListMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, 
             new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.StructMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, Record.class))));
-    tmpMap.put(_Fields.RECORD_COUNT, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("recordCount", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
-        new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32)));
     metaDataMap = Collections.unmodifiableMap(tmpMap);
     org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(Row.class, metaDataMap);
   }
@@ -177,21 +160,17 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
 
   public Row(
     String id,
-    List<Record> records,
-    int recordCount)
+    List<Record> records)
   {
     this();
     this.id = id;
     this.records = records;
-    this.recordCount = recordCount;
-    setRecordCountIsSet(true);
   }
 
   /**
    * Performs a deep copy on <i>other</i>.
    */
   public Row(Row other) {
-    __isset_bitfield = other.__isset_bitfield;
     if (other.isSetId()) {
       this.id = other.id;
     }
@@ -202,7 +181,6 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
       }
       this.records = __this__records;
     }
-    this.recordCount = other.recordCount;
   }
 
   public Row deepCopy() {
@@ -213,8 +191,6 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
   public void clear() {
     this.id = null;
     this.records = null;
-    setRecordCountIsSet(false);
-    this.recordCount = 0;
   }
 
   /**
@@ -294,37 +270,6 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
     }
   }
 
-  /**
-   * The total record count for the row.  If paging is used in a selector to page
-   * through records of a row, this count will reflect the entire row.
-   */
-  public int getRecordCount() {
-    return this.recordCount;
-  }
-
-  /**
-   * The total record count for the row.  If paging is used in a selector to page
-   * through records of a row, this count will reflect the entire row.
-   */
-  public Row setRecordCount(int recordCount) {
-    this.recordCount = recordCount;
-    setRecordCountIsSet(true);
-    return this;
-  }
-
-  public void unsetRecordCount() {
-    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __RECORDCOUNT_ISSET_ID);
-  }
-
-  /** Returns true if field recordCount is set (has been assigned a value) and false otherwise */
-  public boolean isSetRecordCount() {
-    return EncodingUtils.testBit(__isset_bitfield, __RECORDCOUNT_ISSET_ID);
-  }
-
-  public void setRecordCountIsSet(boolean value) {
-    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __RECORDCOUNT_ISSET_ID, value);
-  }
-
   public void setFieldValue(_Fields field, Object value) {
     switch (field) {
     case ID:
@@ -343,14 +288,6 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
       }
       break;
 
-    case RECORD_COUNT:
-      if (value == null) {
-        unsetRecordCount();
-      } else {
-        setRecordCount((Integer)value);
-      }
-      break;
-
     }
   }
 
@@ -362,9 +299,6 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
     case RECORDS:
       return getRecords();
 
-    case RECORD_COUNT:
-      return Integer.valueOf(getRecordCount());
-
     }
     throw new IllegalStateException();
   }
@@ -380,8 +314,6 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
       return isSetId();
     case RECORDS:
       return isSetRecords();
-    case RECORD_COUNT:
-      return isSetRecordCount();
     }
     throw new IllegalStateException();
   }
@@ -417,15 +349,6 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
         return false;
     }
 
-    boolean this_present_recordCount = true;
-    boolean that_present_recordCount = true;
-    if (this_present_recordCount || that_present_recordCount) {
-      if (!(this_present_recordCount && that_present_recordCount))
-        return false;
-      if (this.recordCount != that.recordCount)
-        return false;
-    }
-
     return true;
   }
 
@@ -462,16 +385,6 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
         return lastComparison;
       }
     }
-    lastComparison = Boolean.valueOf(isSetRecordCount()).compareTo(typedOther.isSetRecordCount());
-    if (lastComparison != 0) {
-      return lastComparison;
-    }
-    if (isSetRecordCount()) {
-      lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.recordCount, typedOther.recordCount);
-      if (lastComparison != 0) {
-        return lastComparison;
-      }
-    }
     return 0;
   }
 
@@ -507,10 +420,6 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
       sb.append(this.records);
     }
     first = false;
-    if (!first) sb.append(", ");
-    sb.append("recordCount:");
-    sb.append(this.recordCount);
-    first = false;
     sb.append(")");
     return sb.toString();
   }
@@ -530,8 +439,6 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
 
   private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
     try {
-      // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
-      __isset_bitfield = 0;
       read(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(in)));
     } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) {
       throw new java.io.IOException(te);
@@ -583,14 +490,6 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
               org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
             }
             break;
-          case 3: // RECORD_COUNT
-            if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32) {
-              struct.recordCount = iprot.readI32();
-              struct.setRecordCountIsSet(true);
-            } else { 
-              org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
-            }
-            break;
           default:
             org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
         }
@@ -623,9 +522,6 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
         }
         oprot.writeFieldEnd();
       }
-      oprot.writeFieldBegin(RECORD_COUNT_FIELD_DESC);
-      oprot.writeI32(struct.recordCount);
-      oprot.writeFieldEnd();
       oprot.writeFieldStop();
       oprot.writeStructEnd();
     }
@@ -650,10 +546,7 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
       if (struct.isSetRecords()) {
         optionals.set(1);
       }
-      if (struct.isSetRecordCount()) {
-        optionals.set(2);
-      }
-      oprot.writeBitSet(optionals, 3);
+      oprot.writeBitSet(optionals, 2);
       if (struct.isSetId()) {
         oprot.writeString(struct.id);
       }
@@ -666,15 +559,12 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
           }
         }
       }
-      if (struct.isSetRecordCount()) {
-        oprot.writeI32(struct.recordCount);
-      }
     }
 
     @Override
     public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, Row struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
       TTupleProtocol iprot = (TTupleProtocol) prot;
-      BitSet incoming = iprot.readBitSet(3);
+      BitSet incoming = iprot.readBitSet(2);
       if (incoming.get(0)) {
         struct.id = iprot.readString();
         struct.setIdIsSet(true);
@@ -693,10 +583,6 @@ public class Row implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<Row, R
         }
         struct.setRecordsIsSet(true);
       }
-      if (incoming.get(2)) {
-        struct.recordCount = iprot.readI32();
-        struct.setRecordCountIsSet(true);
-      }
     }
   }
 

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/da6c233c/blur-thrift/src/main/java/org/apache/blur/thrift/generated/RowMutation.java
----------------------------------------------------------------------
diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/RowMutation.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/RowMutation.java
index 9ed33cd..4371cba 100644
--- a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/RowMutation.java
+++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/RowMutation.java
@@ -57,10 +57,8 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
 
   private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField TABLE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("table", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)1);
   private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField ROW_ID_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("rowId", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING, (short)2);
-  private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField WAL_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("wal", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.BOOL, (short)3);
   private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField ROW_MUTATION_TYPE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("rowMutationType", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32, (short)4);
   private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField RECORD_MUTATIONS_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("recordMutations", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, (short)5);
-  private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField WAIT_TO_BE_VISIBLE_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("waitToBeVisible", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.BOOL, (short)6);
 
   private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
   static {
@@ -77,10 +75,6 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
    */
   public String rowId; // required
   /**
-   * 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.
-   */
-  public boolean wal; // required
-  /**
    * The RowMutationType to define how to mutate the given Row.
    * 
    * @see RowMutationType
@@ -90,10 +84,6 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
    * The RecordMutations if any for this Row.
    */
   public List<RecordMutation> recordMutations; // required
-  /**
-   * On mutate waits for the mutation to be visible to queries and fetch requests.
-   */
-  public boolean waitToBeVisible; // required
 
   /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
   public enum _Fields implements org.apache.blur.thirdparty.thrift_0_9_0.TFieldIdEnum {
@@ -106,10 +96,6 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
      */
     ROW_ID((short)2, "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.
-     */
-    WAL((short)3, "wal"),
-    /**
      * The RowMutationType to define how to mutate the given Row.
      * 
      * @see RowMutationType
@@ -118,11 +104,7 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
     /**
      * The RecordMutations if any for this Row.
      */
-    RECORD_MUTATIONS((short)5, "recordMutations"),
-    /**
-     * On mutate waits for the mutation to be visible to queries and fetch requests.
-     */
-    WAIT_TO_BE_VISIBLE((short)6, "waitToBeVisible");
+    RECORD_MUTATIONS((short)5, "recordMutations");
 
     private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -141,14 +123,10 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
           return TABLE;
         case 2: // ROW_ID
           return ROW_ID;
-        case 3: // WAL
-          return WAL;
         case 4: // ROW_MUTATION_TYPE
           return ROW_MUTATION_TYPE;
         case 5: // RECORD_MUTATIONS
           return RECORD_MUTATIONS;
-        case 6: // WAIT_TO_BE_VISIBLE
-          return WAIT_TO_BE_VISIBLE;
         default:
           return null;
       }
@@ -189,9 +167,6 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
   }
 
   // isset id assignments
-  private static final int __WAL_ISSET_ID = 0;
-  private static final int __WAITTOBEVISIBLE_ISSET_ID = 1;
-  private byte __isset_bitfield = 0;
   public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> metaDataMap;
   static {
     Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>(_Fields.class);
@@ -199,59 +174,43 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
         new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING)));
     tmpMap.put(_Fields.ROW_ID, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("rowId", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
         new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRING)));
-    tmpMap.put(_Fields.WAL, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("wal", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
-        new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.BOOL)));
     tmpMap.put(_Fields.ROW_MUTATION_TYPE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("rowMutationType", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
         new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.EnumMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.ENUM, RowMutationType.class)));
     tmpMap.put(_Fields.RECORD_MUTATIONS, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("recordMutations", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
         new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.ListMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST, 
             new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.StructMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, RecordMutation.class))));
-    tmpMap.put(_Fields.WAIT_TO_BE_VISIBLE, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("waitToBeVisible", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
-        new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldValueMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.BOOL)));
     metaDataMap = Collections.unmodifiableMap(tmpMap);
     org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(RowMutation.class, metaDataMap);
   }
 
   public RowMutation() {
-    this.wal = true;
-
     this.rowMutationType = org.apache.blur.thrift.generated.RowMutationType.REPLACE_ROW;
 
-    this.waitToBeVisible = false;
-
   }
 
   public RowMutation(
     String table,
     String rowId,
-    boolean wal,
     RowMutationType rowMutationType,
-    List<RecordMutation> recordMutations,
-    boolean waitToBeVisible)
+    List<RecordMutation> recordMutations)
   {
     this();
     this.table = table;
     this.rowId = rowId;
-    this.wal = wal;
-    setWalIsSet(true);
     this.rowMutationType = rowMutationType;
     this.recordMutations = recordMutations;
-    this.waitToBeVisible = waitToBeVisible;
-    setWaitToBeVisibleIsSet(true);
   }
 
   /**
    * Performs a deep copy on <i>other</i>.
    */
   public RowMutation(RowMutation other) {
-    __isset_bitfield = other.__isset_bitfield;
     if (other.isSetTable()) {
       this.table = other.table;
     }
     if (other.isSetRowId()) {
       this.rowId = other.rowId;
     }
-    this.wal = other.wal;
     if (other.isSetRowMutationType()) {
       this.rowMutationType = other.rowMutationType;
     }
@@ -262,7 +221,6 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
       }
       this.recordMutations = __this__recordMutations;
     }
-    this.waitToBeVisible = other.waitToBeVisible;
   }
 
   public RowMutation deepCopy() {
@@ -273,13 +231,9 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
   public void clear() {
     this.table = null;
     this.rowId = null;
-    this.wal = true;
-
     this.rowMutationType = org.apache.blur.thrift.generated.RowMutationType.REPLACE_ROW;
 
     this.recordMutations = null;
-    this.waitToBeVisible = false;
-
   }
 
   /**
@@ -343,35 +297,6 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
   }
 
   /**
-   * 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.
-   */
-  public boolean isWal() {
-    return this.wal;
-  }
-
-  /**
-   * 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.
-   */
-  public RowMutation setWal(boolean wal) {
-    this.wal = wal;
-    setWalIsSet(true);
-    return this;
-  }
-
-  public void unsetWal() {
-    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __WAL_ISSET_ID);
-  }
-
-  /** Returns true if field wal is set (has been assigned a value) and false otherwise */
-  public boolean isSetWal() {
-    return EncodingUtils.testBit(__isset_bitfield, __WAL_ISSET_ID);
-  }
-
-  public void setWalIsSet(boolean value) {
-    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __WAL_ISSET_ID, value);
-  }
-
-  /**
    * The RowMutationType to define how to mutate the given Row.
    * 
    * @see RowMutationType
@@ -450,35 +375,6 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
     }
   }
 
-  /**
-   * On mutate waits for the mutation to be visible to queries and fetch requests.
-   */
-  public boolean isWaitToBeVisible() {
-    return this.waitToBeVisible;
-  }
-
-  /**
-   * On mutate waits for the mutation to be visible to queries and fetch requests.
-   */
-  public RowMutation setWaitToBeVisible(boolean waitToBeVisible) {
-    this.waitToBeVisible = waitToBeVisible;
-    setWaitToBeVisibleIsSet(true);
-    return this;
-  }
-
-  public void unsetWaitToBeVisible() {
-    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __WAITTOBEVISIBLE_ISSET_ID);
-  }
-
-  /** Returns true if field waitToBeVisible is set (has been assigned a value) and false otherwise */
-  public boolean isSetWaitToBeVisible() {
-    return EncodingUtils.testBit(__isset_bitfield, __WAITTOBEVISIBLE_ISSET_ID);
-  }
-
-  public void setWaitToBeVisibleIsSet(boolean value) {
-    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __WAITTOBEVISIBLE_ISSET_ID, value);
-  }
-
   public void setFieldValue(_Fields field, Object value) {
     switch (field) {
     case TABLE:
@@ -497,14 +393,6 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
       }
       break;
 
-    case WAL:
-      if (value == null) {
-        unsetWal();
-      } else {
-        setWal((Boolean)value);
-      }
-      break;
-
     case ROW_MUTATION_TYPE:
       if (value == null) {
         unsetRowMutationType();
@@ -521,14 +409,6 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
       }
       break;
 
-    case WAIT_TO_BE_VISIBLE:
-      if (value == null) {
-        unsetWaitToBeVisible();
-      } else {
-        setWaitToBeVisible((Boolean)value);
-      }
-      break;
-
     }
   }
 
@@ -540,18 +420,12 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
     case ROW_ID:
       return getRowId();
 
-    case WAL:
-      return Boolean.valueOf(isWal());
-
     case ROW_MUTATION_TYPE:
       return getRowMutationType();
 
     case RECORD_MUTATIONS:
       return getRecordMutations();
 
-    case WAIT_TO_BE_VISIBLE:
-      return Boolean.valueOf(isWaitToBeVisible());
-
     }
     throw new IllegalStateException();
   }
@@ -567,14 +441,10 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
       return isSetTable();
     case ROW_ID:
       return isSetRowId();
-    case WAL:
-      return isSetWal();
     case ROW_MUTATION_TYPE:
       return isSetRowMutationType();
     case RECORD_MUTATIONS:
       return isSetRecordMutations();
-    case WAIT_TO_BE_VISIBLE:
-      return isSetWaitToBeVisible();
     }
     throw new IllegalStateException();
   }
@@ -610,15 +480,6 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
         return false;
     }
 
-    boolean this_present_wal = true;
-    boolean that_present_wal = true;
-    if (this_present_wal || that_present_wal) {
-      if (!(this_present_wal && that_present_wal))
-        return false;
-      if (this.wal != that.wal)
-        return false;
-    }
-
     boolean this_present_rowMutationType = true && this.isSetRowMutationType();
     boolean that_present_rowMutationType = true && that.isSetRowMutationType();
     if (this_present_rowMutationType || that_present_rowMutationType) {
@@ -637,15 +498,6 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
         return false;
     }
 
-    boolean this_present_waitToBeVisible = true;
-    boolean that_present_waitToBeVisible = true;
-    if (this_present_waitToBeVisible || that_present_waitToBeVisible) {
-      if (!(this_present_waitToBeVisible && that_present_waitToBeVisible))
-        return false;
-      if (this.waitToBeVisible != that.waitToBeVisible)
-        return false;
-    }
-
     return true;
   }
 
@@ -682,16 +534,6 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
         return lastComparison;
       }
     }
-    lastComparison = Boolean.valueOf(isSetWal()).compareTo(typedOther.isSetWal());
-    if (lastComparison != 0) {
-      return lastComparison;
-    }
-    if (isSetWal()) {
-      lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.wal, typedOther.wal);
-      if (lastComparison != 0) {
-        return lastComparison;
-      }
-    }
     lastComparison = Boolean.valueOf(isSetRowMutationType()).compareTo(typedOther.isSetRowMutationType());
     if (lastComparison != 0) {
       return lastComparison;
@@ -712,16 +554,6 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
         return lastComparison;
       }
     }
-    lastComparison = Boolean.valueOf(isSetWaitToBeVisible()).compareTo(typedOther.isSetWaitToBeVisible());
-    if (lastComparison != 0) {
-      return lastComparison;
-    }
-    if (isSetWaitToBeVisible()) {
-      lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.waitToBeVisible, typedOther.waitToBeVisible);
-      if (lastComparison != 0) {
-        return lastComparison;
-      }
-    }
     return 0;
   }
 
@@ -758,10 +590,6 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
     }
     first = false;
     if (!first) sb.append(", ");
-    sb.append("wal:");
-    sb.append(this.wal);
-    first = false;
-    if (!first) sb.append(", ");
     sb.append("rowMutationType:");
     if (this.rowMutationType == null) {
       sb.append("null");
@@ -777,10 +605,6 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
       sb.append(this.recordMutations);
     }
     first = false;
-    if (!first) sb.append(", ");
-    sb.append("waitToBeVisible:");
-    sb.append(this.waitToBeVisible);
-    first = false;
     sb.append(")");
     return sb.toString();
   }
@@ -800,8 +624,6 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
 
   private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
     try {
-      // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
-      __isset_bitfield = 0;
       read(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TCompactProtocol(new org.apache.blur.thirdparty.thrift_0_9_0.transport.TIOStreamTransport(in)));
     } catch (org.apache.blur.thirdparty.thrift_0_9_0.TException te) {
       throw new java.io.IOException(te);
@@ -842,14 +664,6 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
               org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
             }
             break;
-          case 3: // WAL
-            if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.BOOL) {
-              struct.wal = iprot.readBool();
-              struct.setWalIsSet(true);
-            } else { 
-              org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
-            }
-            break;
           case 4: // ROW_MUTATION_TYPE
             if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32) {
               struct.rowMutationType = RowMutationType.findByValue(iprot.readI32());
@@ -861,14 +675,14 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
           case 5: // RECORD_MUTATIONS
             if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.LIST) {
               {
-                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list84 = iprot.readListBegin();
-                struct.recordMutations = new ArrayList<RecordMutation>(_list84.size);
-                for (int _i85 = 0; _i85 < _list84.size; ++_i85)
+                org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list92 = iprot.readListBegin();
+                struct.recordMutations = new ArrayList<RecordMutation>(_list92.size);
+                for (int _i93 = 0; _i93 < _list92.size; ++_i93)
                 {
-                  RecordMutation _elem86; // required
-                  _elem86 = new RecordMutation();
-                  _elem86.read(iprot);
-                  struct.recordMutations.add(_elem86);
+                  RecordMutation _elem94; // required
+                  _elem94 = new RecordMutation();
+                  _elem94.read(iprot);
+                  struct.recordMutations.add(_elem94);
                 }
                 iprot.readListEnd();
               }
@@ -877,14 +691,6 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
               org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
             }
             break;
-          case 6: // WAIT_TO_BE_VISIBLE
-            if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.BOOL) {
-              struct.waitToBeVisible = iprot.readBool();
-              struct.setWaitToBeVisibleIsSet(true);
-            } else { 
-              org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
-            }
-            break;
           default:
             org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
         }
@@ -910,9 +716,6 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
         oprot.writeString(struct.rowId);
         oprot.writeFieldEnd();
       }
-      oprot.writeFieldBegin(WAL_FIELD_DESC);
-      oprot.writeBool(struct.wal);
-      oprot.writeFieldEnd();
       if (struct.rowMutationType != null) {
         oprot.writeFieldBegin(ROW_MUTATION_TYPE_FIELD_DESC);
         oprot.writeI32(struct.rowMutationType.getValue());
@@ -922,17 +725,14 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
         oprot.writeFieldBegin(RECORD_MUTATIONS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, struct.recordMutations.size()));
-          for (RecordMutation _iter87 : struct.recordMutations)
+          for (RecordMutation _iter95 : struct.recordMutations)
           {
-            _iter87.write(oprot);
+            _iter95.write(oprot);
           }
           oprot.writeListEnd();
         }
         oprot.writeFieldEnd();
       }
-      oprot.writeFieldBegin(WAIT_TO_BE_VISIBLE_FIELD_DESC);
-      oprot.writeBool(struct.waitToBeVisible);
-      oprot.writeFieldEnd();
       oprot.writeFieldStop();
       oprot.writeStructEnd();
     }
@@ -957,49 +757,37 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
       if (struct.isSetRowId()) {
         optionals.set(1);
       }
-      if (struct.isSetWal()) {
-        optionals.set(2);
-      }
       if (struct.isSetRowMutationType()) {
-        optionals.set(3);
+        optionals.set(2);
       }
       if (struct.isSetRecordMutations()) {
-        optionals.set(4);
-      }
-      if (struct.isSetWaitToBeVisible()) {
-        optionals.set(5);
+        optionals.set(3);
       }
-      oprot.writeBitSet(optionals, 6);
+      oprot.writeBitSet(optionals, 4);
       if (struct.isSetTable()) {
         oprot.writeString(struct.table);
       }
       if (struct.isSetRowId()) {
         oprot.writeString(struct.rowId);
       }
-      if (struct.isSetWal()) {
-        oprot.writeBool(struct.wal);
-      }
       if (struct.isSetRowMutationType()) {
         oprot.writeI32(struct.rowMutationType.getValue());
       }
       if (struct.isSetRecordMutations()) {
         {
           oprot.writeI32(struct.recordMutations.size());
-          for (RecordMutation _iter88 : struct.recordMutations)
+          for (RecordMutation _iter96 : struct.recordMutations)
           {
-            _iter88.write(oprot);
+            _iter96.write(oprot);
           }
         }
       }
-      if (struct.isSetWaitToBeVisible()) {
-        oprot.writeBool(struct.waitToBeVisible);
-      }
     }
 
     @Override
     public void read(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot, RowMutation struct) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
       TTupleProtocol iprot = (TTupleProtocol) prot;
-      BitSet incoming = iprot.readBitSet(6);
+      BitSet incoming = iprot.readBitSet(4);
       if (incoming.get(0)) {
         struct.table = iprot.readString();
         struct.setTableIsSet(true);
@@ -1009,31 +797,23 @@ public class RowMutation implements org.apache.blur.thirdparty.thrift_0_9_0.TBas
         struct.setRowIdIsSet(true);
       }
       if (incoming.get(2)) {
-        struct.wal = iprot.readBool();
-        struct.setWalIsSet(true);
-      }
-      if (incoming.get(3)) {
         struct.rowMutationType = RowMutationType.findByValue(iprot.readI32());
         struct.setRowMutationTypeIsSet(true);
       }
-      if (incoming.get(4)) {
+      if (incoming.get(3)) {
         {
-          org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list89 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, iprot.readI32());
-          struct.recordMutations = new ArrayList<RecordMutation>(_list89.size);
-          for (int _i90 = 0; _i90 < _list89.size; ++_i90)
+          org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList _list97 = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TList(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, iprot.readI32());
+          struct.recordMutations = new ArrayList<RecordMutation>(_list97.size);
+          for (int _i98 = 0; _i98 < _list97.size; ++_i98)
           {
-            RecordMutation _elem91; // required
-            _elem91 = new RecordMutation();
-            _elem91.read(iprot);
-            struct.recordMutations.add(_elem91);
+            RecordMutation _elem99; // required
+            _elem99 = new RecordMutation();
+            _elem99.read(iprot);
+            struct.recordMutations.add(_elem99);
           }
         }
         struct.setRecordMutationsIsSet(true);
       }
-      if (incoming.get(5)) {
-        struct.waitToBeVisible = iprot.readBool();
-        struct.setWaitToBeVisibleIsSet(true);
-      }
     }
   }
 


Mime
View raw message