incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [09/28] Adding fields in Thrift to allow for easier paging through Rows on fetch.
Date Wed, 15 Jan 2014 22:03:32 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/b220118d/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java
----------------------------------------------------------------------
diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java
index 5392531..eb8a126 100644
--- a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java
+++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java
@@ -62,828 +62,828 @@ super(prot);
 }
 
 @Override
-public void optimize(java.lang.String arg0, int arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public boolean addColumnDefinition(java.lang.String arg0, org.apache.blur.thrift.generated.ColumnDefinition arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.optimize(arg0, arg1);
+    return super.addColumnDefinition(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public org.apache.blur.thrift.generated.BlurResults query(java.lang.String arg0, org.apache.blur.thrift.generated.BlurQuery arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void cancelQuery(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.query(arg0, arg1);
+    super.cancelQuery(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void createTable(org.apache.blur.thrift.generated.TableDescriptor arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.Map configuration() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.createTable(arg0);
+    return super.configuration();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_createTable(org.apache.blur.thrift.generated.TableDescriptor arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List controllerServerList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_createTable(arg0);
+    return super.controllerServerList();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void recv_createTable() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void createSnapshot(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.recv_createTable();
+    super.createSnapshot(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void enableTable(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void createTable(org.apache.blur.thrift.generated.TableDescriptor arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.enableTable(arg0);
+    super.createTable(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_enableTable(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public org.apache.blur.thrift.generated.TableDescriptor describe(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_enableTable(arg0);
+    return super.describe(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void recv_enableTable() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void disableTable(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.recv_enableTable();
+    super.disableTable(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void disableTable(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void enableTable(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.disableTable(arg0);
+    super.enableTable(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_disableTable(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public org.apache.blur.thrift.generated.FetchResult fetchRow(java.lang.String arg0, org.apache.blur.thrift.generated.Selector arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_disableTable(arg0);
+    return super.fetchRow(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void recv_disableTable() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List fetchRowBatch(java.lang.String arg0, java.util.List arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.recv_disableTable();
+    return super.fetchRowBatch(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void removeTable(java.lang.String arg0, boolean arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public boolean isInSafeMode(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.removeTable(arg0, arg1);
+    return super.isInSafeMode(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_removeTable(java.lang.String arg0, boolean arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.Map listSnapshots(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_removeTable(arg0, arg1);
+    return super.listSnapshots(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void recv_removeTable() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.Map metrics(java.util.Set arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.recv_removeTable();
+    return super.metrics(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public boolean addColumnDefinition(java.lang.String arg0, org.apache.blur.thrift.generated.ColumnDefinition arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void mutate(org.apache.blur.thrift.generated.RowMutation arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.addColumnDefinition(arg0, arg1);
+    super.mutate(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_addColumnDefinition(java.lang.String arg0, org.apache.blur.thrift.generated.ColumnDefinition arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void mutateBatch(java.util.List arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_addColumnDefinition(arg0, arg1);
+    super.mutateBatch(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public boolean recv_addColumnDefinition() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void optimize(java.lang.String arg0, int arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_addColumnDefinition();
+    super.optimize(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List tableList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.lang.String parseQuery(java.lang.String arg0, org.apache.blur.thrift.generated.Query arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.tableList();
+    return super.parseQuery(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_tableList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void ping() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_tableList();
+    super.ping();
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List recv_tableList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public org.apache.blur.thrift.generated.BlurResults query(java.lang.String arg0, org.apache.blur.thrift.generated.BlurQuery arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_tableList();
+    return super.query(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List tableListByCluster(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public org.apache.blur.thrift.generated.BlurQueryStatus queryStatusById(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.tableListByCluster(arg0);
+    return super.queryStatusById(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_tableListByCluster(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List queryStatusIdList(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_tableListByCluster(arg0);
+    return super.queryStatusIdList(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List recv_tableListByCluster() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public long recordFrequency(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_tableListByCluster();
+    return super.recordFrequency(arg0, arg1, arg2, arg3);
   } finally {_lock.unlock();}
 }
 
 @Override
-public org.apache.blur.thrift.generated.TableDescriptor describe(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public boolean recv_addColumnDefinition() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.describe(arg0);
+    return super.recv_addColumnDefinition();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_describe(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void recv_cancelQuery() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_describe(arg0);
+    super.recv_cancelQuery();
   } finally {_lock.unlock();}
 }
 
 @Override
-public org.apache.blur.thrift.generated.TableDescriptor recv_describe() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.Map recv_configuration() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_describe();
+    return super.recv_configuration();
   } finally {_lock.unlock();}
 }
 
 @Override
-public org.apache.blur.thrift.generated.Schema schema(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List recv_controllerServerList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.schema(arg0);
+    return super.recv_controllerServerList();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_schema(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void recv_createSnapshot() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_schema(arg0);
+    super.recv_createSnapshot();
   } finally {_lock.unlock();}
 }
 
 @Override
-public org.apache.blur.thrift.generated.Schema recv_schema() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void recv_createTable() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_schema();
+    super.recv_createTable();
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.lang.String parseQuery(java.lang.String arg0, org.apache.blur.thrift.generated.Query arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public org.apache.blur.thrift.generated.TableDescriptor recv_describe() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.parseQuery(arg0, arg1);
+    return super.recv_describe();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_parseQuery(java.lang.String arg0, org.apache.blur.thrift.generated.Query arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void recv_disableTable() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_parseQuery(arg0, arg1);
+    super.recv_disableTable();
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.lang.String recv_parseQuery() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void recv_enableTable() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_parseQuery();
+    super.recv_enableTable();
   } finally {_lock.unlock();}
 }
 
 @Override
-public org.apache.blur.thrift.generated.TableStats tableStats(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public org.apache.blur.thrift.generated.FetchResult recv_fetchRow() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.tableStats(arg0);
+    return super.recv_fetchRow();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_tableStats(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List recv_fetchRowBatch() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_tableStats(arg0);
+    return super.recv_fetchRowBatch();
   } finally {_lock.unlock();}
 }
 
 @Override
-public org.apache.blur.thrift.generated.TableStats recv_tableStats() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public boolean recv_isInSafeMode() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_tableStats();
+    return super.recv_isInSafeMode();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_optimize(java.lang.String arg0, int arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.Map recv_listSnapshots() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_optimize(arg0, arg1);
+    return super.recv_listSnapshots();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void recv_optimize() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.Map recv_metrics() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.recv_optimize();
+    return super.recv_metrics();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void createSnapshot(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void recv_mutate() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.createSnapshot(arg0, arg1);
+    super.recv_mutate();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_createSnapshot(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void recv_mutateBatch() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_createSnapshot(arg0, arg1);
+    super.recv_mutateBatch();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void recv_createSnapshot() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void recv_optimize() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.recv_createSnapshot();
+    super.recv_optimize();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void removeSnapshot(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.lang.String recv_parseQuery() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.removeSnapshot(arg0, arg1);
+    return super.recv_parseQuery();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_removeSnapshot(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void recv_ping() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_removeSnapshot(arg0, arg1);
+    super.recv_ping();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void recv_removeSnapshot() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public org.apache.blur.thrift.generated.BlurResults recv_query() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.recv_removeSnapshot();
+    return super.recv_query();
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.Map listSnapshots(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public org.apache.blur.thrift.generated.BlurQueryStatus recv_queryStatusById() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.listSnapshots(arg0);
+    return super.recv_queryStatusById();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_listSnapshots(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List recv_queryStatusIdList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_listSnapshots(arg0);
+    return super.recv_queryStatusIdList();
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.Map recv_listSnapshots() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public long recv_recordFrequency() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_listSnapshots();
+    return super.recv_recordFrequency();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void setUser(org.apache.blur.thrift.generated.User arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void recv_removeSnapshot() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.setUser(arg0);
+    super.recv_removeSnapshot();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_setUser(org.apache.blur.thrift.generated.User arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void recv_removeTable() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_setUser(arg0);
+    super.recv_removeTable();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_query(java.lang.String arg0, org.apache.blur.thrift.generated.BlurQuery arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public org.apache.blur.thrift.generated.Schema recv_schema() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_query(arg0, arg1);
+    return super.recv_schema();
   } finally {_lock.unlock();}
 }
 
 @Override
-public org.apache.blur.thrift.generated.BlurResults recv_query() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List recv_shardClusterList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_query();
+    return super.recv_shardClusterList();
   } finally {_lock.unlock();}
 }
 
 @Override
-public org.apache.blur.thrift.generated.FetchResult fetchRow(java.lang.String arg0, org.apache.blur.thrift.generated.Selector arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.Map recv_shardServerLayout() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.fetchRow(arg0, arg1);
+    return super.recv_shardServerLayout();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_fetchRow(java.lang.String arg0, org.apache.blur.thrift.generated.Selector arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.Map recv_shardServerLayoutState() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_fetchRow(arg0, arg1);
+    return super.recv_shardServerLayoutState();
   } finally {_lock.unlock();}
 }
 
 @Override
-public org.apache.blur.thrift.generated.FetchResult recv_fetchRow() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List recv_shardServerList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_fetchRow();
+    return super.recv_shardServerList();
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List fetchRowBatch(java.lang.String arg0, java.util.List arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List recv_tableList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.fetchRowBatch(arg0, arg1);
+    return super.recv_tableList();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_fetchRowBatch(java.lang.String arg0, java.util.List arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List recv_tableListByCluster() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_fetchRowBatch(arg0, arg1);
+    return super.recv_tableListByCluster();
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List recv_fetchRowBatch() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public org.apache.blur.thrift.generated.TableStats recv_tableStats() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_fetchRowBatch();
+    return super.recv_tableStats();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void mutate(org.apache.blur.thrift.generated.RowMutation arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List recv_terms() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.mutate(arg0);
+    return super.recv_terms();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_mutate(org.apache.blur.thrift.generated.RowMutation arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List recv_traceList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_mutate(arg0);
+    return super.recv_traceList();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void recv_mutate() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void recv_traceRemove() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.recv_mutate();
+    super.recv_traceRemove();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void mutateBatch(java.util.List arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.lang.String recv_traceRequestFetch() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.mutateBatch(arg0);
+    return super.recv_traceRequestFetch();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_mutateBatch(java.util.List arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List recv_traceRequestList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_mutateBatch(arg0);
+    return super.recv_traceRequestList();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void recv_mutateBatch() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void removeSnapshot(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.recv_mutateBatch();
+    super.removeSnapshot(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void cancelQuery(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void removeTable(java.lang.String arg0, boolean arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.cancelQuery(arg0, arg1);
+    super.removeTable(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_cancelQuery(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public org.apache.blur.thrift.generated.Schema schema(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_cancelQuery(arg0, arg1);
+    return super.schema(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void recv_cancelQuery() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_addColumnDefinition(java.lang.String arg0, org.apache.blur.thrift.generated.ColumnDefinition arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.recv_cancelQuery();
+    super.send_addColumnDefinition(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List queryStatusIdList(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_cancelQuery(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.queryStatusIdList(arg0);
+    super.send_cancelQuery(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_queryStatusIdList(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_configuration() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_queryStatusIdList(arg0);
+    super.send_configuration();
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List recv_queryStatusIdList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_controllerServerList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_queryStatusIdList();
+    super.send_controllerServerList();
   } finally {_lock.unlock();}
 }
 
 @Override
-public org.apache.blur.thrift.generated.BlurQueryStatus queryStatusById(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_createSnapshot(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.queryStatusById(arg0, arg1);
+    super.send_createSnapshot(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_queryStatusById(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_createTable(org.apache.blur.thrift.generated.TableDescriptor arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_queryStatusById(arg0, arg1);
+    super.send_createTable(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public org.apache.blur.thrift.generated.BlurQueryStatus recv_queryStatusById() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_describe(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_queryStatusById();
+    super.send_describe(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List terms(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3, short arg4) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_disableTable(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.terms(arg0, arg1, arg2, arg3, arg4);
+    super.send_disableTable(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_terms(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3, short arg4) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_enableTable(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_terms(arg0, arg1, arg2, arg3, arg4);
+    super.send_enableTable(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List recv_terms() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_fetchRow(java.lang.String arg0, org.apache.blur.thrift.generated.Selector arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_terms();
+    super.send_fetchRow(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public long recordFrequency(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_fetchRowBatch(java.lang.String arg0, java.util.List arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recordFrequency(arg0, arg1, arg2, arg3);
+    super.send_fetchRowBatch(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_recordFrequency(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_isInSafeMode(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_recordFrequency(arg0, arg1, arg2, arg3);
+    super.send_isInSafeMode(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public long recv_recordFrequency() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_listSnapshots(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_recordFrequency();
+    super.send_listSnapshots(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List shardClusterList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_metrics(java.util.Set arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.shardClusterList();
+    super.send_metrics(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_shardClusterList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_mutate(org.apache.blur.thrift.generated.RowMutation arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_shardClusterList();
+    super.send_mutate(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List recv_shardClusterList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_mutateBatch(java.util.List arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_shardClusterList();
+    super.send_mutateBatch(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List shardServerList(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_optimize(java.lang.String arg0, int arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.shardServerList(arg0);
+    super.send_optimize(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_shardServerList(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_parseQuery(java.lang.String arg0, org.apache.blur.thrift.generated.Query arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_shardServerList(arg0);
+    super.send_parseQuery(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List recv_shardServerList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_ping() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_shardServerList();
+    super.send_ping();
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List controllerServerList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_query(java.lang.String arg0, org.apache.blur.thrift.generated.BlurQuery arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.controllerServerList();
+    super.send_query(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_controllerServerList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_queryStatusById(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_controllerServerList();
+    super.send_queryStatusById(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List recv_controllerServerList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_queryStatusIdList(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_controllerServerList();
+    super.send_queryStatusIdList(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.Map shardServerLayout(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_recordFrequency(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.shardServerLayout(arg0);
+    super.send_recordFrequency(arg0, arg1, arg2, arg3);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_shardServerLayout(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_removeSnapshot(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_shardServerLayout(arg0);
+    super.send_removeSnapshot(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.Map recv_shardServerLayout() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_removeTable(java.lang.String arg0, boolean arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_shardServerLayout();
+    super.send_removeTable(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.Map shardServerLayoutState(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_schema(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.shardServerLayoutState(arg0);
+    super.send_schema(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_shardServerLayoutState(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_setUser(org.apache.blur.thrift.generated.User arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_shardServerLayoutState(arg0);
+    super.send_setUser(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.Map recv_shardServerLayoutState() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_shardClusterList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_shardServerLayoutState();
+    super.send_shardClusterList();
   } finally {_lock.unlock();}
 }
 
 @Override
-public boolean isInSafeMode(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_shardServerLayout(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.isInSafeMode(arg0);
+    super.send_shardServerLayout(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_isInSafeMode(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_shardServerLayoutState(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_isInSafeMode(arg0);
+    super.send_shardServerLayoutState(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public boolean recv_isInSafeMode() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_shardServerList(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_isInSafeMode();
+    super.send_shardServerList(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_configuration() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_startTrace(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_configuration();
+    super.send_startTrace(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.Map recv_configuration() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_tableList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_configuration();
+    super.send_tableList();
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.Map metrics(java.util.Set arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_tableListByCluster(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.metrics(arg0);
+    super.send_tableListByCluster(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_metrics(java.util.Set arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_tableStats(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_metrics(arg0);
+    super.send_tableStats(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.Map recv_metrics() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_terms(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3, short arg4) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_metrics();
+    super.send_terms(arg0, arg1, arg2, arg3, arg4);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void startTrace(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_traceList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.startTrace(arg0, arg1);
+    super.send_traceList();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_startTrace(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_traceRemove(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_startTrace(arg0, arg1);
+    super.send_traceRemove(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List traceList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_traceRequestFetch(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.traceList();
+    super.send_traceRequestFetch(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_traceList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void send_traceRequestList(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_traceList();
+    super.send_traceRequestList(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List recv_traceList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void setUser(org.apache.blur.thrift.generated.User arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_traceList();
+    super.setUser(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List traceRequestList(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List shardClusterList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.traceRequestList(arg0);
+    return super.shardClusterList();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_traceRequestList(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.Map shardServerLayout(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_traceRequestList(arg0);
+    return super.shardServerLayout(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.List recv_traceRequestList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.Map shardServerLayoutState(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_traceRequestList();
+    return super.shardServerLayoutState(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.lang.String traceRequestFetch(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List shardServerList(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.traceRequestFetch(arg0, arg1);
+    return super.shardServerList(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_traceRequestFetch(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void startTrace(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_traceRequestFetch(arg0, arg1);
+    super.startTrace(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.lang.String recv_traceRequestFetch() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List tableList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.recv_traceRequestFetch();
+    return super.tableList();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void traceRemove(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List tableListByCluster(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.traceRemove(arg0);
+    return super.tableListByCluster(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_traceRemove(java.lang.String arg0) throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public org.apache.blur.thrift.generated.TableStats tableStats(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_traceRemove(arg0);
+    return super.tableStats(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void recv_traceRemove() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List terms(java.lang.String arg0, java.lang.String arg1, java.lang.String arg2, java.lang.String arg3, short arg4) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.recv_traceRemove();
+    return super.terms(arg0, arg1, arg2, arg3, arg4);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void ping() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List traceList() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.ping();
+    return super.traceList();
   } finally {_lock.unlock();}
 }
 
 @Override
-public void send_ping() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public void traceRemove(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.send_ping();
+    super.traceRemove(arg0);
   } finally {_lock.unlock();}
 }
 
 @Override
-public void recv_ping() throws org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.lang.String traceRequestFetch(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    super.recv_ping();
+    return super.traceRequestFetch(arg0, arg1);
   } finally {_lock.unlock();}
 }
 
 @Override
-public java.util.Map configuration() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
+public java.util.List traceRequestList(java.lang.String arg0) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException {
   _lock.errorFailLock(); try {
-    return super.configuration();
+    return super.traceRequestList(arg0);
   } finally {_lock.unlock();}
 }
 

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/b220118d/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Selector.java
----------------------------------------------------------------------
diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Selector.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Selector.java
index b5d6a04..81f5b69 100644
--- a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Selector.java
+++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Selector.java
@@ -106,7 +106,7 @@ public class Selector implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<S
   /**
    * Only valid for Row fetches, the number of records to fetch.  If the row contains 1000 records
    * and you want the first 100, then this value is 100.  If you want records 300-400 then this value
-   * would be 100.  Used in conjunction with maxRecordsToFetch. By default this will fetch the first
+   * would be 100.  Used in conjunction with startRecord. By default this will fetch the first
    * 1000 records of the row.
    */
   public int maxRecordsToFetch; // required
@@ -152,7 +152,7 @@ public class Selector implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<S
     /**
      * Only valid for Row fetches, the number of records to fetch.  If the row contains 1000 records
      * and you want the first 100, then this value is 100.  If you want records 300-400 then this value
-     * would be 100.  Used in conjunction with maxRecordsToFetch. By default this will fetch the first
+     * would be 100.  Used in conjunction with startRecord. By default this will fetch the first
      * 1000 records of the row.
      */
     MAX_RECORDS_TO_FETCH((short)9, "maxRecordsToFetch"),
@@ -610,7 +610,7 @@ public class Selector implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<S
   /**
    * Only valid for Row fetches, the number of records to fetch.  If the row contains 1000 records
    * and you want the first 100, then this value is 100.  If you want records 300-400 then this value
-   * would be 100.  Used in conjunction with maxRecordsToFetch. By default this will fetch the first
+   * would be 100.  Used in conjunction with startRecord. By default this will fetch the first
    * 1000 records of the row.
    */
   public int getMaxRecordsToFetch() {
@@ -620,7 +620,7 @@ public class Selector implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<S
   /**
    * Only valid for Row fetches, the number of records to fetch.  If the row contains 1000 records
    * and you want the first 100, then this value is 100.  If you want records 300-400 then this value
-   * would be 100.  Used in conjunction with maxRecordsToFetch. By default this will fetch the first
+   * would be 100.  Used in conjunction with startRecord. By default this will fetch the first
    * 1000 records of the row.
    */
   public Selector setMaxRecordsToFetch(int maxRecordsToFetch) {

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/b220118d/blur-thrift/src/main/java/org/apache/blur/thrift/util/GenerateSafeClient.java
----------------------------------------------------------------------
diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/util/GenerateSafeClient.java b/blur-thrift/src/main/java/org/apache/blur/thrift/util/GenerateSafeClient.java
index 5d0c0a2..ef123d4 100644
--- a/blur-thrift/src/main/java/org/apache/blur/thrift/util/GenerateSafeClient.java
+++ b/blur-thrift/src/main/java/org/apache/blur/thrift/util/GenerateSafeClient.java
@@ -23,6 +23,8 @@ import java.io.IOException;
 import java.io.InputStreamReader;
 import java.io.PrintWriter;
 import java.lang.reflect.Method;
+import java.util.Arrays;
+import java.util.Comparator;
 
 import org.apache.blur.thrift.ClientLock;
 import org.apache.blur.thrift.generated.Blur;
@@ -66,6 +68,20 @@ public class GenerateSafeClient {
     writer.println();
 
     Method[] methods = Blur.Client.class.getDeclaredMethods();
+    Arrays.sort(methods, new Comparator<Method>() {
+      @Override
+      public int compare(Method o1, Method o2) {
+        String name1 = o1.getName();
+        String name2 = o2.getName();
+        int compareTo = name1.compareTo(name2);
+        if (compareTo == 0) {
+          String p1 = getArgs(o1.getParameterTypes());
+          String p2 = getArgs(o2.getParameterTypes());
+          return p1.compareTo(p2);
+        }
+        return compareTo;
+      }
+    });
     for (Method method : methods) {
       Class<?>[] exceptionTypes = method.getExceptionTypes();
       Class<?>[] parameterTypes = method.getParameterTypes();

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/b220118d/distribution/src/main/scripts/interface/Blur.thrift
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/Blur.thrift b/distribution/src/main/scripts/interface/Blur.thrift
index 0378788..b56f1a8 100644
--- a/distribution/src/main/scripts/interface/Blur.thrift
+++ b/distribution/src/main/scripts/interface/Blur.thrift
@@ -298,7 +298,7 @@ struct Selector {
   /**
    * Only valid for Row fetches, the number of records to fetch.  If the row contains 1000 records 
    * and you want the first 100, then this value is 100.  If you want records 300-400 then this value 
-   * would be 100.  Used in conjunction with maxRecordsToFetch. By default this will fetch the first 
+   * would be 100.  Used in conjunction with startRecord. By default this will fetch the first 
    * 1000 records of the row.
    */
   9:i32 maxRecordsToFetch = 1000,
@@ -315,7 +315,19 @@ struct FetchRowResult {
   /**
    * The row fetched.
    */
-  1:Row row
+  1:Row row,
+  /**
+   * See Selector startRecord.
+   */
+  2:i32 startRecord = -1,
+  /**
+   * See Selector maxRecordsToFetch.
+   */
+  3:i32 maxRecordsToFetch = -1,
+  /**
+   * Are there more Records to fetch based on the Selector provided.
+   */
+  4:bool moreRecordsToFetch = 0
 }
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/b220118d/distribution/src/main/scripts/interface/gen-html/Blur.html
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-html/Blur.html b/distribution/src/main/scripts/interface/gen-html/Blur.html
index 9a951aa..7d4a69f 100644
--- a/distribution/src/main/scripts/interface/gen-html/Blur.html
+++ b/distribution/src/main/scripts/interface/gen-html/Blur.html
@@ -274,7 +274,7 @@ FetchResult.  Used in conjunction with maxRecordsToFetch.
 </td><td>default</td><td>0</td></tr>
 <tr><td>9</td><td>maxRecordsToFetch</td><td><code>i32</code></td><td>Only valid for Row fetches, the number of records to fetch.  If the row contains 1000 records
 and you want the first 100, then this value is 100.  If you want records 300-400 then this value
-would be 100.  Used in conjunction with maxRecordsToFetch. By default this will fetch the first
+would be 100.  Used in conjunction with startRecord. By default this will fetch the first
 1000 records of the row.
 </td><td>default</td><td>1000</td></tr>
 <tr><td>10</td><td>highlightOptions</td><td><code><a href="Blur.html#Struct_HighlightOptions">HighlightOptions</a></code></td><td>The HighlightOptions object controls how the data is highlighted.  If null no highlighting will occur.
@@ -284,6 +284,12 @@ would be 100.  Used in conjunction with maxRecordsToFetch. By default this will
 <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>row</td><td><code><a href="Blur.html#Struct_Row">Row</a></code></td><td>The row fetched.
 </td><td>default</td><td></td></tr>
+<tr><td>2</td><td>startRecord</td><td><code>i32</code></td><td>See Selector startRecord.
+</td><td>default</td><td>-1</td></tr>
+<tr><td>3</td><td>maxRecordsToFetch</td><td><code>i32</code></td><td>See Selector maxRecordsToFetch.
+</td><td>default</td><td>-1</td></tr>
+<tr><td>4</td><td>moreRecordsToFetch</td><td><code>bool</code></td><td>Are there more Records to fetch based on the Selector provided.
+</td><td>default</td><td>0</td></tr>
 </table><br/>FetchRowResult contains row result from a fetch.
 <br/></div><div class="definition"><h3 id="Struct_FetchRecordResult">Struct: FetchRecordResult</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>

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/b220118d/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/FetchRowResult.java
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/FetchRowResult.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/FetchRowResult.java
index b170a4c..b87a9da 100644
--- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/FetchRowResult.java
+++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/FetchRowResult.java
@@ -56,6 +56,9 @@ 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.TStruct STRUCT_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TStruct("FetchRowResult");
 
   private static final org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField ROW_FIELD_DESC = new org.apache.blur.thirdparty.thrift_0_9_0.protocol.TField("row", org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, (short)1);
+  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 Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
   static {
@@ -67,13 +70,37 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
    * The row fetched.
    */
   public Row row; // required
+  /**
+   * See Selector startRecord.
+   */
+  public int startRecord; // required
+  /**
+   * See Selector maxRecordsToFetch.
+   */
+  public int maxRecordsToFetch; // required
+  /**
+   * Are there more Records to fetch based on the Selector provided.
+   */
+  public boolean moreRecordsToFetch; // 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 {
     /**
      * The row fetched.
      */
-    ROW((short)1, "row");
+    ROW((short)1, "row"),
+    /**
+     * See Selector startRecord.
+     */
+    START_RECORD((short)2, "startRecord"),
+    /**
+     * See Selector maxRecordsToFetch.
+     */
+    MAX_RECORDS_TO_FETCH((short)3, "maxRecordsToFetch"),
+    /**
+     * Are there more Records to fetch based on the Selector provided.
+     */
+    MORE_RECORDS_TO_FETCH((short)4, "moreRecordsToFetch");
 
     private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -90,6 +117,12 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
       switch(fieldId) {
         case 1: // ROW
           return ROW;
+        case 2: // START_RECORD
+          return START_RECORD;
+        case 3: // MAX_RECORDS_TO_FETCH
+          return MAX_RECORDS_TO_FETCH;
+        case 4: // MORE_RECORDS_TO_FETCH
+          return MORE_RECORDS_TO_FETCH;
         default:
           return null;
       }
@@ -130,32 +163,61 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
   }
 
   // isset id assignments
+  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 byte __isset_bitfield = 0;
   public static final Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> metaDataMap;
   static {
     Map<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData>(_Fields.class);
     tmpMap.put(_Fields.ROW, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("row", org.apache.blur.thirdparty.thrift_0_9_0.TFieldRequirementType.DEFAULT, 
         new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.StructMetaData(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.STRUCT, Row.class)));
+    tmpMap.put(_Fields.START_RECORD, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("startRecord", 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)));
+    tmpMap.put(_Fields.MAX_RECORDS_TO_FETCH, new org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData("maxRecordsToFetch", 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)));
+    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)));
     metaDataMap = Collections.unmodifiableMap(tmpMap);
     org.apache.blur.thirdparty.thrift_0_9_0.meta_data.FieldMetaData.addStructMetaDataMap(FetchRowResult.class, metaDataMap);
   }
 
   public FetchRowResult() {
+    this.startRecord = -1;
+
+    this.maxRecordsToFetch = -1;
+
+    this.moreRecordsToFetch = false;
+
   }
 
   public FetchRowResult(
-    Row row)
+    Row row,
+    int startRecord,
+    int maxRecordsToFetch,
+    boolean moreRecordsToFetch)
   {
     this();
     this.row = row;
+    this.startRecord = startRecord;
+    setStartRecordIsSet(true);
+    this.maxRecordsToFetch = maxRecordsToFetch;
+    setMaxRecordsToFetchIsSet(true);
+    this.moreRecordsToFetch = moreRecordsToFetch;
+    setMoreRecordsToFetchIsSet(true);
   }
 
   /**
    * Performs a deep copy on <i>other</i>.
    */
   public FetchRowResult(FetchRowResult other) {
+    __isset_bitfield = other.__isset_bitfield;
     if (other.isSetRow()) {
       this.row = new Row(other.row);
     }
+    this.startRecord = other.startRecord;
+    this.maxRecordsToFetch = other.maxRecordsToFetch;
+    this.moreRecordsToFetch = other.moreRecordsToFetch;
   }
 
   public FetchRowResult deepCopy() {
@@ -165,6 +227,12 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
   @Override
   public void clear() {
     this.row = null;
+    this.startRecord = -1;
+
+    this.maxRecordsToFetch = -1;
+
+    this.moreRecordsToFetch = false;
+
   }
 
   /**
@@ -197,6 +265,93 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
     }
   }
 
+  /**
+   * See Selector startRecord.
+   */
+  public int getStartRecord() {
+    return this.startRecord;
+  }
+
+  /**
+   * See Selector startRecord.
+   */
+  public FetchRowResult setStartRecord(int startRecord) {
+    this.startRecord = startRecord;
+    setStartRecordIsSet(true);
+    return this;
+  }
+
+  public void unsetStartRecord() {
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __STARTRECORD_ISSET_ID);
+  }
+
+  /** Returns true if field startRecord is set (has been assigned a value) and false otherwise */
+  public boolean isSetStartRecord() {
+    return EncodingUtils.testBit(__isset_bitfield, __STARTRECORD_ISSET_ID);
+  }
+
+  public void setStartRecordIsSet(boolean value) {
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __STARTRECORD_ISSET_ID, value);
+  }
+
+  /**
+   * See Selector maxRecordsToFetch.
+   */
+  public int getMaxRecordsToFetch() {
+    return this.maxRecordsToFetch;
+  }
+
+  /**
+   * See Selector maxRecordsToFetch.
+   */
+  public FetchRowResult setMaxRecordsToFetch(int maxRecordsToFetch) {
+    this.maxRecordsToFetch = maxRecordsToFetch;
+    setMaxRecordsToFetchIsSet(true);
+    return this;
+  }
+
+  public void unsetMaxRecordsToFetch() {
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __MAXRECORDSTOFETCH_ISSET_ID);
+  }
+
+  /** Returns true if field maxRecordsToFetch is set (has been assigned a value) and false otherwise */
+  public boolean isSetMaxRecordsToFetch() {
+    return EncodingUtils.testBit(__isset_bitfield, __MAXRECORDSTOFETCH_ISSET_ID);
+  }
+
+  public void setMaxRecordsToFetchIsSet(boolean value) {
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MAXRECORDSTOFETCH_ISSET_ID, value);
+  }
+
+  /**
+   * Are there more Records to fetch based on the Selector provided.
+   */
+  public boolean isMoreRecordsToFetch() {
+    return this.moreRecordsToFetch;
+  }
+
+  /**
+   * Are there more Records to fetch based on the Selector provided.
+   */
+  public FetchRowResult setMoreRecordsToFetch(boolean moreRecordsToFetch) {
+    this.moreRecordsToFetch = moreRecordsToFetch;
+    setMoreRecordsToFetchIsSet(true);
+    return this;
+  }
+
+  public void unsetMoreRecordsToFetch() {
+    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __MORERECORDSTOFETCH_ISSET_ID);
+  }
+
+  /** Returns true if field moreRecordsToFetch is set (has been assigned a value) and false otherwise */
+  public boolean isSetMoreRecordsToFetch() {
+    return EncodingUtils.testBit(__isset_bitfield, __MORERECORDSTOFETCH_ISSET_ID);
+  }
+
+  public void setMoreRecordsToFetchIsSet(boolean value) {
+    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __MORERECORDSTOFETCH_ISSET_ID, value);
+  }
+
   public void setFieldValue(_Fields field, Object value) {
     switch (field) {
     case ROW:
@@ -207,6 +362,30 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
       }
       break;
 
+    case START_RECORD:
+      if (value == null) {
+        unsetStartRecord();
+      } else {
+        setStartRecord((Integer)value);
+      }
+      break;
+
+    case MAX_RECORDS_TO_FETCH:
+      if (value == null) {
+        unsetMaxRecordsToFetch();
+      } else {
+        setMaxRecordsToFetch((Integer)value);
+      }
+      break;
+
+    case MORE_RECORDS_TO_FETCH:
+      if (value == null) {
+        unsetMoreRecordsToFetch();
+      } else {
+        setMoreRecordsToFetch((Boolean)value);
+      }
+      break;
+
     }
   }
 
@@ -215,6 +394,15 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
     case ROW:
       return getRow();
 
+    case START_RECORD:
+      return Integer.valueOf(getStartRecord());
+
+    case MAX_RECORDS_TO_FETCH:
+      return Integer.valueOf(getMaxRecordsToFetch());
+
+    case MORE_RECORDS_TO_FETCH:
+      return Boolean.valueOf(isMoreRecordsToFetch());
+
     }
     throw new IllegalStateException();
   }
@@ -228,6 +416,12 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
     switch (field) {
     case ROW:
       return isSetRow();
+    case START_RECORD:
+      return isSetStartRecord();
+    case MAX_RECORDS_TO_FETCH:
+      return isSetMaxRecordsToFetch();
+    case MORE_RECORDS_TO_FETCH:
+      return isSetMoreRecordsToFetch();
     }
     throw new IllegalStateException();
   }
@@ -254,6 +448,33 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
         return false;
     }
 
+    boolean this_present_startRecord = true;
+    boolean that_present_startRecord = true;
+    if (this_present_startRecord || that_present_startRecord) {
+      if (!(this_present_startRecord && that_present_startRecord))
+        return false;
+      if (this.startRecord != that.startRecord)
+        return false;
+    }
+
+    boolean this_present_maxRecordsToFetch = true;
+    boolean that_present_maxRecordsToFetch = true;
+    if (this_present_maxRecordsToFetch || that_present_maxRecordsToFetch) {
+      if (!(this_present_maxRecordsToFetch && that_present_maxRecordsToFetch))
+        return false;
+      if (this.maxRecordsToFetch != that.maxRecordsToFetch)
+        return false;
+    }
+
+    boolean this_present_moreRecordsToFetch = true;
+    boolean that_present_moreRecordsToFetch = true;
+    if (this_present_moreRecordsToFetch || that_present_moreRecordsToFetch) {
+      if (!(this_present_moreRecordsToFetch && that_present_moreRecordsToFetch))
+        return false;
+      if (this.moreRecordsToFetch != that.moreRecordsToFetch)
+        return false;
+    }
+
     return true;
   }
 
@@ -280,6 +501,36 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
         return lastComparison;
       }
     }
+    lastComparison = Boolean.valueOf(isSetStartRecord()).compareTo(typedOther.isSetStartRecord());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetStartRecord()) {
+      lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.startRecord, typedOther.startRecord);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetMaxRecordsToFetch()).compareTo(typedOther.isSetMaxRecordsToFetch());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetMaxRecordsToFetch()) {
+      lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.maxRecordsToFetch, typedOther.maxRecordsToFetch);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
+    lastComparison = Boolean.valueOf(isSetMoreRecordsToFetch()).compareTo(typedOther.isSetMoreRecordsToFetch());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    if (isSetMoreRecordsToFetch()) {
+      lastComparison = org.apache.blur.thirdparty.thrift_0_9_0.TBaseHelper.compareTo(this.moreRecordsToFetch, typedOther.moreRecordsToFetch);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+    }
     return 0;
   }
 
@@ -307,6 +558,18 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
       sb.append(this.row);
     }
     first = false;
+    if (!first) sb.append(", ");
+    sb.append("startRecord:");
+    sb.append(this.startRecord);
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("maxRecordsToFetch:");
+    sb.append(this.maxRecordsToFetch);
+    first = false;
+    if (!first) sb.append(", ");
+    sb.append("moreRecordsToFetch:");
+    sb.append(this.moreRecordsToFetch);
+    first = false;
     sb.append(")");
     return sb.toString();
   }
@@ -329,6 +592,8 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
 
   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);
@@ -362,6 +627,30 @@ 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 2: // START_RECORD
+            if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32) {
+              struct.startRecord = iprot.readI32();
+              struct.setStartRecordIsSet(true);
+            } else { 
+              org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 3: // MAX_RECORDS_TO_FETCH
+            if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.I32) {
+              struct.maxRecordsToFetch = iprot.readI32();
+              struct.setMaxRecordsToFetchIsSet(true);
+            } else { 
+              org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+            }
+            break;
+          case 4: // MORE_RECORDS_TO_FETCH
+            if (schemeField.type == org.apache.blur.thirdparty.thrift_0_9_0.protocol.TType.BOOL) {
+              struct.moreRecordsToFetch = iprot.readBool();
+              struct.setMoreRecordsToFetchIsSet(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);
         }
@@ -382,6 +671,15 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
         struct.row.write(oprot);
         oprot.writeFieldEnd();
       }
+      oprot.writeFieldBegin(START_RECORD_FIELD_DESC);
+      oprot.writeI32(struct.startRecord);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(MAX_RECORDS_TO_FETCH_FIELD_DESC);
+      oprot.writeI32(struct.maxRecordsToFetch);
+      oprot.writeFieldEnd();
+      oprot.writeFieldBegin(MORE_RECORDS_TO_FETCH_FIELD_DESC);
+      oprot.writeBool(struct.moreRecordsToFetch);
+      oprot.writeFieldEnd();
       oprot.writeFieldStop();
       oprot.writeStructEnd();
     }
@@ -403,21 +701,51 @@ public class FetchRowResult implements org.apache.blur.thirdparty.thrift_0_9_0.T
       if (struct.isSetRow()) {
         optionals.set(0);
       }
-      oprot.writeBitSet(optionals, 1);
+      if (struct.isSetStartRecord()) {
+        optionals.set(1);
+      }
+      if (struct.isSetMaxRecordsToFetch()) {
+        optionals.set(2);
+      }
+      if (struct.isSetMoreRecordsToFetch()) {
+        optionals.set(3);
+      }
+      oprot.writeBitSet(optionals, 4);
       if (struct.isSetRow()) {
         struct.row.write(oprot);
       }
+      if (struct.isSetStartRecord()) {
+        oprot.writeI32(struct.startRecord);
+      }
+      if (struct.isSetMaxRecordsToFetch()) {
+        oprot.writeI32(struct.maxRecordsToFetch);
+      }
+      if (struct.isSetMoreRecordsToFetch()) {
+        oprot.writeBool(struct.moreRecordsToFetch);
+      }
     }
 
     @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(1);
+      BitSet incoming = iprot.readBitSet(4);
       if (incoming.get(0)) {
         struct.row = new Row();
         struct.row.read(iprot);
         struct.setRowIsSet(true);
       }
+      if (incoming.get(1)) {
+        struct.startRecord = iprot.readI32();
+        struct.setStartRecordIsSet(true);
+      }
+      if (incoming.get(2)) {
+        struct.maxRecordsToFetch = iprot.readI32();
+        struct.setMaxRecordsToFetchIsSet(true);
+      }
+      if (incoming.get(3)) {
+        struct.moreRecordsToFetch = iprot.readBool();
+        struct.setMoreRecordsToFetchIsSet(true);
+      }
     }
   }
 

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/b220118d/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Selector.java
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Selector.java b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Selector.java
index b5d6a04..81f5b69 100644
--- a/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Selector.java
+++ b/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Selector.java
@@ -106,7 +106,7 @@ public class Selector implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<S
   /**
    * Only valid for Row fetches, the number of records to fetch.  If the row contains 1000 records
    * and you want the first 100, then this value is 100.  If you want records 300-400 then this value
-   * would be 100.  Used in conjunction with maxRecordsToFetch. By default this will fetch the first
+   * would be 100.  Used in conjunction with startRecord. By default this will fetch the first
    * 1000 records of the row.
    */
   public int maxRecordsToFetch; // required
@@ -152,7 +152,7 @@ public class Selector implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<S
     /**
      * Only valid for Row fetches, the number of records to fetch.  If the row contains 1000 records
      * and you want the first 100, then this value is 100.  If you want records 300-400 then this value
-     * would be 100.  Used in conjunction with maxRecordsToFetch. By default this will fetch the first
+     * would be 100.  Used in conjunction with startRecord. By default this will fetch the first
      * 1000 records of the row.
      */
     MAX_RECORDS_TO_FETCH((short)9, "maxRecordsToFetch"),
@@ -610,7 +610,7 @@ public class Selector implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<S
   /**
    * Only valid for Row fetches, the number of records to fetch.  If the row contains 1000 records
    * and you want the first 100, then this value is 100.  If you want records 300-400 then this value
-   * would be 100.  Used in conjunction with maxRecordsToFetch. By default this will fetch the first
+   * would be 100.  Used in conjunction with startRecord. By default this will fetch the first
    * 1000 records of the row.
    */
   public int getMaxRecordsToFetch() {
@@ -620,7 +620,7 @@ public class Selector implements org.apache.blur.thirdparty.thrift_0_9_0.TBase<S
   /**
    * Only valid for Row fetches, the number of records to fetch.  If the row contains 1000 records
    * and you want the first 100, then this value is 100.  If you want records 300-400 then this value
-   * would be 100.  Used in conjunction with maxRecordsToFetch. By default this will fetch the first
+   * would be 100.  Used in conjunction with startRecord. By default this will fetch the first
    * 1000 records of the row.
    */
   public Selector setMaxRecordsToFetch(int maxRecordsToFetch) {

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/b220118d/distribution/src/main/scripts/interface/gen-js/Blur_types.js
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-js/Blur_types.js b/distribution/src/main/scripts/interface/gen-js/Blur_types.js
index 4046d88..1191088 100644
--- a/distribution/src/main/scripts/interface/gen-js/Blur_types.js
+++ b/distribution/src/main/scripts/interface/gen-js/Blur_types.js
@@ -859,10 +859,22 @@ Selector.prototype.write = function(output) {
 
 FetchRowResult = function(args) {
   this.row = null;
+  this.startRecord = -1;
+  this.maxRecordsToFetch = -1;
+  this.moreRecordsToFetch = false;
   if (args) {
     if (args.row !== undefined) {
       this.row = args.row;
     }
+    if (args.startRecord !== undefined) {
+      this.startRecord = args.startRecord;
+    }
+    if (args.maxRecordsToFetch !== undefined) {
+      this.maxRecordsToFetch = args.maxRecordsToFetch;
+    }
+    if (args.moreRecordsToFetch !== undefined) {
+      this.moreRecordsToFetch = args.moreRecordsToFetch;
+    }
   }
 };
 FetchRowResult.prototype = {};
@@ -887,9 +899,27 @@ FetchRowResult.prototype.read = function(input) {
         input.skip(ftype);
       }
       break;
-      case 0:
+      case 2:
+      if (ftype == Thrift.Type.I32) {
+        this.startRecord = input.readI32().value;
+      } else {
+        input.skip(ftype);
+      }
+      break;
+      case 3:
+      if (ftype == Thrift.Type.I32) {
+        this.maxRecordsToFetch = input.readI32().value;
+      } else {
+        input.skip(ftype);
+      }
+      break;
+      case 4:
+      if (ftype == Thrift.Type.BOOL) {
+        this.moreRecordsToFetch = input.readBool().value;
+      } else {
         input.skip(ftype);
-        break;
+      }
+      break;
       default:
         input.skip(ftype);
     }
@@ -906,6 +936,21 @@ FetchRowResult.prototype.write = function(output) {
     this.row.write(output);
     output.writeFieldEnd();
   }
+  if (this.startRecord !== null && this.startRecord !== undefined) {
+    output.writeFieldBegin('startRecord', Thrift.Type.I32, 2);
+    output.writeI32(this.startRecord);
+    output.writeFieldEnd();
+  }
+  if (this.maxRecordsToFetch !== null && this.maxRecordsToFetch !== undefined) {
+    output.writeFieldBegin('maxRecordsToFetch', Thrift.Type.I32, 3);
+    output.writeI32(this.maxRecordsToFetch);
+    output.writeFieldEnd();
+  }
+  if (this.moreRecordsToFetch !== null && this.moreRecordsToFetch !== undefined) {
+    output.writeFieldBegin('moreRecordsToFetch', Thrift.Type.BOOL, 4);
+    output.writeBool(this.moreRecordsToFetch);
+    output.writeFieldEnd();
+  }
   output.writeFieldStop();
   output.writeStructEnd();
   return;


Mime
View raw message