incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [10/11] More changes, blur-core compile and tests pass.
Date Sun, 24 Mar 2013 20:05:27 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/f4c3cc19/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
----------------------------------------------------------------------
diff --git a/interface/gen-java/org/apache/blur/thrift/generated/Blur.java b/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
index b23b71a..589c8ea 100644
--- a/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
+++ b/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
@@ -1,7 +1,8 @@
 /**
- * Autogenerated by Thrift Compiler (0.7.0)
+ * Autogenerated by Thrift Compiler (0.9.0)
  *
  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ *  @generated
  */
 package org.apache.blur.thrift.generated;
 
@@ -24,6 +25,15 @@ package org.apache.blur.thrift.generated;
 
 
 
+import org.apache.thrift.scheme.IScheme;
+import org.apache.thrift.scheme.SchemeFactory;
+import org.apache.thrift.scheme.StandardScheme;
+
+import org.apache.thrift.scheme.TupleScheme;
+import org.apache.thrift.protocol.TTupleProtocol;
+import org.apache.thrift.protocol.TProtocolException;
+import org.apache.thrift.EncodingUtils;
+import org.apache.thrift.TException;
 import java.util.List;
 import java.util.ArrayList;
 import java.util.Map;
@@ -1847,7 +1857,7 @@ public class Blur {
 
   }
 
