incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [4/20] Generated the thrift code with new package names.
Date Mon, 03 Sep 2012 16:06:56 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/c9a4a8eb/interface/gen-java/com/nearinfinity/blur/thrift/generated/Blur.java
----------------------------------------------------------------------
diff --git a/interface/gen-java/com/nearinfinity/blur/thrift/generated/Blur.java b/interface/gen-java/com/nearinfinity/blur/thrift/generated/Blur.java
deleted file mode 100644
index 60a6f53..0000000
--- a/interface/gen-java/com/nearinfinity/blur/thrift/generated/Blur.java
+++ /dev/null
@@ -1,21343 +0,0 @@
-/**
- * Autogenerated by Thrift Compiler (0.7.0)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- */
-package com.nearinfinity.blur.thrift.generated;
-
-import java.util.List;
-import java.util.ArrayList;
-import java.util.Map;
-import java.util.HashMap;
-import java.util.EnumMap;
-import java.util.Set;
-import java.util.HashSet;
-import java.util.EnumSet;
-import java.util.Collections;
-import java.util.BitSet;
-import java.nio.ByteBuffer;
-import java.util.Arrays;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class Blur {
-
-  /**
-   * 
-   */
-  public interface Iface {
-
-    /**
-     * Returns a list of all the shard clusters.
-     */
-    public List<String> shardClusterList() throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Returns a list of all the shard servers for the given cluster.
-     * @param cluster the cluster name.
-     * 
-     * @param cluster
-     */
-    public List<String> shardServerList(String cluster) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Returns a list of all the controller servers.
-     */
-    public List<String> controllerServerList() throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Returns a map of the layout of the given table, where the key is the shard name and the value is the shard server.
-     * @param table the table name.
-     * 
-     * @param table
-     */
-    public Map<String,String> shardServerLayout(String table) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Returns a list of the table names across all shard clusters.
-     */
-    public List<String> tableList() throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Returns a list of the table names for the given cluster.
-     * @param cluster the cluster name.
-     * 
-     * @param cluster
-     */
-    public List<String> tableListByCluster(String cluster) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Returns a table descriptor for the given table.
-     * @param table the table name.
-     * 
-     * @param table
-     */
-    public TableDescriptor describe(String table) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Executes a query against a the given table and returns the results.  If this method is executed against a controller the results will contain the aggregated results from all the shards.  If this method is executed against a shard server the results will only contain aggregated results from the shards of the given table that are being served on the shard server, if any.
-     * @param table the table name.
-     * @param blurQuery the query to execute.
-     * 
-     * @param table
-     * @param blurQuery
-     */
-    public BlurResults query(String table, BlurQuery blurQuery) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Cancels a query that is executing against the given table with the given uuid.  Note, the cancel call maybe take some time for the query actually stops executing.
-     * @param table the table name.
-     * @param uuid the uuid of the query.
-     * 
-     * @param table
-     * @param uuid
-     */
-    public void cancelQuery(String table, long uuid) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * @deprecated This method should avoided, @see #queryStatusIdList and #queryStatusById.
-     * @param table the table name.
-     * 
-     * @param table
-     */
-    public List<BlurQueryStatus> currentQueries(String table) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Returns a list of the query ids of queries that have recently been executed for the given table.
-     * @param table the table name.
-     * 
-     * @param table
-     */
-    public List<Long> queryStatusIdList(String table) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Returns the query status for the given table and query uuid.
-     * @param table the table name.
-     * @param uuid the uuid of the query.
-     * 
-     * @param table
-     * @param uuid
-     */
-    public BlurQueryStatus queryStatusById(String table, long uuid) throws BlurException, org.apache.thrift.TException;
-
-    public Schema schema(String table) throws BlurException, org.apache.thrift.TException;
-
-    public TableStats getTableStats(String table) throws BlurException, org.apache.thrift.TException;
-
-    public TableStats tableStats(String table) throws BlurException, org.apache.thrift.TException;
-
-    public List<String> terms(String table, String columnFamily, String columnName, String startWith, short size) throws BlurException, org.apache.thrift.TException;
-
-    public long recordFrequency(String table, String columnFamily, String columnName, String value) throws BlurException, org.apache.thrift.TException;
-
-    public FetchResult fetchRow(String table, Selector selector) throws BlurException, org.apache.thrift.TException;
-
-    public void mutate(RowMutation mutation) throws BlurException, org.apache.thrift.TException;
-
-    public void mutateBatch(List<RowMutation> mutations) throws BlurException, org.apache.thrift.TException;
-
-    public void createTable(TableDescriptor tableDescriptor) throws BlurException, org.apache.thrift.TException;
-
-    public void enableTable(String table) throws BlurException, org.apache.thrift.TException;
-
-    public void disableTable(String table) throws BlurException, org.apache.thrift.TException;
-
-    public void removeTable(String table, boolean deleteIndexFiles) throws BlurException, org.apache.thrift.TException;
-
-    public void optimize(String table, int numberOfSegmentsPerShard) throws BlurException, org.apache.thrift.TException;
-
-    public boolean isInSafeMode(String cluster) throws BlurException, org.apache.thrift.TException;
-
-    public Map<String,String> configuration() throws BlurException, org.apache.thrift.TException;
-
-  }
-
-  public interface AsyncIface {
-
-    public void shardClusterList(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.shardClusterList_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void shardServerList(String cluster, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.shardServerList_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void controllerServerList(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.controllerServerList_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void shardServerLayout(String table, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.shardServerLayout_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void tableList(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.tableList_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void tableListByCluster(String cluster, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.tableListByCluster_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void describe(String table, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.describe_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void query(String table, BlurQuery blurQuery, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.query_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void cancelQuery(String table, long uuid, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.cancelQuery_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void currentQueries(String table, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.currentQueries_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void queryStatusIdList(String table, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.queryStatusIdList_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void queryStatusById(String table, long uuid, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.queryStatusById_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void schema(String table, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.schema_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void getTableStats(String table, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getTableStats_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void tableStats(String table, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.tableStats_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void terms(String table, String columnFamily, String columnName, String startWith, short size, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.terms_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void recordFrequency(String table, String columnFamily, String columnName, String value, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.recordFrequency_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void fetchRow(String table, Selector selector, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.fetchRow_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void mutate(RowMutation mutation, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.mutate_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void mutateBatch(List<RowMutation> mutations, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.mutateBatch_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void createTable(TableDescriptor tableDescriptor, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.createTable_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void enableTable(String table, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.enableTable_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void disableTable(String table, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.disableTable_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void removeTable(String table, boolean deleteIndexFiles, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.removeTable_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void optimize(String table, int numberOfSegmentsPerShard, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.optimize_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void isInSafeMode(String cluster, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.isInSafeMode_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void configuration(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.configuration_call> resultHandler) throws org.apache.thrift.TException;
-
-  }
-
-  public static class Client extends org.apache.thrift.TServiceClient implements Iface {
-    public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> {
-      public Factory() {}
-      public Client getClient(org.apache.thrift.protocol.TProtocol prot) {
-        return new Client(prot);
-      }
-      public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
-        return new Client(iprot, oprot);
-      }
-    }
-
-    public Client(org.apache.thrift.protocol.TProtocol prot)
-    {
-      super(prot, prot);
-    }
-
-    public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
-      super(iprot, oprot);
-    }
-
-    public List<String> shardClusterList() throws BlurException, org.apache.thrift.TException
-    {
-      send_shardClusterList();
-      return recv_shardClusterList();
-    }
-
-    public void send_shardClusterList() throws org.apache.thrift.TException
-    {
-      shardClusterList_args args = new shardClusterList_args();
-      sendBase("shardClusterList", args);
-    }
-
-    public List<String> recv_shardClusterList() throws BlurException, org.apache.thrift.TException
-    {
-      shardClusterList_result result = new shardClusterList_result();
-      receiveBase(result, "shardClusterList");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "shardClusterList failed: unknown result");
-    }
-
-    public List<String> shardServerList(String cluster) throws BlurException, org.apache.thrift.TException
-    {
-      send_shardServerList(cluster);
-      return recv_shardServerList();
-    }
-
-    public void send_shardServerList(String cluster) throws org.apache.thrift.TException
-    {
-      shardServerList_args args = new shardServerList_args();
-      args.setCluster(cluster);
-      sendBase("shardServerList", args);
-    }
-
-    public List<String> recv_shardServerList() throws BlurException, org.apache.thrift.TException
-    {
-      shardServerList_result result = new shardServerList_result();
-      receiveBase(result, "shardServerList");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "shardServerList failed: unknown result");
-    }
-
-    public List<String> controllerServerList() throws BlurException, org.apache.thrift.TException
-    {
-      send_controllerServerList();
-      return recv_controllerServerList();
-    }
-
-    public void send_controllerServerList() throws org.apache.thrift.TException
-    {
-      controllerServerList_args args = new controllerServerList_args();
-      sendBase("controllerServerList", args);
-    }
-
-    public List<String> recv_controllerServerList() throws BlurException, org.apache.thrift.TException
-    {
-      controllerServerList_result result = new controllerServerList_result();
-      receiveBase(result, "controllerServerList");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "controllerServerList failed: unknown result");
-    }
-
-    public Map<String,String> shardServerLayout(String table) throws BlurException, org.apache.thrift.TException
-    {
-      send_shardServerLayout(table);
-      return recv_shardServerLayout();
-    }
-
-    public void send_shardServerLayout(String table) throws org.apache.thrift.TException
-    {
-      shardServerLayout_args args = new shardServerLayout_args();
-      args.setTable(table);
-      sendBase("shardServerLayout", args);
-    }
-
-    public Map<String,String> recv_shardServerLayout() throws BlurException, org.apache.thrift.TException
-    {
-      shardServerLayout_result result = new shardServerLayout_result();
-      receiveBase(result, "shardServerLayout");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "shardServerLayout failed: unknown result");
-    }
-
-    public List<String> tableList() throws BlurException, org.apache.thrift.TException
-    {
-      send_tableList();
-      return recv_tableList();
-    }
-
-    public void send_tableList() throws org.apache.thrift.TException
-    {
-      tableList_args args = new tableList_args();
-      sendBase("tableList", args);
-    }
-
-    public List<String> recv_tableList() throws BlurException, org.apache.thrift.TException
-    {
-      tableList_result result = new tableList_result();
-      receiveBase(result, "tableList");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "tableList failed: unknown result");
-    }
-
-    public List<String> tableListByCluster(String cluster) throws BlurException, org.apache.thrift.TException
-    {
-      send_tableListByCluster(cluster);
-      return recv_tableListByCluster();
-    }
-
-    public void send_tableListByCluster(String cluster) throws org.apache.thrift.TException
-    {
-      tableListByCluster_args args = new tableListByCluster_args();
-      args.setCluster(cluster);
-      sendBase("tableListByCluster", args);
-    }
-
-    public List<String> recv_tableListByCluster() throws BlurException, org.apache.thrift.TException
-    {
-      tableListByCluster_result result = new tableListByCluster_result();
-      receiveBase(result, "tableListByCluster");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "tableListByCluster failed: unknown result");
-    }
-
-    public TableDescriptor describe(String table) throws BlurException, org.apache.thrift.TException
-    {
-      send_describe(table);
-      return recv_describe();
-    }
-
-    public void send_describe(String table) throws org.apache.thrift.TException
-    {
-      describe_args args = new describe_args();
-      args.setTable(table);
-      sendBase("describe", args);
-    }
-
-    public TableDescriptor recv_describe() throws BlurException, org.apache.thrift.TException
-    {
-      describe_result result = new describe_result();
-      receiveBase(result, "describe");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "describe failed: unknown result");
-    }
-
-    public BlurResults query(String table, BlurQuery blurQuery) throws BlurException, org.apache.thrift.TException
-    {
-      send_query(table, blurQuery);
-      return recv_query();
-    }
-
-    public void send_query(String table, BlurQuery blurQuery) throws org.apache.thrift.TException
-    {
-      query_args args = new query_args();
-      args.setTable(table);
-      args.setBlurQuery(blurQuery);
-      sendBase("query", args);
-    }
-
-    public BlurResults recv_query() throws BlurException, org.apache.thrift.TException
-    {
-      query_result result = new query_result();
-      receiveBase(result, "query");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "query failed: unknown result");
-    }
-
-    public void cancelQuery(String table, long uuid) throws BlurException, org.apache.thrift.TException
-    {
-      send_cancelQuery(table, uuid);
-      recv_cancelQuery();
-    }
-
-    public void send_cancelQuery(String table, long uuid) throws org.apache.thrift.TException
-    {
-      cancelQuery_args args = new cancelQuery_args();
-      args.setTable(table);
-      args.setUuid(uuid);
-      sendBase("cancelQuery", args);
-    }
-
-    public void recv_cancelQuery() throws BlurException, org.apache.thrift.TException
-    {
-      cancelQuery_result result = new cancelQuery_result();
-      receiveBase(result, "cancelQuery");
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      return;
-    }
-
-    public List<BlurQueryStatus> currentQueries(String table) throws BlurException, org.apache.thrift.TException
-    {
-      send_currentQueries(table);
-      return recv_currentQueries();
-    }
-
-    public void send_currentQueries(String table) throws org.apache.thrift.TException
-    {
-      currentQueries_args args = new currentQueries_args();
-      args.setTable(table);
-      sendBase("currentQueries", args);
-    }
-
-    public List<BlurQueryStatus> recv_currentQueries() throws BlurException, org.apache.thrift.TException
-    {
-      currentQueries_result result = new currentQueries_result();
-      receiveBase(result, "currentQueries");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "currentQueries failed: unknown result");
-    }
-
-    public List<Long> queryStatusIdList(String table) throws BlurException, org.apache.thrift.TException
-    {
-      send_queryStatusIdList(table);
-      return recv_queryStatusIdList();
-    }
-
-    public void send_queryStatusIdList(String table) throws org.apache.thrift.TException
-    {
-      queryStatusIdList_args args = new queryStatusIdList_args();
-      args.setTable(table);
-      sendBase("queryStatusIdList", args);
-    }
-
-    public List<Long> recv_queryStatusIdList() throws BlurException, org.apache.thrift.TException
-    {
-      queryStatusIdList_result result = new queryStatusIdList_result();
-      receiveBase(result, "queryStatusIdList");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "queryStatusIdList failed: unknown result");
-    }
-
-    public BlurQueryStatus queryStatusById(String table, long uuid) throws BlurException, org.apache.thrift.TException
-    {
-      send_queryStatusById(table, uuid);
-      return recv_queryStatusById();
-    }
-
-    public void send_queryStatusById(String table, long uuid) throws org.apache.thrift.TException
-    {
-      queryStatusById_args args = new queryStatusById_args();
-      args.setTable(table);
-      args.setUuid(uuid);
-      sendBase("queryStatusById", args);
-    }
-
-    public BlurQueryStatus recv_queryStatusById() throws BlurException, org.apache.thrift.TException
-    {
-      queryStatusById_result result = new queryStatusById_result();
-      receiveBase(result, "queryStatusById");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "queryStatusById failed: unknown result");
-    }
-
-    public Schema schema(String table) throws BlurException, org.apache.thrift.TException
-    {
-      send_schema(table);
-      return recv_schema();
-    }
-
-    public void send_schema(String table) throws org.apache.thrift.TException
-    {
-      schema_args args = new schema_args();
-      args.setTable(table);
-      sendBase("schema", args);
-    }
-
-    public Schema recv_schema() throws BlurException, org.apache.thrift.TException
-    {
-      schema_result result = new schema_result();
-      receiveBase(result, "schema");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "schema failed: unknown result");
-    }
-
-    public TableStats getTableStats(String table) throws BlurException, org.apache.thrift.TException
-    {
-      send_getTableStats(table);
-      return recv_getTableStats();
-    }
-
-    public void send_getTableStats(String table) throws org.apache.thrift.TException
-    {
-      getTableStats_args args = new getTableStats_args();
-      args.setTable(table);
-      sendBase("getTableStats", args);
-    }
-
-    public TableStats recv_getTableStats() throws BlurException, org.apache.thrift.TException
-    {
-      getTableStats_result result = new getTableStats_result();
-      receiveBase(result, "getTableStats");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getTableStats failed: unknown result");
-    }
-
-    public TableStats tableStats(String table) throws BlurException, org.apache.thrift.TException
-    {
-      send_tableStats(table);
-      return recv_tableStats();
-    }
-
-    public void send_tableStats(String table) throws org.apache.thrift.TException
-    {
-      tableStats_args args = new tableStats_args();
-      args.setTable(table);
-      sendBase("tableStats", args);
-    }
-
-    public TableStats recv_tableStats() throws BlurException, org.apache.thrift.TException
-    {
-      tableStats_result result = new tableStats_result();
-      receiveBase(result, "tableStats");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "tableStats failed: unknown result");
-    }
-
-    public List<String> terms(String table, String columnFamily, String columnName, String startWith, short size) throws BlurException, org.apache.thrift.TException
-    {
-      send_terms(table, columnFamily, columnName, startWith, size);
-      return recv_terms();
-    }
-
-    public void send_terms(String table, String columnFamily, String columnName, String startWith, short size) throws org.apache.thrift.TException
-    {
-      terms_args args = new terms_args();
-      args.setTable(table);
-      args.setColumnFamily(columnFamily);
-      args.setColumnName(columnName);
-      args.setStartWith(startWith);
-      args.setSize(size);
-      sendBase("terms", args);
-    }
-
-    public List<String> recv_terms() throws BlurException, org.apache.thrift.TException
-    {
-      terms_result result = new terms_result();
-      receiveBase(result, "terms");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "terms failed: unknown result");
-    }
-
-    public long recordFrequency(String table, String columnFamily, String columnName, String value) throws BlurException, org.apache.thrift.TException
-    {
-      send_recordFrequency(table, columnFamily, columnName, value);
-      return recv_recordFrequency();
-    }
-
-    public void send_recordFrequency(String table, String columnFamily, String columnName, String value) throws org.apache.thrift.TException
-    {
-      recordFrequency_args args = new recordFrequency_args();
-      args.setTable(table);
-      args.setColumnFamily(columnFamily);
-      args.setColumnName(columnName);
-      args.setValue(value);
-      sendBase("recordFrequency", args);
-    }
-
-    public long recv_recordFrequency() throws BlurException, org.apache.thrift.TException
-    {
-      recordFrequency_result result = new recordFrequency_result();
-      receiveBase(result, "recordFrequency");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "recordFrequency failed: unknown result");
-    }
-
-    public FetchResult fetchRow(String table, Selector selector) throws BlurException, org.apache.thrift.TException
-    {
-      send_fetchRow(table, selector);
-      return recv_fetchRow();
-    }
-
-    public void send_fetchRow(String table, Selector selector) throws org.apache.thrift.TException
-    {
-      fetchRow_args args = new fetchRow_args();
-      args.setTable(table);
-      args.setSelector(selector);
-      sendBase("fetchRow", args);
-    }
-
-    public FetchResult recv_fetchRow() throws BlurException, org.apache.thrift.TException
-    {
-      fetchRow_result result = new fetchRow_result();
-      receiveBase(result, "fetchRow");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "fetchRow failed: unknown result");
-    }
-
-    public void mutate(RowMutation mutation) throws BlurException, org.apache.thrift.TException
-    {
-      send_mutate(mutation);
-      recv_mutate();
-    }
-
-    public void send_mutate(RowMutation mutation) throws org.apache.thrift.TException
-    {
-      mutate_args args = new mutate_args();
-      args.setMutation(mutation);
-      sendBase("mutate", args);
-    }
-
-    public void recv_mutate() throws BlurException, org.apache.thrift.TException
-    {
-      mutate_result result = new mutate_result();
-      receiveBase(result, "mutate");
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      return;
-    }
-
-    public void mutateBatch(List<RowMutation> mutations) throws BlurException, org.apache.thrift.TException
-    {
-      send_mutateBatch(mutations);
-      recv_mutateBatch();
-    }
-
-    public void send_mutateBatch(List<RowMutation> mutations) throws org.apache.thrift.TException
-    {
-      mutateBatch_args args = new mutateBatch_args();
-      args.setMutations(mutations);
-      sendBase("mutateBatch", args);
-    }
-
-    public void recv_mutateBatch() throws BlurException, org.apache.thrift.TException
-    {
-      mutateBatch_result result = new mutateBatch_result();
-      receiveBase(result, "mutateBatch");
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      return;
-    }
-
-    public void createTable(TableDescriptor tableDescriptor) throws BlurException, org.apache.thrift.TException
-    {
-      send_createTable(tableDescriptor);
-      recv_createTable();
-    }
-
-    public void send_createTable(TableDescriptor tableDescriptor) throws org.apache.thrift.TException
-    {
-      createTable_args args = new createTable_args();
-      args.setTableDescriptor(tableDescriptor);
-      sendBase("createTable", args);
-    }
-
-    public void recv_createTable() throws BlurException, org.apache.thrift.TException
-    {
-      createTable_result result = new createTable_result();
-      receiveBase(result, "createTable");
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      return;
-    }
-
-    public void enableTable(String table) throws BlurException, org.apache.thrift.TException
-    {
-      send_enableTable(table);
-      recv_enableTable();
-    }
-
-    public void send_enableTable(String table) throws org.apache.thrift.TException
-    {
-      enableTable_args args = new enableTable_args();
-      args.setTable(table);
-      sendBase("enableTable", args);
-    }
-
-    public void recv_enableTable() throws BlurException, org.apache.thrift.TException
-    {
-      enableTable_result result = new enableTable_result();
-      receiveBase(result, "enableTable");
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      return;
-    }
-
-    public void disableTable(String table) throws BlurException, org.apache.thrift.TException
-    {
-      send_disableTable(table);
-      recv_disableTable();
-    }
-
-    public void send_disableTable(String table) throws org.apache.thrift.TException
-    {
-      disableTable_args args = new disableTable_args();
-      args.setTable(table);
-      sendBase("disableTable", args);
-    }
-
-    public void recv_disableTable() throws BlurException, org.apache.thrift.TException
-    {
-      disableTable_result result = new disableTable_result();
-      receiveBase(result, "disableTable");
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      return;
-    }
-
-    public void removeTable(String table, boolean deleteIndexFiles) throws BlurException, org.apache.thrift.TException
-    {
-      send_removeTable(table, deleteIndexFiles);
-      recv_removeTable();
-    }
-
-    public void send_removeTable(String table, boolean deleteIndexFiles) throws org.apache.thrift.TException
-    {
-      removeTable_args args = new removeTable_args();
-      args.setTable(table);
-      args.setDeleteIndexFiles(deleteIndexFiles);
-      sendBase("removeTable", args);
-    }
-
-    public void recv_removeTable() throws BlurException, org.apache.thrift.TException
-    {
-      removeTable_result result = new removeTable_result();
-      receiveBase(result, "removeTable");
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      return;
-    }
-
-    public void optimize(String table, int numberOfSegmentsPerShard) throws BlurException, org.apache.thrift.TException
-    {
-      send_optimize(table, numberOfSegmentsPerShard);
-      recv_optimize();
-    }
-
-    public void send_optimize(String table, int numberOfSegmentsPerShard) throws org.apache.thrift.TException
-    {
-      optimize_args args = new optimize_args();
-      args.setTable(table);
-      args.setNumberOfSegmentsPerShard(numberOfSegmentsPerShard);
-      sendBase("optimize", args);
-    }
-
-    public void recv_optimize() throws BlurException, org.apache.thrift.TException
-    {
-      optimize_result result = new optimize_result();
-      receiveBase(result, "optimize");
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      return;
-    }
-
-    public boolean isInSafeMode(String cluster) throws BlurException, org.apache.thrift.TException
-    {
-      send_isInSafeMode(cluster);
-      return recv_isInSafeMode();
-    }
-
-    public void send_isInSafeMode(String cluster) throws org.apache.thrift.TException
-    {
-      isInSafeMode_args args = new isInSafeMode_args();
-      args.setCluster(cluster);
-      sendBase("isInSafeMode", args);
-    }
-
-    public boolean recv_isInSafeMode() throws BlurException, org.apache.thrift.TException
-    {
-      isInSafeMode_result result = new isInSafeMode_result();
-      receiveBase(result, "isInSafeMode");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "isInSafeMode failed: unknown result");
-    }
-
-    public Map<String,String> configuration() throws BlurException, org.apache.thrift.TException
-    {
-      send_configuration();
-      return recv_configuration();
-    }
-
-    public void send_configuration() throws org.apache.thrift.TException
-    {
-      configuration_args args = new configuration_args();
-      sendBase("configuration", args);
-    }
-
-    public Map<String,String> recv_configuration() throws BlurException, org.apache.thrift.TException
-    {
-      configuration_result result = new configuration_result();
-      receiveBase(result, "configuration");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.ex != null) {
-        throw result.ex;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "configuration failed: unknown result");
-    }
-
-  }
-  public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface {
-    public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {
-      private org.apache.thrift.async.TAsyncClientManager clientManager;
-      private org.apache.thrift.protocol.TProtocolFactory protocolFactory;
-      public Factory(org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) {
-        this.clientManager = clientManager;
-        this.protocolFactory = protocolFactory;
-      }
-      public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) {
-        return new AsyncClient(protocolFactory, clientManager, transport);
-      }
-    }
-
-    public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) {
-      super(protocolFactory, clientManager, transport);
-    }
-
-    public void shardClusterList(org.apache.thrift.async.AsyncMethodCallback<shardClusterList_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      shardClusterList_call method_call = new shardClusterList_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class shardClusterList_call extends org.apache.thrift.async.TAsyncMethodCall {
-      public shardClusterList_call(org.apache.thrift.async.AsyncMethodCallback<shardClusterList_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("shardClusterList", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        shardClusterList_args args = new shardClusterList_args();
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public List<String> getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_shardClusterList();
-      }
-    }
-
-    public void shardServerList(String cluster, org.apache.thrift.async.AsyncMethodCallback<shardServerList_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      shardServerList_call method_call = new shardServerList_call(cluster, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class shardServerList_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String cluster;
-      public shardServerList_call(String cluster, org.apache.thrift.async.AsyncMethodCallback<shardServerList_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.cluster = cluster;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("shardServerList", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        shardServerList_args args = new shardServerList_args();
-        args.setCluster(cluster);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public List<String> getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_shardServerList();
-      }
-    }
-
-    public void controllerServerList(org.apache.thrift.async.AsyncMethodCallback<controllerServerList_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      controllerServerList_call method_call = new controllerServerList_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class controllerServerList_call extends org.apache.thrift.async.TAsyncMethodCall {
-      public controllerServerList_call(org.apache.thrift.async.AsyncMethodCallback<controllerServerList_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("controllerServerList", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        controllerServerList_args args = new controllerServerList_args();
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public List<String> getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_controllerServerList();
-      }
-    }
-
-    public void shardServerLayout(String table, org.apache.thrift.async.AsyncMethodCallback<shardServerLayout_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      shardServerLayout_call method_call = new shardServerLayout_call(table, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class shardServerLayout_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      public shardServerLayout_call(String table, org.apache.thrift.async.AsyncMethodCallback<shardServerLayout_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.table = table;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("shardServerLayout", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        shardServerLayout_args args = new shardServerLayout_args();
-        args.setTable(table);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Map<String,String> getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_shardServerLayout();
-      }
-    }
-
-    public void tableList(org.apache.thrift.async.AsyncMethodCallback<tableList_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      tableList_call method_call = new tableList_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class tableList_call extends org.apache.thrift.async.TAsyncMethodCall {
-      public tableList_call(org.apache.thrift.async.AsyncMethodCallback<tableList_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("tableList", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        tableList_args args = new tableList_args();
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public List<String> getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_tableList();
-      }
-    }
-
-    public void tableListByCluster(String cluster, org.apache.thrift.async.AsyncMethodCallback<tableListByCluster_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      tableListByCluster_call method_call = new tableListByCluster_call(cluster, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class tableListByCluster_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String cluster;
-      public tableListByCluster_call(String cluster, org.apache.thrift.async.AsyncMethodCallback<tableListByCluster_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.cluster = cluster;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("tableListByCluster", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        tableListByCluster_args args = new tableListByCluster_args();
-        args.setCluster(cluster);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public List<String> getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_tableListByCluster();
-      }
-    }
-
-    public void describe(String table, org.apache.thrift.async.AsyncMethodCallback<describe_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      describe_call method_call = new describe_call(table, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class describe_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      public describe_call(String table, org.apache.thrift.async.AsyncMethodCallback<describe_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.table = table;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("describe", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        describe_args args = new describe_args();
-        args.setTable(table);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public TableDescriptor getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_describe();
-      }
-    }
-
-    public void query(String table, BlurQuery blurQuery, org.apache.thrift.async.AsyncMethodCallback<query_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      query_call method_call = new query_call(table, blurQuery, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class query_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      private BlurQuery blurQuery;
-      public query_call(String table, BlurQuery blurQuery, org.apache.thrift.async.AsyncMethodCallback<query_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.table = table;
-        this.blurQuery = blurQuery;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("query", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        query_args args = new query_args();
-        args.setTable(table);
-        args.setBlurQuery(blurQuery);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public BlurResults getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_query();
-      }
-    }
-
-    public void cancelQuery(String table, long uuid, org.apache.thrift.async.AsyncMethodCallback<cancelQuery_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      cancelQuery_call method_call = new cancelQuery_call(table, uuid, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class cancelQuery_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      private long uuid;
-      public cancelQuery_call(String table, long uuid, org.apache.thrift.async.AsyncMethodCallback<cancelQuery_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.table = table;
-        this.uuid = uuid;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("cancelQuery", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        cancelQuery_args args = new cancelQuery_args();
-        args.setTable(table);
-        args.setUuid(uuid);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_cancelQuery();
-      }
-    }
-
-    public void currentQueries(String table, org.apache.thrift.async.AsyncMethodCallback<currentQueries_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      currentQueries_call method_call = new currentQueries_call(table, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class currentQueries_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      public currentQueries_call(String table, org.apache.thrift.async.AsyncMethodCallback<currentQueries_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.table = table;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("currentQueries", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        currentQueries_args args = new currentQueries_args();
-        args.setTable(table);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public List<BlurQueryStatus> getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_currentQueries();
-      }
-    }
-
-    public void queryStatusIdList(String table, org.apache.thrift.async.AsyncMethodCallback<queryStatusIdList_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      queryStatusIdList_call method_call = new queryStatusIdList_call(table, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class queryStatusIdList_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      public queryStatusIdList_call(String table, org.apache.thrift.async.AsyncMethodCallback<queryStatusIdList_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.table = table;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("queryStatusIdList", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        queryStatusIdList_args args = new queryStatusIdList_args();
-        args.setTable(table);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public List<Long> getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_queryStatusIdList();
-      }
-    }
-
-    public void queryStatusById(String table, long uuid, org.apache.thrift.async.AsyncMethodCallback<queryStatusById_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      queryStatusById_call method_call = new queryStatusById_call(table, uuid, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class queryStatusById_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      private long uuid;
-      public queryStatusById_call(String table, long uuid, org.apache.thrift.async.AsyncMethodCallback<queryStatusById_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.table = table;
-        this.uuid = uuid;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("queryStatusById", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        queryStatusById_args args = new queryStatusById_args();
-        args.setTable(table);
-        args.setUuid(uuid);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public BlurQueryStatus getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_queryStatusById();
-      }
-    }
-
-    public void schema(String table, org.apache.thrift.async.AsyncMethodCallback<schema_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      schema_call method_call = new schema_call(table, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class schema_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      public schema_call(String table, org.apache.thrift.async.AsyncMethodCallback<schema_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.table = table;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("schema", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        schema_args args = new schema_args();
-        args.setTable(table);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Schema getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_schema();
-      }
-    }
-
-    public void getTableStats(String table, org.apache.thrift.async.AsyncMethodCallback<getTableStats_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      getTableStats_call method_call = new getTableStats_call(table, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class getTableStats_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      public getTableStats_call(String table, org.apache.thrift.async.AsyncMethodCallback<getTableStats_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.table = table;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getTableStats", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        getTableStats_args args = new getTableStats_args();
-        args.setTable(table);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public TableStats getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_getTableStats();
-      }
-    }
-
-    public void tableStats(String table, org.apache.thrift.async.AsyncMethodCallback<tableStats_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      tableStats_call method_call = new tableStats_call(table, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class tableStats_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      public tableStats_call(String table, org.apache.thrift.async.AsyncMethodCallback<tableStats_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.table = table;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("tableStats", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        tableStats_args args = new tableStats_args();
-        args.setTable(table);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public TableStats getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_tableStats();
-      }
-    }
-
-    public void terms(String table, String columnFamily, String columnName, String startWith, short size, org.apache.thrift.async.AsyncMethodCallback<terms_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      terms_call method_call = new terms_call(table, columnFamily, columnName, startWith, size, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class terms_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      private String columnFamily;
-      private String columnName;
-      private String startWith;
-      private short size;
-      public terms_call(String table, String columnFamily, String columnName, String startWith, short size, org.apache.thrift.async.AsyncMethodCallback<terms_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.table = table;
-        this.columnFamily = columnFamily;
-        this.columnName = columnName;
-        this.startWith = startWith;
-        this.size = size;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("terms", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        terms_args args = new terms_args();
-        args.setTable(table);
-        args.setColumnFamily(columnFamily);
-        args.setColumnName(columnName);
-        args.setStartWith(startWith);
-        args.setSize(size);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public List<String> getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_terms();
-      }
-    }
-
-    public void recordFrequency(String table, String columnFamily, String columnName, String value, org.apache.thrift.async.AsyncMethodCallback<recordFrequency_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      recordFrequency_call method_call = new recordFrequency_call(table, columnFamily, columnName, value, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class recordFrequency_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      private String columnFamily;
-      private String columnName;
-      private String value;
-      public recordFrequency_call(String table, String columnFamily, String columnName, String value, org.apache.thrift.async.AsyncMethodCallback<recordFrequency_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.table = table;
-        this.columnFamily = columnFamily;
-        this.columnName = columnName;
-        this.value = value;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("recordFrequency", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        recordFrequency_args args = new recordFrequency_args();
-        args.setTable(table);
-        args.setColumnFamily(columnFamily);
-        args.setColumnName(columnName);
-        args.setValue(value);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public long getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_recordFrequency();
-      }
-    }
-
-    public void fetchRow(String table, Selector selector, org.apache.thrift.async.AsyncMethodCallback<fetchRow_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      fetchRow_call method_call = new fetchRow_call(table, selector, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class fetchRow_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      private Selector selector;
-      public fetchRow_call(String table, Selector selector, org.apache.thrift.async.AsyncMethodCallback<fetchRow_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.table = table;
-        this.selector = selector;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("fetchRow", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        fetchRow_args args = new fetchRow_args();
-        args.setTable(table);
-        args.setSelector(selector);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public FetchResult getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        return (new Client(prot)).recv_fetchRow();
-      }
-    }
-
-    public void mutate(RowMutation mutation, org.apache.thrift.async.AsyncMethodCallback<mutate_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      mutate_call method_call = new mutate_call(mutation, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class mutate_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private RowMutation mutation;
-      public mutate_call(RowMutation mutation, org.apache.thrift.async.AsyncMethodCallback<mutate_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.mutation = mutation;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("mutate", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        mutate_args args = new mutate_args();
-        args.setMutation(mutation);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_mutate();
-      }
-    }
-
-    public void mutateBatch(List<RowMutation> mutations, org.apache.thrift.async.AsyncMethodCallback<mutateBatch_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      mutateBatch_call method_call = new mutateBatch_call(mutations, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class mutateBatch_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private List<RowMutation> mutations;
-      public mutateBatch_call(List<RowMutation> mutations, org.apache.thrift.async.AsyncMethodCallback<mutateBatch_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.mutations = mutations;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("mutateBatch", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        mutateBatch_args args = new mutateBatch_args();
-        args.setMutations(mutations);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_mutateBatch();
-      }
-    }
-
-    public void createTable(TableDescriptor tableDescriptor, org.apache.thrift.async.AsyncMethodCallback<createTable_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      createTable_call method_call = new createTable_call(tableDescriptor, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class createTable_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private TableDescriptor tableDescriptor;
-      public createTable_call(TableDescriptor tableDescriptor, org.apache.thrift.async.AsyncMethodCallback<createTable_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.tableDescriptor = tableDescriptor;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("createTable", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        createTable_args args = new createTable_args();
-        args.setTableDescriptor(tableDescriptor);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_createTable();
-      }
-    }
-
-    public void enableTable(String table, org.apache.thrift.async.AsyncMethodCallback<enableTable_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      enableTable_call method_call = new enableTable_call(table, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class enableTable_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      public enableTable_call(String table, org.apache.thrift.async.AsyncMethodCallback<enableTable_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.table = table;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("enableTable", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        enableTable_args args = new enableTable_args();
-        args.setTable(table);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_enableTable();
-      }
-    }
-
-    public void disableTable(String table, org.apache.thrift.async.AsyncMethodCallback<disableTable_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      disableTable_call method_call = new disableTable_call(table, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class disableTable_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      public disableTable_call(String table, org.apache.thrift.async.AsyncMethodCallback<disableTable_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.table = table;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("disableTable", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        disableTable_args args = new disableTable_args();
-        args.setTable(table);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_disableTable();
-      }
-    }
-
-    public void removeTable(String table, boolean deleteIndexFiles, org.apache.thrift.async.AsyncMethodCallback<removeTable_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      removeTable_call method_call = new removeTable_call(table, deleteIndexFiles, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class removeTable_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      private boolean deleteIndexFiles;
-      public removeTable_call(String table, boolean deleteIndexFiles, org.apache.thrift.async.AsyncMethodCallback<removeTable_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.table = table;
-        this.deleteIndexFiles = deleteIndexFiles;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("removeTable", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        removeTable_args args = new removeTable_args();
-        args.setTable(table);
-        args.setDeleteIndexFiles(deleteIndexFiles);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_removeTable();
-      }
-    }
-
-    public void optimize(String table, int numberOfSegmentsPerShard, org.apache.thrift.async.AsyncMethodCallback<optimize_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      optimize_call method_call = new optimize_call(table, numberOfSegmentsPerShard, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class optimize_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      private int numberOfSegmentsPerShard;
-      public optimize_call(String table, int numberOfSegmentsPerShard, org.apache.thrift.async.AsyncMethodCallback<optimize_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
-        super(client, protocolFactory, transport, resultHandler, false);
-        this.table = table;
-        this.numberOfSegmentsPerShard = numberOfSegmentsPerShard;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("optimize", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        optimize_args args = new optimize_args();
-        args.setTable(table);
-        args.setNumberOfSegmentsPerShard(numberOfSegmentsPerShard);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public void getResult() throws BlurException, org.apache.thrift.TException {
-        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
-          throw new IllegalStateException("Method call not finished!");
-        }
-        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
-        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
-        (new Client(prot)).recv_optimize();
-      }
-    }
-
-    public void isInSafeMode(String cluster, org.apache.thrift.async.AsyncMethodCallback<isInSafeMode_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      isInSafeMode_call method_call = new isInSafeMode_call(cluster, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class isInSafeMode_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String cluster;
-      public isInSafeMode_call(String cluster, org.apache.thrift.async.AsyncMethodCallback<isInSafeMode_call> resultHandler, org.apache.thrift.async.TAsyncClient client, o

<TRUNCATED>

Mime
View raw message