-  public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor implements org.apache.thrift.TProcessor {
+  public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor<I> implements org.apache.thrift.TProcessor {
     private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName());
     public Processor(I iface) {
       super(iface, getProcessMap(new HashMap<String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>()));
@@ -1888,16 +1898,20 @@ public class Blur {
       return processMap;
     }
 
-    private static class shardClusterList<I extends Iface> extends org.apache.thrift.ProcessFunction<I, shardClusterList_args> {
+    public static class shardClusterList<I extends Iface> extends org.apache.thrift.ProcessFunction<I, shardClusterList_args> {
       public shardClusterList() {
         super("shardClusterList");
       }
 
-      protected shardClusterList_args getEmptyArgsInstance() {
+      public shardClusterList_args getEmptyArgsInstance() {
         return new shardClusterList_args();
       }
 
-      protected shardClusterList_result getResult(I iface, shardClusterList_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public shardClusterList_result getResult(I iface, shardClusterList_args args) throws org.apache.thrift.TException {
         shardClusterList_result result = new shardClusterList_result();
         try {
           result.success = iface.shardClusterList();
@@ -1908,16 +1922,20 @@ public class Blur {
       }
     }
 
-    private static class shardServerList<I extends Iface> extends org.apache.thrift.ProcessFunction<I, shardServerList_args> {
+    public static class shardServerList<I extends Iface> extends org.apache.thrift.ProcessFunction<I, shardServerList_args> {
       public shardServerList() {
         super("shardServerList");
       }
 
-      protected shardServerList_args getEmptyArgsInstance() {
+      public shardServerList_args getEmptyArgsInstance() {
         return new shardServerList_args();
       }
 
-      protected shardServerList_result getResult(I iface, shardServerList_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public shardServerList_result getResult(I iface, shardServerList_args args) throws org.apache.thrift.TException {
         shardServerList_result result = new shardServerList_result();
         try {
           result.success = iface.shardServerList(args.cluster);
@@ -1928,16 +1946,20 @@ public class Blur {
       }
     }
 
-    private static class controllerServerList<I extends Iface> extends org.apache.thrift.ProcessFunction<I, controllerServerList_args> {
+    public static class controllerServerList<I extends Iface> extends org.apache.thrift.ProcessFunction<I, controllerServerList_args> {
       public controllerServerList() {
         super("controllerServerList");
       }
 
-      protected controllerServerList_args getEmptyArgsInstance() {
+      public controllerServerList_args getEmptyArgsInstance() {
         return new controllerServerList_args();
       }
 
-      protected controllerServerList_result getResult(I iface, controllerServerList_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public controllerServerList_result getResult(I iface, controllerServerList_args args) throws org.apache.thrift.TException {
         controllerServerList_result result = new controllerServerList_result();
         try {
           result.success = iface.controllerServerList();
@@ -1948,16 +1970,20 @@ public class Blur {
       }
     }
 
-    private static class shardServerLayout<I extends Iface> extends org.apache.thrift.ProcessFunction<I, shardServerLayout_args> {
+    public static class shardServerLayout<I extends Iface> extends org.apache.thrift.ProcessFunction<I, shardServerLayout_args> {
       public shardServerLayout() {
         super("shardServerLayout");
       }
 
-      protected shardServerLayout_args getEmptyArgsInstance() {
+      public shardServerLayout_args getEmptyArgsInstance() {
         return new shardServerLayout_args();
       }
 
-      protected shardServerLayout_result getResult(I iface, shardServerLayout_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public shardServerLayout_result getResult(I iface, shardServerLayout_args args) throws org.apache.thrift.TException {
         shardServerLayout_result result = new shardServerLayout_result();
         try {
           result.success = iface.shardServerLayout(args.table);
@@ -1968,16 +1994,20 @@ public class Blur {
       }
     }
 
-    private static class tableList<I extends Iface> extends org.apache.thrift.ProcessFunction<I, tableList_args> {
+    public static class tableList<I extends Iface> extends org.apache.thrift.ProcessFunction<I, tableList_args> {
       public tableList() {
         super("tableList");
       }
 
-      protected tableList_args getEmptyArgsInstance() {
+      public tableList_args getEmptyArgsInstance() {
         return new tableList_args();
       }
 
-      protected tableList_result getResult(I iface, tableList_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public tableList_result getResult(I iface, tableList_args args) throws org.apache.thrift.TException {
         tableList_result result = new tableList_result();
         try {
           result.success = iface.tableList();
@@ -1988,16 +2018,20 @@ public class Blur {
       }
     }
 
-    private static class tableListByCluster<I extends Iface> extends org.apache.thrift.ProcessFunction<I, tableListByCluster_args> {
+    public static class tableListByCluster<I extends Iface> extends org.apache.thrift.ProcessFunction<I, tableListByCluster_args> {
       public tableListByCluster() {
         super("tableListByCluster");
       }
 
-      protected tableListByCluster_args getEmptyArgsInstance() {
+      public tableListByCluster_args getEmptyArgsInstance() {
         return new tableListByCluster_args();
       }
 
-      protected tableListByCluster_result getResult(I iface, tableListByCluster_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public tableListByCluster_result getResult(I iface, tableListByCluster_args args) throws org.apache.thrift.TException {
         tableListByCluster_result result = new tableListByCluster_result();
         try {
           result.success = iface.tableListByCluster(args.cluster);
@@ -2008,16 +2042,20 @@ public class Blur {
       }
     }
 
-    private static class describe<I extends Iface> extends org.apache.thrift.ProcessFunction<I, describe_args> {
+    public static class describe<I extends Iface> extends org.apache.thrift.ProcessFunction<I, describe_args> {
       public describe() {
         super("describe");
       }
 
-      protected describe_args getEmptyArgsInstance() {
+      public describe_args getEmptyArgsInstance() {
         return new describe_args();
       }
 
-      protected describe_result getResult(I iface, describe_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public describe_result getResult(I iface, describe_args args) throws org.apache.thrift.TException {
         describe_result result = new describe_result();
         try {
           result.success = iface.describe(args.table);
@@ -2028,16 +2066,20 @@ public class Blur {
       }
     }
 
-    private static class query<I extends Iface> extends org.apache.thrift.ProcessFunction<I, query_args> {
+    public static class query<I extends Iface> extends org.apache.thrift.ProcessFunction<I, query_args> {
       public query() {
         super("query");
       }
 
-      protected query_args getEmptyArgsInstance() {
+      public query_args getEmptyArgsInstance() {
         return new query_args();
       }
 
-      protected query_result getResult(I iface, query_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public query_result getResult(I iface, query_args args) throws org.apache.thrift.TException {
         query_result result = new query_result();
         try {
           result.success = iface.query(args.table, args.blurQuery);
@@ -2048,16 +2090,20 @@ public class Blur {
       }
     }
 
-    private static class cancelQuery<I extends Iface> extends org.apache.thrift.ProcessFunction<I, cancelQuery_args> {
+    public static class cancelQuery<I extends Iface> extends org.apache.thrift.ProcessFunction<I, cancelQuery_args> {
       public cancelQuery() {
         super("cancelQuery");
       }
 
-      protected cancelQuery_args getEmptyArgsInstance() {
+      public cancelQuery_args getEmptyArgsInstance() {
         return new cancelQuery_args();
       }
 
-      protected cancelQuery_result getResult(I iface, cancelQuery_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public cancelQuery_result getResult(I iface, cancelQuery_args args) throws org.apache.thrift.TException {
         cancelQuery_result result = new cancelQuery_result();
         try {
           iface.cancelQuery(args.table, args.uuid);
@@ -2068,16 +2114,20 @@ public class Blur {
       }
     }
 
-    private static class currentQueries<I extends Iface> extends org.apache.thrift.ProcessFunction<I, currentQueries_args> {
+    public static class currentQueries<I extends Iface> extends org.apache.thrift.ProcessFunction<I, currentQueries_args> {
       public currentQueries() {
         super("currentQueries");
       }
 
-      protected currentQueries_args getEmptyArgsInstance() {
+      public currentQueries_args getEmptyArgsInstance() {
         return new currentQueries_args();
       }
 
-      protected currentQueries_result getResult(I iface, currentQueries_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public currentQueries_result getResult(I iface, currentQueries_args args) throws org.apache.thrift.TException {
         currentQueries_result result = new currentQueries_result();
         try {
           result.success = iface.currentQueries(args.table);
@@ -2088,16 +2138,20 @@ public class Blur {
       }
     }
 
-    private static class queryStatusIdList<I extends Iface> extends org.apache.thrift.ProcessFunction<I, queryStatusIdList_args> {
+    public static class queryStatusIdList<I extends Iface> extends org.apache.thrift.ProcessFunction<I, queryStatusIdList_args> {
       public queryStatusIdList() {
         super("queryStatusIdList");
       }
 
-      protected queryStatusIdList_args getEmptyArgsInstance() {
+      public queryStatusIdList_args getEmptyArgsInstance() {
         return new queryStatusIdList_args();
       }
 
-      protected queryStatusIdList_result getResult(I iface, queryStatusIdList_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public queryStatusIdList_result getResult(I iface, queryStatusIdList_args args) throws org.apache.thrift.TException {
         queryStatusIdList_result result = new queryStatusIdList_result();
         try {
           result.success = iface.queryStatusIdList(args.table);
@@ -2108,16 +2162,20 @@ public class Blur {
       }
     }
 
-    private static class queryStatusById<I extends Iface> extends org.apache.thrift.ProcessFunction<I, queryStatusById_args> {
+    public static class queryStatusById<I extends Iface> extends org.apache.thrift.ProcessFunction<I, queryStatusById_args> {
       public queryStatusById() {
         super("queryStatusById");
       }
 
-      protected queryStatusById_args getEmptyArgsInstance() {
+      public queryStatusById_args getEmptyArgsInstance() {
         return new queryStatusById_args();
       }
 
-      protected queryStatusById_result getResult(I iface, queryStatusById_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public queryStatusById_result getResult(I iface, queryStatusById_args args) throws org.apache.thrift.TException {
         queryStatusById_result result = new queryStatusById_result();
         try {
           result.success = iface.queryStatusById(args.table, args.uuid);
@@ -2128,16 +2186,20 @@ public class Blur {
       }
     }
 
-    private static class schema<I extends Iface> extends org.apache.thrift.ProcessFunction<I, schema_args> {
+    public static class schema<I extends Iface> extends org.apache.thrift.ProcessFunction<I, schema_args> {
       public schema() {
         super("schema");
       }
 
-      protected schema_args getEmptyArgsInstance() {
+      public schema_args getEmptyArgsInstance() {
         return new schema_args();
       }
 
-      protected schema_result getResult(I iface, schema_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public schema_result getResult(I iface, schema_args args) throws org.apache.thrift.TException {
         schema_result result = new schema_result();
         try {
           result.success = iface.schema(args.table);
@@ -2148,16 +2210,20 @@ public class Blur {
       }
     }
 
-    private static class getTableStats<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getTableStats_args> {
+    public static class getTableStats<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getTableStats_args> {
       public getTableStats() {
         super("getTableStats");
       }
 
-      protected getTableStats_args getEmptyArgsInstance() {
+      public getTableStats_args getEmptyArgsInstance() {
         return new getTableStats_args();
       }
 
-      protected getTableStats_result getResult(I iface, getTableStats_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public getTableStats_result getResult(I iface, getTableStats_args args) throws org.apache.thrift.TException {
         getTableStats_result result = new getTableStats_result();
         try {
           result.success = iface.getTableStats(args.table);
@@ -2168,16 +2234,20 @@ public class Blur {
       }
     }
 
-    private static class tableStats<I extends Iface> extends org.apache.thrift.ProcessFunction<I, tableStats_args> {
+    public static class tableStats<I extends Iface> extends org.apache.thrift.ProcessFunction<I, tableStats_args> {
       public tableStats() {
         super("tableStats");
       }
 
-      protected tableStats_args getEmptyArgsInstance() {
+      public tableStats_args getEmptyArgsInstance() {
         return new tableStats_args();
       }
 
-      protected tableStats_result getResult(I iface, tableStats_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public tableStats_result getResult(I iface, tableStats_args args) throws org.apache.thrift.TException {
         tableStats_result result = new tableStats_result();
         try {
           result.success = iface.tableStats(args.table);
@@ -2188,16 +2258,20 @@ public class Blur {
       }
     }
 
-    private static class terms<I extends Iface> extends org.apache.thrift.ProcessFunction<I, terms_args> {
+    public static class terms<I extends Iface> extends org.apache.thrift.ProcessFunction<I, terms_args> {
       public terms() {
         super("terms");
       }
 
-      protected terms_args getEmptyArgsInstance() {
+      public terms_args getEmptyArgsInstance() {
         return new terms_args();
       }
 
-      protected terms_result getResult(I iface, terms_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public terms_result getResult(I iface, terms_args args) throws org.apache.thrift.TException {
         terms_result result = new terms_result();
         try {
           result.success = iface.terms(args.table, args.columnFamily, args.columnName, args.startWith, args.size);
@@ -2208,16 +2282,20 @@ public class Blur {
       }
     }
 
-    private static class recordFrequency<I extends Iface> extends org.apache.thrift.ProcessFunction<I, recordFrequency_args> {
+    public static class recordFrequency<I extends Iface> extends org.apache.thrift.ProcessFunction<I, recordFrequency_args> {
       public recordFrequency() {
         super("recordFrequency");
       }
 
-      protected recordFrequency_args getEmptyArgsInstance() {
+      public recordFrequency_args getEmptyArgsInstance() {
         return new recordFrequency_args();
       }
 
-      protected recordFrequency_result getResult(I iface, recordFrequency_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public recordFrequency_result getResult(I iface, recordFrequency_args args) throws org.apache.thrift.TException {
         recordFrequency_result result = new recordFrequency_result();
         try {
           result.success = iface.recordFrequency(args.table, args.columnFamily, args.columnName, args.value);
@@ -2229,16 +2307,20 @@ public class Blur {
       }
     }
 
-    private static class fetchRow<I extends Iface> extends org.apache.thrift.ProcessFunction<I, fetchRow_args> {
+    public static class fetchRow<I extends Iface> extends org.apache.thrift.ProcessFunction<I, fetchRow_args> {
       public fetchRow() {
         super("fetchRow");
       }
 
-      protected fetchRow_args getEmptyArgsInstance() {
+      public fetchRow_args getEmptyArgsInstance() {
         return new fetchRow_args();
       }
 
-      protected fetchRow_result getResult(I iface, fetchRow_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public fetchRow_result getResult(I iface, fetchRow_args args) throws org.apache.thrift.TException {
         fetchRow_result result = new fetchRow_result();
         try {
           result.success = iface.fetchRow(args.table, args.selector);
@@ -2249,16 +2331,20 @@ public class Blur {
       }
     }
 
-    private static class mutate<I extends Iface> extends org.apache.thrift.ProcessFunction<I, mutate_args> {
+    public static class mutate<I extends Iface> extends org.apache.thrift.ProcessFunction<I, mutate_args> {
       public mutate() {
         super("mutate");
       }
 
-      protected mutate_args getEmptyArgsInstance() {
+      public mutate_args getEmptyArgsInstance() {
         return new mutate_args();
       }
 
-      protected mutate_result getResult(I iface, mutate_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public mutate_result getResult(I iface, mutate_args args) throws org.apache.thrift.TException {
         mutate_result result = new mutate_result();
         try {
           iface.mutate(args.mutation);
@@ -2269,16 +2355,20 @@ public class Blur {
       }
     }
 
-    private static class mutateBatch<I extends Iface> extends org.apache.thrift.ProcessFunction<I, mutateBatch_args> {
+    public static class mutateBatch<I extends Iface> extends org.apache.thrift.ProcessFunction<I, mutateBatch_args> {
       public mutateBatch() {
         super("mutateBatch");
       }
 
-      protected mutateBatch_args getEmptyArgsInstance() {
+      public mutateBatch_args getEmptyArgsInstance() {
         return new mutateBatch_args();
       }
 
-      protected mutateBatch_result getResult(I iface, mutateBatch_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public mutateBatch_result getResult(I iface, mutateBatch_args args) throws org.apache.thrift.TException {
         mutateBatch_result result = new mutateBatch_result();
         try {
           iface.mutateBatch(args.mutations);
@@ -2289,16 +2379,20 @@ public class Blur {
       }
     }
 
-    private static class createTable<I extends Iface> extends org.apache.thrift.ProcessFunction<I, createTable_args> {
+    public static class createTable<I extends Iface> extends org.apache.thrift.ProcessFunction<I, createTable_args> {
       public createTable() {
         super("createTable");
       }
 
-      protected createTable_args getEmptyArgsInstance() {
+      public createTable_args getEmptyArgsInstance() {
         return new createTable_args();
       }
 
-      protected createTable_result getResult(I iface, createTable_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public createTable_result getResult(I iface, createTable_args args) throws org.apache.thrift.TException {
         createTable_result result = new createTable_result();
         try {
           iface.createTable(args.tableDescriptor);
@@ -2309,16 +2403,20 @@ public class Blur {
       }
     }
 
-    private static class enableTable<I extends Iface> extends org.apache.thrift.ProcessFunction<I, enableTable_args> {
+    public static class enableTable<I extends Iface> extends org.apache.thrift.ProcessFunction<I, enableTable_args> {
       public enableTable() {
         super("enableTable");
       }
 
-      protected enableTable_args getEmptyArgsInstance() {
+      public enableTable_args getEmptyArgsInstance() {
         return new enableTable_args();
       }
 
-      protected enableTable_result getResult(I iface, enableTable_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public enableTable_result getResult(I iface, enableTable_args args) throws org.apache.thrift.TException {
         enableTable_result result = new enableTable_result();
         try {
           iface.enableTable(args.table);
@@ -2329,16 +2427,20 @@ public class Blur {
       }
     }
 
-    private static class disableTable<I extends Iface> extends org.apache.thrift.ProcessFunction<I, disableTable_args> {
+    public static class disableTable<I extends Iface> extends org.apache.thrift.ProcessFunction<I, disableTable_args> {
       public disableTable() {
         super("disableTable");
       }
 
-      protected disableTable_args getEmptyArgsInstance() {
+      public disableTable_args getEmptyArgsInstance() {
         return new disableTable_args();
       }
 
-      protected disableTable_result getResult(I iface, disableTable_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public disableTable_result getResult(I iface, disableTable_args args) throws org.apache.thrift.TException {
         disableTable_result result = new disableTable_result();
         try {
           iface.disableTable(args.table);
@@ -2349,16 +2451,20 @@ public class Blur {
       }
     }
 
-    private static class removeTable<I extends Iface> extends org.apache.thrift.ProcessFunction<I, removeTable_args> {
+    public static class removeTable<I extends Iface> extends org.apache.thrift.ProcessFunction<I, removeTable_args> {
       public removeTable() {
         super("removeTable");
       }
 
-      protected removeTable_args getEmptyArgsInstance() {
+      public removeTable_args getEmptyArgsInstance() {
         return new removeTable_args();
       }
 
-      protected removeTable_result getResult(I iface, removeTable_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public removeTable_result getResult(I iface, removeTable_args args) throws org.apache.thrift.TException {
         removeTable_result result = new removeTable_result();
         try {
           iface.removeTable(args.table, args.deleteIndexFiles);
@@ -2369,16 +2475,20 @@ public class Blur {
       }
     }
 
-    private static class optimize<I extends Iface> extends org.apache.thrift.ProcessFunction<I, optimize_args> {
+    public static class optimize<I extends Iface> extends org.apache.thrift.ProcessFunction<I, optimize_args> {
       public optimize() {
         super("optimize");
       }
 
-      protected optimize_args getEmptyArgsInstance() {
+      public optimize_args getEmptyArgsInstance() {
         return new optimize_args();
       }
 
-      protected optimize_result getResult(I iface, optimize_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public optimize_result getResult(I iface, optimize_args args) throws org.apache.thrift.TException {
         optimize_result result = new optimize_result();
         try {
           iface.optimize(args.table, args.numberOfSegmentsPerShard);
@@ -2389,16 +2499,20 @@ public class Blur {
       }
     }
 
-    private static class isInSafeMode<I extends Iface> extends org.apache.thrift.ProcessFunction<I, isInSafeMode_args> {
+    public static class isInSafeMode<I extends Iface> extends org.apache.thrift.ProcessFunction<I, isInSafeMode_args> {
       public isInSafeMode() {
         super("isInSafeMode");
       }
 
-      protected isInSafeMode_args getEmptyArgsInstance() {
+      public isInSafeMode_args getEmptyArgsInstance() {
         return new isInSafeMode_args();
       }
 
-      protected isInSafeMode_result getResult(I iface, isInSafeMode_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public isInSafeMode_result getResult(I iface, isInSafeMode_args args) throws org.apache.thrift.TException {
         isInSafeMode_result result = new isInSafeMode_result();
         try {
           result.success = iface.isInSafeMode(args.cluster);
@@ -2410,16 +2524,20 @@ public class Blur {
       }
     }
 
-    private static class configuration<I extends Iface> extends org.apache.thrift.ProcessFunction<I, configuration_args> {
+    public static class configuration<I extends Iface> extends org.apache.thrift.ProcessFunction<I, configuration_args> {
       public configuration() {
         super("configuration");
       }
 
-      protected configuration_args getEmptyArgsInstance() {
+      public configuration_args getEmptyArgsInstance() {
         return new configuration_args();
       }
 
-      protected configuration_result getResult(I iface, configuration_args args) throws org.apache.thrift.TException {
+      protected boolean isOneway() {
+        return false;
+      }
+
+      public configuration_result getResult(I iface, configuration_args args) throws org.apache.thrift.TException {
         configuration_result result = new configuration_result();
         try {
           result.success = iface.configuration();
@@ -2436,6 +2554,12 @@ public class Blur {
     private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("shardClusterList_args");
 
 
+    private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+    static {
+      schemes.put(StandardScheme.class, new shardClusterList_argsStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new shardClusterList_argsTupleSchemeFactory());
+    }
+
 
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
     public enum _Fields implements org.apache.thrift.TFieldIdEnum {
@@ -2575,32 +2699,11 @@ public class Blur {
     }
 
     public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
-      org.apache.thrift.protocol.TField field;
-      iprot.readStructBegin();
-      while (true)
-      {
-        field = iprot.readFieldBegin();
-        if (field.type == org.apache.thrift.protocol.TType.STOP) { 
-          break;
-        }
-        switch (field.id) {
-          default:
-            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-        }
-        iprot.readFieldEnd();
-      }
-      iprot.readStructEnd();
-
-      // check for required fields of primitive type, which can't be checked in the validate method
-      validate();
+      schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
     }
 
     public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
-      validate();
-
-      oprot.writeStructBegin(STRUCT_DESC);
-      oprot.writeFieldStop();
-      oprot.writeStructEnd();
+      schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
     }
 
     @Override
@@ -2614,6 +2717,7 @@ public class Blur {
 
     public void validate() throws org.apache.thrift.TException {
       // check for required fields
+      // check for sub-struct validity
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -2632,6 +2736,64 @@ public class Blur {
       }
     }
 
+    private static class shardClusterList_argsStandardSchemeFactory implements SchemeFactory {
+      public shardClusterList_argsStandardScheme getScheme() {
+        return new shardClusterList_argsStandardScheme();
+      }
+    }
+
+    private static class shardClusterList_argsStandardScheme extends StandardScheme<shardClusterList_args> {
+
+      public void read(org.apache.thrift.protocol.TProtocol iprot, shardClusterList_args struct) throws org.apache.thrift.TException {
+        org.apache.thrift.protocol.TField schemeField;
+        iprot.readStructBegin();
+        while (true)
+        {
+          schemeField = iprot.readFieldBegin();
+          if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
+            break;
+          }
+          switch (schemeField.id) {
+            default:
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+          }
+          iprot.readFieldEnd();
+        }
+        iprot.readStructEnd();
+
+        // check for required fields of primitive type, which can't be checked in the validate method
+        struct.validate();
+      }
+
+      public void write(org.apache.thrift.protocol.TProtocol oprot, shardClusterList_args struct) throws org.apache.thrift.TException {
+        struct.validate();
+
+        oprot.writeStructBegin(STRUCT_DESC);
+        oprot.writeFieldStop();
+        oprot.writeStructEnd();
+      }
+
+    }
+
+    private static class shardClusterList_argsTupleSchemeFactory implements SchemeFactory {
+      public shardClusterList_argsTupleScheme getScheme() {
+        return new shardClusterList_argsTupleScheme();
+      }
+    }
+
+    private static class shardClusterList_argsTupleScheme extends TupleScheme<shardClusterList_args> {
+
+      @Override
+      public void write(org.apache.thrift.protocol.TProtocol prot, shardClusterList_args struct) throws org.apache.thrift.TException {
+        TTupleProtocol oprot = (TTupleProtocol) prot;
+      }
+
+      @Override
+      public void read(org.apache.thrift.protocol.TProtocol prot, shardClusterList_args struct) throws org.apache.thrift.TException {
+        TTupleProtocol iprot = (TTupleProtocol) prot;
+      }
+    }
+
   }
 
   public static class shardClusterList_result implements org.apache.thrift.TBase<shardClusterList_result, shardClusterList_result._Fields>, java.io.Serializable, Cloneable   {
@@ -2640,6 +2802,12 @@ public class Blur {
     private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.LIST, (short)0);
     private static final org.apache.thrift.protocol.TField EX_FIELD_DESC = new org.apache.thrift.protocol.TField("ex", org.apache.thrift.protocol.TType.STRUCT, (short)1);
 
+    private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+    static {
+      schemes.put(StandardScheme.class, new shardClusterList_resultStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new shardClusterList_resultTupleSchemeFactory());
+    }
+
     public List<String> success; // required
     public BlurException ex; // required
 
@@ -2705,7 +2873,6 @@ public class Blur {
     }
 
     // isset id assignments
-
     public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
     static {
       Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -2942,73 +3109,12 @@ public class Blur {
     }
 
     public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
-      org.apache.thrift.protocol.TField field;
-      iprot.readStructBegin();
-      while (true)
-      {
-        field = iprot.readFieldBegin();
-        if (field.type == org.apache.thrift.protocol.TType.STOP) { 
-          break;
-        }
-        switch (field.id) {
-          case 0: // SUCCESS
-            if (field.type == org.apache.thrift.protocol.TType.LIST) {
-              {
-                org.apache.thrift.protocol.TList _list83 = iprot.readListBegin();
-                this.success = new ArrayList<String>(_list83.size);
-                for (int _i84 = 0; _i84 < _list83.size; ++_i84)
-                {
-                  String _elem85; // required
-                  _elem85 = iprot.readString();
-                  this.success.add(_elem85);
-                }
-                iprot.readListEnd();
-              }
-            } else { 
-              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-            }
-            break;
-          case 1: // EX
-            if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
-              this.ex = new BlurException();
-              this.ex.read(iprot);
-            } else { 
-              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-            }
-            break;
-          default:
-            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-        }
-        iprot.readFieldEnd();
-      }
-      iprot.readStructEnd();
-
-      // check for required fields of primitive type, which can't be checked in the validate method
-      validate();
+      schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
     }
 
     public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
-      oprot.writeStructBegin(STRUCT_DESC);
-
-      if (this.isSetSuccess()) {
-        oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
-        {
-          oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, this.success.size()));
-          for (String _iter86 : this.success)
-          {
-            oprot.writeString(_iter86);
-          }
-          oprot.writeListEnd();
-        }
-        oprot.writeFieldEnd();
-      } else if (this.isSetEx()) {
-        oprot.writeFieldBegin(EX_FIELD_DESC);
-        this.ex.write(oprot);
-        oprot.writeFieldEnd();
+      schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
       }
-      oprot.writeFieldStop();
-      oprot.writeStructEnd();
-    }
 
     @Override
     public String toString() {
@@ -3036,6 +3142,7 @@ public class Blur {
 
     public void validate() throws org.apache.thrift.TException {
       // check for required fields
+      // check for sub-struct validity
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -3054,6 +3161,147 @@ public class Blur {
       }
     }
 
+    private static class shardClusterList_resultStandardSchemeFactory implements SchemeFactory {
+      public shardClusterList_resultStandardScheme getScheme() {
+        return new shardClusterList_resultStandardScheme();
+      }
+    }
+
+    private static class shardClusterList_resultStandardScheme extends StandardScheme<shardClusterList_result> {
+
+      public void read(org.apache.thrift.protocol.TProtocol iprot, shardClusterList_result struct) throws org.apache.thrift.TException {
+        org.apache.thrift.protocol.TField schemeField;
+        iprot.readStructBegin();
+        while (true)
+        {
+          schemeField = iprot.readFieldBegin();
+          if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
+            break;
+          }
+          switch (schemeField.id) {
+            case 0: // SUCCESS
+              if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+                {
+                  org.apache.thrift.protocol.TList _list176 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list176.size);
+                  for (int _i177 = 0; _i177 < _list176.size; ++_i177)
+                  {
+                    String _elem178; // required
+                    _elem178 = iprot.readString();
+                    struct.success.add(_elem178);
+                  }
+                  iprot.readListEnd();
+                }
+                struct.setSuccessIsSet(true);
+              } else { 
+                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
+            case 1: // EX
+              if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+                struct.ex = new BlurException();
+                struct.ex.read(iprot);
+                struct.setExIsSet(true);
+              } else { 
+                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
+            default:
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+          }
+          iprot.readFieldEnd();
+        }
+        iprot.readStructEnd();
+
+        // check for required fields of primitive type, which can't be checked in the validate method
+        struct.validate();
+      }
+
+      public void write(org.apache.thrift.protocol.TProtocol oprot, shardClusterList_result struct) throws org.apache.thrift.TException {
+        struct.validate();
+
+        oprot.writeStructBegin(STRUCT_DESC);
+        if (struct.success != null) {
+          oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+          {
+            oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
+            for (String _iter179 : struct.success)
+            {
+              oprot.writeString(_iter179);
+            }
+            oprot.writeListEnd();
+          }
+          oprot.writeFieldEnd();
+        }
+        if (struct.ex != null) {
+          oprot.writeFieldBegin(EX_FIELD_DESC);
+          struct.ex.write(oprot);
+          oprot.writeFieldEnd();
+        }
+        oprot.writeFieldStop();
+        oprot.writeStructEnd();
+      }
+
+    }
+
+    private static class shardClusterList_resultTupleSchemeFactory implements SchemeFactory {
+      public shardClusterList_resultTupleScheme getScheme() {
+        return new shardClusterList_resultTupleScheme();
+      }
+    }
+
+    private static class shardClusterList_resultTupleScheme extends TupleScheme<shardClusterList_result> {
+
+      @Override
+      public void write(org.apache.thrift.protocol.TProtocol prot, shardClusterList_result struct) throws org.apache.thrift.TException {
+        TTupleProtocol oprot = (TTupleProtocol) prot;
+        BitSet optionals = new BitSet();
+        if (struct.isSetSuccess()) {
+          optionals.set(0);
+        }
+        if (struct.isSetEx()) {
+          optionals.set(1);
+        }
+        oprot.writeBitSet(optionals, 2);
+        if (struct.isSetSuccess()) {
+          {
+            oprot.writeI32(struct.success.size());
+            for (String _iter180 : struct.success)
+            {
+              oprot.writeString(_iter180);
+            }
+          }
+        }
+        if (struct.isSetEx()) {
+          struct.ex.write(oprot);
+        }
+      }
+
+      @Override
+      public void read(org.apache.thrift.protocol.TProtocol prot, shardClusterList_result struct) throws org.apache.thrift.TException {
+        TTupleProtocol iprot = (TTupleProtocol) prot;
+        BitSet incoming = iprot.readBitSet(2);
+        if (incoming.get(0)) {
+          {
+            org.apache.thrift.protocol.TList _list181 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list181.size);
+            for (int _i182 = 0; _i182 < _list181.size; ++_i182)
+            {
+              String _elem183; // required
+              _elem183 = iprot.readString();
+              struct.success.add(_elem183);
+            }
+          }
+          struct.setSuccessIsSet(true);
+        }
+        if (incoming.get(1)) {
+          struct.ex = new BlurException();
+          struct.ex.read(iprot);
+          struct.setExIsSet(true);
+        }
+      }
+    }
+
   }
 
   public static class shardServerList_args implements org.apache.thrift.TBase<shardServerList_args, shardServerList_args._Fields>, java.io.Serializable, Cloneable   {
@@ -3061,6 +3309,12 @@ public class Blur {
 
     private static final org.apache.thrift.protocol.TField CLUSTER_FIELD_DESC = new org.apache.thrift.protocol.TField("cluster", org.apache.thrift.protocol.TType.STRING, (short)1);
 
+    private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+    static {
+      schemes.put(StandardScheme.class, new shardServerList_argsStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new shardServerList_argsTupleSchemeFactory());
+    }
+
     public String cluster; // required
 
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
@@ -3122,7 +3376,6 @@ public class Blur {
     }
 
     // isset id assignments
-
     public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
     static {
       Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -3275,44 +3528,11 @@ public class Blur {
     }
 
     public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
-      org.apache.thrift.protocol.TField field;
-      iprot.readStructBegin();
-      while (true)
-      {
-        field = iprot.readFieldBegin();
-        if (field.type == org.apache.thrift.protocol.TType.STOP) { 
-          break;
-        }
-        switch (field.id) {
-          case 1: // CLUSTER
-            if (field.type == org.apache.thrift.protocol.TType.STRING) {
-              this.cluster = iprot.readString();
-            } else { 
-              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-            }
-            break;
-          default:
-            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-        }
-        iprot.readFieldEnd();
-      }
-      iprot.readStructEnd();
-
-      // check for required fields of primitive type, which can't be checked in the validate method
-      validate();
+      schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
     }
 
     public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
-      validate();
-
-      oprot.writeStructBegin(STRUCT_DESC);
-      if (this.cluster != null) {
-        oprot.writeFieldBegin(CLUSTER_FIELD_DESC);
-        oprot.writeString(this.cluster);
-        oprot.writeFieldEnd();
-      }
-      oprot.writeFieldStop();
-      oprot.writeStructEnd();
+      schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
     }
 
     @Override
@@ -3333,6 +3553,7 @@ public class Blur {
 
     public void validate() throws org.apache.thrift.TException {
       // check for required fields
+      // check for sub-struct validity
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -3351,6 +3572,90 @@ public class Blur {
       }
     }
 
+    private static class shardServerList_argsStandardSchemeFactory implements SchemeFactory {
+      public shardServerList_argsStandardScheme getScheme() {
+        return new shardServerList_argsStandardScheme();
+      }
+    }
+
+    private static class shardServerList_argsStandardScheme extends StandardScheme<shardServerList_args> {
+
+      public void read(org.apache.thrift.protocol.TProtocol iprot, shardServerList_args struct) throws org.apache.thrift.TException {
+        org.apache.thrift.protocol.TField schemeField;
+        iprot.readStructBegin();
+        while (true)
+        {
+          schemeField = iprot.readFieldBegin();
+          if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
+            break;
+          }
+          switch (schemeField.id) {
+            case 1: // CLUSTER
+              if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+                struct.cluster = iprot.readString();
+                struct.setClusterIsSet(true);
+              } else { 
+                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
+            default:
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+          }
+          iprot.readFieldEnd();
+        }
+        iprot.readStructEnd();
+
+        // check for required fields of primitive type, which can't be checked in the validate method
+        struct.validate();
+      }
+
+      public void write(org.apache.thrift.protocol.TProtocol oprot, shardServerList_args struct) throws org.apache.thrift.TException {
+        struct.validate();
+
+        oprot.writeStructBegin(STRUCT_DESC);
+        if (struct.cluster != null) {
+          oprot.writeFieldBegin(CLUSTER_FIELD_DESC);
+          oprot.writeString(struct.cluster);
+          oprot.writeFieldEnd();
+        }
+        oprot.writeFieldStop();
+        oprot.writeStructEnd();
+      }
+
+    }
+
+    private static class shardServerList_argsTupleSchemeFactory implements SchemeFactory {
+      public shardServerList_argsTupleScheme getScheme() {
+        return new shardServerList_argsTupleScheme();
+      }
+    }
+
+    private static class shardServerList_argsTupleScheme extends TupleScheme<shardServerList_args> {
+
+      @Override
+      public void write(org.apache.thrift.protocol.TProtocol prot, shardServerList_args struct) throws org.apache.thrift.TException {
+        TTupleProtocol oprot = (TTupleProtocol) prot;
+        BitSet optionals = new BitSet();
+        if (struct.isSetCluster()) {
+          optionals.set(0);
+        }
+        oprot.writeBitSet(optionals, 1);
+        if (struct.isSetCluster()) {
+          oprot.writeString(struct.cluster);
+        }
+      }
+
+      @Override
+      public void read(org.apache.thrift.protocol.TProtocol prot, shardServerList_args struct) throws org.apache.thrift.TException {
+        TTupleProtocol iprot = (TTupleProtocol) prot;
+        BitSet incoming = iprot.readBitSet(1);
+        if (incoming.get(0)) {
+          struct.cluster = iprot.readString();
+          struct.setClusterIsSet(true);
+        }
+      }
+    }
+
   }
 
   public static class shardServerList_result implements org.apache.thrift.TBase<shardServerList_result, shardServerList_result._Fields>, java.io.Serializable, Cloneable   {
@@ -3359,6 +3664,12 @@ public class Blur {
     private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.LIST, (short)0);
     private static final org.apache.thrift.protocol.TField EX_FIELD_DESC = new org.apache.thrift.protocol.TField("ex", org.apache.thrift.protocol.TType.STRUCT, (short)1);
 
+    private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+    static {
+      schemes.put(StandardScheme.class, new shardServerList_resultStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new shardServerList_resultTupleSchemeFactory());
+    }
+
     public List<String> success; // required
     public BlurException ex; // required
 
@@ -3424,7 +3735,6 @@ public class Blur {
     }
 
     // isset id assignments
-
     public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
     static {
       Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -3661,73 +3971,12 @@ public class Blur {
     }
 
     public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
-      org.apache.thrift.protocol.TField field;
-      iprot.readStructBegin();
-      while (true)
-      {
-        field = iprot.readFieldBegin();
-        if (field.type == org.apache.thrift.protocol.TType.STOP) { 
-          break;
-        }
-        switch (field.id) {
-          case 0: // SUCCESS
-            if (field.type == org.apache.thrift.protocol.TType.LIST) {
-              {
-                org.apache.thrift.protocol.TList _list87 = iprot.readListBegin();
-                this.success = new ArrayList<String>(_list87.size);
-                for (int _i88 = 0; _i88 < _list87.size; ++_i88)
-                {
-                  String _elem89; // required
-                  _elem89 = iprot.readString();
-                  this.success.add(_elem89);
-                }
-                iprot.readListEnd();
-              }
-            } else { 
-              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-            }
-            break;
-          case 1: // EX
-            if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
-              this.ex = new BlurException();
-              this.ex.read(iprot);
-            } else { 
-              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-            }
-            break;
-          default:
-            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-        }
-        iprot.readFieldEnd();
-      }
-      iprot.readStructEnd();
-
-      // check for required fields of primitive type, which can't be checked in the validate method
-      validate();
+      schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
     }
 
     public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
-      oprot.writeStructBegin(STRUCT_DESC);
-
-      if (this.isSetSuccess()) {
-        oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
-        {
-          oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, this.success.size()));
-          for (String _iter90 : this.success)
-          {
-            oprot.writeString(_iter90);
-          }
-          oprot.writeListEnd();
-        }
-        oprot.writeFieldEnd();
-      } else if (this.isSetEx()) {
-        oprot.writeFieldBegin(EX_FIELD_DESC);
-        this.ex.write(oprot);
-        oprot.writeFieldEnd();
-      }
-      oprot.writeFieldStop();
-      oprot.writeStructEnd();
-    }
+      schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
+      }
 
     @Override
     public String toString() {
@@ -3755,6 +4004,7 @@ public class Blur {
 
     public void validate() throws org.apache.thrift.TException {
       // check for required fields
+      // check for sub-struct validity
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -3773,12 +4023,159 @@ public class Blur {
       }
     }
 
+    private static class shardServerList_resultStandardSchemeFactory implements SchemeFactory {
+      public shardServerList_resultStandardScheme getScheme() {
+        return new shardServerList_resultStandardScheme();
+      }
+    }
+
+    private static class shardServerList_resultStandardScheme extends StandardScheme<shardServerList_result> {
+
+      public void read(org.apache.thrift.protocol.TProtocol iprot, shardServerList_result struct) throws org.apache.thrift.TException {
+        org.apache.thrift.protocol.TField schemeField;
+        iprot.readStructBegin();
+        while (true)
+        {
+          schemeField = iprot.readFieldBegin();
+          if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
+            break;
+          }
+          switch (schemeField.id) {
+            case 0: // SUCCESS
+              if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+                {
+                  org.apache.thrift.protocol.TList _list184 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list184.size);
+                  for (int _i185 = 0; _i185 < _list184.size; ++_i185)
+                  {
+                    String _elem186; // required
+                    _elem186 = iprot.readString();
+                    struct.success.add(_elem186);
+                  }
+                  iprot.readListEnd();
+                }
+                struct.setSuccessIsSet(true);
+              } else { 
+                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
+            case 1: // EX
+              if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+                struct.ex = new BlurException();
+                struct.ex.read(iprot);
+                struct.setExIsSet(true);
+              } else { 
+                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
+            default:
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+          }
+          iprot.readFieldEnd();
+        }
+        iprot.readStructEnd();
+
+        // check for required fields of primitive type, which can't be checked in the validate method
+        struct.validate();
+      }
+
+      public void write(org.apache.thrift.protocol.TProtocol oprot, shardServerList_result struct) throws org.apache.thrift.TException {
+        struct.validate();
+
+        oprot.writeStructBegin(STRUCT_DESC);
+        if (struct.success != null) {
+          oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+          {
+            oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
+            for (String _iter187 : struct.success)
+            {
+              oprot.writeString(_iter187);
+            }
+            oprot.writeListEnd();
+          }
+          oprot.writeFieldEnd();
+        }
+        if (struct.ex != null) {
+          oprot.writeFieldBegin(EX_FIELD_DESC);
+          struct.ex.write(oprot);
+          oprot.writeFieldEnd();
+        }
+        oprot.writeFieldStop();
+        oprot.writeStructEnd();
+      }
+
+    }
+
+    private static class shardServerList_resultTupleSchemeFactory implements SchemeFactory {
+      public shardServerList_resultTupleScheme getScheme() {
+        return new shardServerList_resultTupleScheme();
+      }
+    }
+
+    private static class shardServerList_resultTupleScheme extends TupleScheme<shardServerList_result> {
+
+      @Override
+      public void write(org.apache.thrift.protocol.TProtocol prot, shardServerList_result struct) throws org.apache.thrift.TException {
+        TTupleProtocol oprot = (TTupleProtocol) prot;
+        BitSet optionals = new BitSet();
+        if (struct.isSetSuccess()) {
+          optionals.set(0);
+        }
+        if (struct.isSetEx()) {
+          optionals.set(1);
+        }
+        oprot.writeBitSet(optionals, 2);
+        if (struct.isSetSuccess()) {
+          {
+            oprot.writeI32(struct.success.size());
+            for (String _iter188 : struct.success)
+            {
+              oprot.writeString(_iter188);
+            }
+          }
+        }
+        if (struct.isSetEx()) {
+          struct.ex.write(oprot);
+        }
+      }
+
+      @Override
+      public void read(org.apache.thrift.protocol.TProtocol prot, shardServerList_result struct) throws org.apache.thrift.TException {
+        TTupleProtocol iprot = (TTupleProtocol) prot;
+        BitSet incoming = iprot.readBitSet(2);
+        if (incoming.get(0)) {
+          {
+            org.apache.thrift.protocol.TList _list189 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list189.size);
+            for (int _i190 = 0; _i190 < _list189.size; ++_i190)
+            {
+              String _elem191; // required
+              _elem191 = iprot.readString();
+              struct.success.add(_elem191);
+            }
+          }
+          struct.setSuccessIsSet(true);
+        }
+        if (incoming.get(1)) {
+          struct.ex = new BlurException();
+          struct.ex.read(iprot);
+          struct.setExIsSet(true);
+        }
+      }
+    }
+
   }
 
   public static class controllerServerList_args implements org.apache.thrift.TBase<controllerServerList_args, controllerServerList_args._Fields>, java.io.Serializable, Cloneable   {
     private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("controllerServerList_args");
 
 
+    private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+    static {
+      schemes.put(StandardScheme.class, new controllerServerList_argsStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new controllerServerList_argsTupleSchemeFactory());
+    }
+
 
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
     public enum _Fields implements org.apache.thrift.TFieldIdEnum {
@@ -3918,32 +4315,11 @@ public class Blur {
     }
 
     public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
-      org.apache.thrift.protocol.TField field;
-      iprot.readStructBegin();
-      while (true)
-      {
-        field = iprot.readFieldBegin();
-        if (field.type == org.apache.thrift.protocol.TType.STOP) { 
-          break;
-        }
-        switch (field.id) {
-          default:
-            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-        }
-        iprot.readFieldEnd();
-      }
-      iprot.readStructEnd();
-
-      // check for required fields of primitive type, which can't be checked in the validate method
-      validate();
+      schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
     }
 
     public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
-      validate();
-
-      oprot.writeStructBegin(STRUCT_DESC);
-      oprot.writeFieldStop();
-      oprot.writeStructEnd();
+      schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
     }
 
     @Override
@@ -3957,6 +4333,7 @@ public class Blur {
 
     public void validate() throws org.apache.thrift.TException {
       // check for required fields
+      // check for sub-struct validity
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -3975,6 +4352,64 @@ public class Blur {
       }
     }
 
+    private static class controllerServerList_argsStandardSchemeFactory implements SchemeFactory {
+      public controllerServerList_argsStandardScheme getScheme() {
+        return new controllerServerList_argsStandardScheme();
+      }
+    }
+
+    private static class controllerServerList_argsStandardScheme extends StandardScheme<controllerServerList_args> {
+
+      public void read(org.apache.thrift.protocol.TProtocol iprot, controllerServerList_args struct) throws org.apache.thrift.TException {
+        org.apache.thrift.protocol.TField schemeField;
+        iprot.readStructBegin();
+        while (true)
+        {
+          schemeField = iprot.readFieldBegin();
+          if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
+            break;
+          }
+          switch (schemeField.id) {
+            default:
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+          }
+          iprot.readFieldEnd();
+        }
+        iprot.readStructEnd();
+
+        // check for required fields of primitive type, which can't be checked in the validate method
+        struct.validate();
+      }
+
+      public void write(org.apache.thrift.protocol.TProtocol oprot, controllerServerList_args struct) throws org.apache.thrift.TException {
+        struct.validate();
+
+        oprot.writeStructBegin(STRUCT_DESC);
+        oprot.writeFieldStop();
+        oprot.writeStructEnd();
+      }
+
+    }
+
+    private static class controllerServerList_argsTupleSchemeFactory implements SchemeFactory {
+      public controllerServerList_argsTupleScheme getScheme() {
+        return new controllerServerList_argsTupleScheme();
+      }
+    }
+
+    private static class controllerServerList_argsTupleScheme extends TupleScheme<controllerServerList_args> {
+
+      @Override
+      public void write(org.apache.thrift.protocol.TProtocol prot, controllerServerList_args struct) throws org.apache.thrift.TException {
+        TTupleProtocol oprot = (TTupleProtocol) prot;
+      }
+
+      @Override
+      public void read(org.apache.thrift.protocol.TProtocol prot, controllerServerList_args struct) throws org.apache.thrift.TException {
+        TTupleProtocol iprot = (TTupleProtocol) prot;
+      }
+    }
+
   }
 
   public static class controllerServerList_result implements org.apache.thrift.TBase<controllerServerList_result, controllerServerList_result._Fields>, java.io.Serializable, Cloneable   {
@@ -3983,6 +4418,12 @@ public class Blur {
     private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.LIST, (short)0);
     private static final org.apache.thrift.protocol.TField EX_FIELD_DESC = new org.apache.thrift.protocol.TField("ex", org.apache.thrift.protocol.TType.STRUCT, (short)1);
 
+    private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+    static {
+      schemes.put(StandardScheme.class, new controllerServerList_resultStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new controllerServerList_resultTupleSchemeFactory());
+    }
+
     public List<String> success; // required
     public BlurException ex; // required
 
@@ -4048,7 +4489,6 @@ public class Blur {
     }
 
     // isset id assignments
-
     public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
     static {
       Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -4285,73 +4725,12 @@ public class Blur {
     }
 
     public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
-      org.apache.thrift.protocol.TField field;
-      iprot.readStructBegin();
-      while (true)
-      {
-        field = iprot.readFieldBegin();
-        if (field.type == org.apache.thrift.protocol.TType.STOP) { 
-          break;
-        }
-        switch (field.id) {
-          case 0: // SUCCESS
-            if (field.type == org.apache.thrift.protocol.TType.LIST) {
-              {
-                org.apache.thrift.protocol.TList _list91 = iprot.readListBegin();
-                this.success = new ArrayList<String>(_list91.size);
-                for (int _i92 = 0; _i92 < _list91.size; ++_i92)
-                {
-                  String _elem93; // required
-                  _elem93 = iprot.readString();
-                  this.success.add(_elem93);
-                }
-                iprot.readListEnd();
-              }
-            } else { 
-              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-            }
-            break;
-          case 1: // EX
-            if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
-              this.ex = new BlurException();
-              this.ex.read(iprot);
-            } else { 
-              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-            }
-            break;
-          default:
-            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-        }
-        iprot.readFieldEnd();
-      }
-      iprot.readStructEnd();
-
-      // check for required fields of primitive type, which can't be checked in the validate method
-      validate();
+      schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
     }
 
     public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
-      oprot.writeStructBegin(STRUCT_DESC);
-
-      if (this.isSetSuccess()) {
-        oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
-        {
-          oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, this.success.size()));
-          for (String _iter94 : this.success)
-          {
-            oprot.writeString(_iter94);
-          }
-          oprot.writeListEnd();
-        }
-        oprot.writeFieldEnd();
-      } else if (this.isSetEx()) {
-        oprot.writeFieldBegin(EX_FIELD_DESC);
-        this.ex.write(oprot);
-        oprot.writeFieldEnd();
+      schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
       }
-      oprot.writeFieldStop();
-      oprot.writeStructEnd();
-    }
 
     @Override
     public String toString() {
@@ -4379,6 +4758,7 @@ public class Blur {
 
     public void validate() throws org.apache.thrift.TException {
       // check for required fields
+      // check for sub-struct validity
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -4397,6 +4777,147 @@ public class Blur {
       }
     }
 
+    private static class controllerServerList_resultStandardSchemeFactory implements SchemeFactory {
+      public controllerServerList_resultStandardScheme getScheme() {
+        return new controllerServerList_resultStandardScheme();
+      }
+    }
+
+    private static class controllerServerList_resultStandardScheme extends StandardScheme<controllerServerList_result> {
+
+      public void read(org.apache.thrift.protocol.TProtocol iprot, controllerServerList_result struct) throws org.apache.thrift.TException {
+        org.apache.thrift.protocol.TField schemeField;
+        iprot.readStructBegin();
+        while (true)
+        {
+          schemeField = iprot.readFieldBegin();
+          if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
+            break;
+          }
+          switch (schemeField.id) {
+            case 0: // SUCCESS
+              if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+                {
+                  org.apache.thrift.protocol.TList _list192 = iprot.readListBegin();
+                  struct.success = new ArrayList<String>(_list192.size);
+                  for (int _i193 = 0; _i193 < _list192.size; ++_i193)
+                  {
+                    String _elem194; // required
+                    _elem194 = iprot.readString();
+                    struct.success.add(_elem194);
+                  }
+                  iprot.readListEnd();
+                }
+                struct.setSuccessIsSet(true);
+              } else { 
+                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
+            case 1: // EX
+              if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+                struct.ex = new BlurException();
+                struct.ex.read(iprot);
+                struct.setExIsSet(true);
+              } else { 
+                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
+            default:
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+          }
+          iprot.readFieldEnd();
+        }
+        iprot.readStructEnd();
+
+        // check for required fields of primitive type, which can't be checked in the validate method
+        struct.validate();
+      }
+
+      public void write(org.apache.thrift.protocol.TProtocol oprot, controllerServerList_result struct) throws org.apache.thrift.TException {
+        struct.validate();
+
+        oprot.writeStructBegin(STRUCT_DESC);
+        if (struct.success != null) {
+          oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+          {
+            oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.success.size()));
+            for (String _iter195 : struct.success)
+            {
+              oprot.writeString(_iter195);
+            }
+            oprot.writeListEnd();
+          }
+          oprot.writeFieldEnd();
+        }
+        if (struct.ex != null) {
+          oprot.writeFieldBegin(EX_FIELD_DESC);
+          struct.ex.write(oprot);
+          oprot.writeFieldEnd();
+        }
+        oprot.writeFieldStop();
+        oprot.writeStructEnd();
+      }
+
+    }
+
+    private static class controllerServerList_resultTupleSchemeFactory implements SchemeFactory {
+      public controllerServerList_resultTupleScheme getScheme() {
+        return new controllerServerList_resultTupleScheme();
+      }
+    }
+
+    private static class controllerServerList_resultTupleScheme extends TupleScheme<controllerServerList_result> {
+
+      @Override
+      public void write(org.apache.thrift.protocol.TProtocol prot, controllerServerList_result struct) throws org.apache.thrift.TException {
+        TTupleProtocol oprot = (TTupleProtocol) prot;
+        BitSet optionals = new BitSet();
+        if (struct.isSetSuccess()) {
+          optionals.set(0);
+        }
+        if (struct.isSetEx()) {
+          optionals.set(1);
+        }
+        oprot.writeBitSet(optionals, 2);
+        if (struct.isSetSuccess()) {
+          {
+            oprot.writeI32(struct.success.size());
+            for (String _iter196 : struct.success)
+            {
+              oprot.writeString(_iter196);
+            }
+          }
+        }
+        if (struct.isSetEx()) {
+          struct.ex.write(oprot);
+        }
+      }
+
+      @Override
+      public void read(org.apache.thrift.protocol.TProtocol prot, controllerServerList_result struct) throws org.apache.thrift.TException {
+        TTupleProtocol iprot = (TTupleProtocol) prot;
+        BitSet incoming = iprot.readBitSet(2);
+        if (incoming.get(0)) {
+          {
+            org.apache.thrift.protocol.TList _list197 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+            struct.success = new ArrayList<String>(_list197.size);
+            for (int _i198 = 0; _i198 < _list197.size; ++_i198)
+            {
+              String _elem199; // required
+              _elem199 = iprot.readString();
+              struct.success.add(_elem199);
+            }
+          }
+          struct.setSuccessIsSet(true);
+        }
+        if (incoming.get(1)) {
+          struct.ex = new BlurException();
+          struct.ex.read(iprot);
+          struct.setExIsSet(true);
+        }
+      }
+    }
+
   }
 
   public static class shardServerLayout_args implements org.apache.thrift.TBase<shardServerLayout_args, shardServerLayout_args._Fields>, java.io.Serializable, Cloneable   {
@@ -4404,6 +4925,12 @@ public class Blur {
 
     private static final org.apache.thrift.protocol.TField TABLE_FIELD_DESC = new org.apache.thrift.protocol.TField("table", org.apache.thrift.protocol.TType.STRING, (short)1);
 
+    private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+    static {
+      schemes.put(StandardScheme.class, new shardServerLayout_argsStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new shardServerLayout_argsTupleSchemeFactory());
+    }
+
     public String table; // required
 
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
@@ -4465,7 +4992,6 @@ public class Blur {
     }
 
     // isset id assignments
-
     public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
     static {
       Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -4618,44 +5144,11 @@ public class Blur {
     }
 
     public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
-      org.apache.thrift.protocol.TField field;
-      iprot.readStructBegin();
-      while (true)
-      {
-        field = iprot.readFieldBegin();
-        if (field.type == org.apache.thrift.protocol.TType.STOP) { 
-          break;
-        }
-        switch (field.id) {
-          case 1: // TABLE
-            if (field.type == org.apache.thrift.protocol.TType.STRING) {
-              this.table = iprot.readString();
-            } else { 
-              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-            }
-            break;
-          default:
-            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-        }
-        iprot.readFieldEnd();
-      }
-      iprot.readStructEnd();
-
-      // check for required fields of primitive type, which can't be checked in the validate method
-      validate();
+      schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
     }
 
     public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
-      validate();
-
-      oprot.writeStructBegin(STRUCT_DESC);
-      if (this.table != null) {
-        oprot.writeFieldBegin(TABLE_FIELD_DESC);
-        oprot.writeString(this.table);
-        oprot.writeFieldEnd();
-      }
-      oprot.writeFieldStop();
-      oprot.writeStructEnd();
+      schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
     }
 
     @Override
@@ -4676,6 +5169,7 @@ public class Blur {
 
     public void validate() throws org.apache.thrift.TException {
       // check for required fields
+      // check for sub-struct validity
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -4694,6 +5188,90 @@ public class Blur {
       }
     }
 
+    private static class shardServerLayout_argsStandardSchemeFactory implements SchemeFactory {
+      public shardServerLayout_argsStandardScheme getScheme() {
+        return new shardServerLayout_argsStandardScheme();
+      }
+    }
+
+    private static class shardServerLayout_argsStandardScheme extends StandardScheme<shardServerLayout_args> {
+
+      public void read(org.apache.thrift.protocol.TProtocol iprot, shardServerLayout_args struct) throws org.apache.thrift.TException {
+        org.apache.thrift.protocol.TField schemeField;
+        iprot.readStructBegin();
+        while (true)
+        {
+          schemeField = iprot.readFieldBegin();
+          if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
+            break;
+          }
+          switch (schemeField.id) {
+            case 1: // TABLE
+              if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+                struct.table = iprot.readString();
+                struct.setTableIsSet(true);
+              } else { 
+                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
+            default:
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+          }
+          iprot.readFieldEnd();
+        }
+        iprot.readStructEnd();
+
+        // check for required fields of primitive type, which can't be checked in the validate method
+        struct.validate();
+      }
+
+      public void write(org.apache.thrift.protocol.TProtocol oprot, shardServerLayout_args struct) throws org.apache.thrift.TException {
+        struct.validate();
+
+        oprot.writeStructBegin(STRUCT_DESC);
+        if (struct.table != null) {
+          oprot.writeFieldBegin(TABLE_FIELD_DESC);
+          oprot.writeString(struct.table);
+          oprot.writeFieldEnd();
+        }
+        oprot.writeFieldStop();
+        oprot.writeStructEnd();
+      }
+
+    }
+
+    private static class shardServerLayout_argsTupleSchemeFactory implements SchemeFactory {
+      public shardServerLayout_argsTupleScheme getScheme() {
+        return new shardServerLayout_argsTupleScheme();
+      }
+    }
+
+    private static class shardServerLayout_argsTupleScheme extends TupleScheme<shardServerLayout_args> {
+
+      @Override
+      public void write(org.apache.thrift.protocol.TProtocol prot, shardServerLayout_args struct) throws org.apache.thrift.TException {
+        TTupleProtocol oprot = (TTupleProtocol) prot;
+        BitSet optionals = new BitSet();
+        if (struct.isSetTable()) {
+          optionals.set(0);
+        }
+        oprot.writeBitSet(optionals, 1);
+        if (struct.isSetTable()) {
+          oprot.writeString(struct.table);
+        }
+      }
+
+      @Override
+      public void read(org.apache.thrift.protocol.TProtocol prot, shardServerLayout_args struct) throws org.apache.thrift.TException {
+        TTupleProtocol iprot = (TTupleProtocol) prot;
+        BitSet incoming = iprot.readBitSet(1);
+        if (incoming.get(0)) {
+          struct.table = iprot.readString();
+          struct.setTableIsSet(true);
+        }
+      }
+    }
+
   }
 
   public static class shardServerLayout_result implements org.apache.thrift.TBase<shardServerLayout_result, shardServerLayout_result._Fields>, java.io.Serializable, Cloneable   {
@@ -4702,6 +5280,12 @@ public class Blur {
     private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.MAP, (short)0);
     private static final org.apache.thrift.protocol.TField EX_FIELD_DESC = new org.apache.thrift.protocol.TField("ex", org.apache.thrift.protocol.TType.STRUCT, (short)1);
 
+    private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
+    static {
+      schemes.put(StandardScheme.class, new shardServerLayout_resultStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new shardServerLayout_resultTupleSchemeFactory());
+    }
+
     public Map<String,String> success; // required
     public BlurException ex; // required
 
@@ -4767,7 +5351,6 @@ public class Blur {
     }
 
     // isset id assignments
-
     public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
     static {
       Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
@@ -5009,76 +5592,12 @@ public class Blur {
     }
 
     public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
-      org.apache.thrift.protocol.TField field;
-      iprot.readStructBegin();
-      while (true)
-      {
-        field = iprot.readFieldBegin();
-        if (field.type == org.apache.thrift.protocol.TType.STOP) { 
-          break;
-        }
-        switch (field.id) {
-          case 0: // SUCCESS
-            if (field.type == org.apache.thrift.protocol.TType.MAP) {
-              {
-                org.apache.thrift.protocol.TMap _map95 = iprot.readMapBegin();
-                this.success = new HashMap<String,String>(2*_map95.size);
-                for (int _i96 = 0; _i96 < _map95.size; ++_i96)
-                {
-                  String _key97; // required
-                  String _val98; // required
-                  _key97 = iprot.readString();
-                  _val98 = iprot.readString();
-                  this.success.put(_key97, _val98);
-                }
-                iprot.readMapEnd();
-              }
-            } else { 
-              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-            }
-            break;
-          case 1: // EX
-            if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
-              this.ex = new BlurException();
-              this.ex.read(iprot);
-            } else { 
-              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-            }
-            break;
-          default:
-            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
-        }
-        iprot.readFieldEnd();
-      }
-      iprot.readStructEnd();
-
-      // check for required fields of primitive type, which can't be checked in the validate method
-      validate();
+      schemes.get(iprot.getScheme()).getScheme().read(iprot, this);
     }
 
     public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
-      oprot.writeStructBegin(STRUCT_DESC);
-
-      if (this.isSetSuccess()) {
-        oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
-        {
-          oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, this.success.size()));
-          for (Map.Entry<String, String> _iter99 : this.success.entrySet())
-          {
-            oprot.writeString(_iter99.getKey());
-            oprot.writeString(_iter99.getValue());
-          }
-          oprot.writeMapEnd();
-        }
-        oprot.writeFieldEnd();
-      } else if (this.isSetEx()) {
-        oprot.writeFieldBegin(EX_FIELD_DESC);
-        this.ex.write(oprot);
-        oprot.writeFieldEnd();
+      schemes.get(oprot.getScheme()).getScheme().write(oprot, this);
       }
-      oprot.writeFieldStop();
-      oprot.writeStructEnd();
-    }
 
     @Override
     public String toString() {
@@ -5106,6 +5625,7 @@ public class Blur {
 
     public void validate() throws org.apache.thrift.TException {
       // check for required fields
+      // check for sub-struct validity
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -5124,27 +5644,180 @@ public class Blur {
       }
     }
 
-  }
-
-  public static class tableList_args implements org.apache.thrift.TBase<tableList_args, tableList_args._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("tableList_args");
+    private static class shardServerLayout_resultStandardSchemeFactory implements SchemeFactory {
+      public shardServerLayout_resultStandardScheme getScheme() {
+        return new shardServerLayout_resultStandardScheme();
+      }
+    }
 
+    private static class shardServerLayout_resultStandardScheme extends StandardScheme<shardServerLayout_result> {
 
+      public void read(org.apache.thrift.protocol.TProtocol iprot, shardServerLayout_result struct) throws org.apache.thrift.TException {
+        org.apache.thrift.protocol.TField schemeField;
+        iprot.readStructBegin();
+        while (true)
+        {
+          schemeField = iprot.readFieldBegin();
+          if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { 
+            break;
+          }
+          switch (schemeField.id) {
+            case 0: // SUCCESS
+              if (schemeField.type == org.apache.thrift.protocol.TType.MAP) {
+                {
+                  org.apache.thrift.protocol.TMap _map200 = iprot.readMapBegin();
+                  struct.success = new HashMap<String,String>(2*_map200.size);
+                  for (int _i201 = 0; _i201 < _map200.size; ++_i201)
+                  {
+                    String _key202; // required
+                    String _val203; // optional
+                    _key202 = iprot.readString();
+                    _val203 = iprot.readString();
+                    struct.success.put(_key202, _val203);
+                  }
+                  iprot.readMapEnd();
+                }
+                struct.setSuccessIsSet(true);
+              } else { 
+                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
+            case 1: // EX
+              if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
+                struct.ex = new BlurException();
+                struct.ex.read(iprot);
+                struct.setExIsSet(true);
+              } else { 
+                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
+            default:
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+          }
+          iprot.readFieldEnd();
+        }
+        iprot.readStructEnd();
 
-    /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
-    public enum _Fields implements org.apache.thrift.TFieldIdEnum {
-;
+        // check for required fields of primitive type, which can't be checked in the validate method
+        struct.validate();
+      }
 
-      private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
+      public void write(org.apache.thrift.protocol.TProtocol oprot, shardServerLayout_result struct) throws org.apache.thrift.TException {
+        struct.validate();
 
-      static {
-        for (_Fields field : EnumSet.allOf(_Fields.class)) {
-          byName.put(field.getFieldName(), field);
+        oprot.writeStructBegin(STRUCT_DESC);
+        if (struct.success != null) {
+          oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+          {
+            oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.STRING, struct.success.size()));
+            for (Map.Entry<String, String> _iter204 : struct.success.entrySet())
+            {
+              oprot.writeString(_iter204.getKey());
+              oprot.writeString(_iter204.getValue());
+            }
+            oprot.writeMapEnd();
+          }
+          oprot.writeFieldEnd();
+        }
+        if (struct.ex != null) {
+          oprot.writeFieldBegin(EX_FIELD_DESC);
+          struct.ex.write(oprot);
+          oprot.writeFieldEnd();
         }
+        oprot.writeFieldStop();
+        oprot.writeStructEnd();
       }
 
-      /**
-       * Find the _Fields constant that matches fieldId, or null if its not found.
+    }
+
+    private static class shardServerLayout_resultTupleSchemeFactory implements SchemeFactory {
+      public shardServerLayout_resultTupleScheme getScheme() {
+        return new shardServerLayout_resultTupleScheme();
+      }
+    }
+
+    private static class shardServe

<TRUNCATED>

Mime
View raw message