incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [11/39] Some changes while prototyping.
Date Thu, 28 Feb 2013 03:07:40 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/ae2ff9e4/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java b/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
deleted file mode 100644
index d27a94b..0000000
--- a/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
+++ /dev/null
@@ -1,23493 +0,0 @@
-/**
- * Autogenerated by Thrift Compiler (0.9.0)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- *  @generated
- */
-package org.apache.blur.thrift.generated;
-
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-
-import org.apache.thrift.scheme.IScheme;
-import org.apache.thrift.scheme.SchemeFactory;
-import org.apache.thrift.scheme.StandardScheme;
-
-import org.apache.thrift.scheme.TupleScheme;
-import org.apache.thrift.protocol.TTupleProtocol;
-import org.apache.thrift.protocol.TProtocolException;
-import org.apache.thrift.EncodingUtils;
-import org.apache.thrift.TException;
-import java.util.List;
-import java.util.ArrayList;
-import java.util.Map;
-import java.util.HashMap;
-import java.util.EnumMap;
-import java.util.Set;
-import java.util.HashSet;
-import java.util.EnumSet;
-import java.util.Collections;
-import java.util.BitSet;
-import java.nio.ByteBuffer;
-import java.util.Arrays;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class Blur {
-
-  public interface Iface {
-
-    /**
-     * Creating a session snapshots the readers during search and document
-     * fetching.  This provides a static view of the indexes so the document
-     * ids will remain the same during a session.
-     * @param table the table name.
-     * @return the new Session.
-     * 
-     * @param table
-     */
-    public Session openReadSession(String table) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Runs a search with the given query arguments.  Invalid Sessions will throw a BlurException.
-     * @param session the Session.
-     * @param queryArgs the QueryArgs which contains the query, filter, sort, fetch, paging information, etc.
-     * @return the TopFieldDocs, where there is a TopFieldDocs object for each shard that was search against.
-     * 
-     * @param session
-     * @param queryArgs
-     */
-    public List<TopFieldDocs> search(Session session, QueryArgs queryArgs) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Fetches a document based on the DocLocation list with the fields specified.
-     * @param session the Session.
-     * @param docLocations the document locations, which include shard index and document id.
-     * @param fields the field names to fetch.
-     * @return the Documents that were requested.
-     * 
-     * @param session
-     * @param docLocations
-     * @param fields
-     */
-    public List<Document> doc(Session session, List<Long> docLocations, Set<String> fields) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Closes the session and allows the readers to be closed.
-     * @param session the Session.
-     * 
-     * @param session
-     */
-    public void closeReadSession(Session session) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Add Documents to the given table in the provided shard.  If the table or
-     * shard is not found on this shard server a BlurException will be thrown.
-     * @param options the MutateOptions provide the table name, shard index, etc.
-     * @param documents the documents to be added.  NOTE: All documents
-     * provided to be indexed in a single segment.
-     * 
-     * @param options
-     * @param documents
-     */
-    public List<Generation> addDocuments(MutateOptions options, List<Document> documents) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Delete Documents to the given table in the provided shard.  If the table
-     * or shard is not found on this shard server a BlurException will be thrown.
-     * @param options the MutateOptions provide the table name, shard index, etc.
-     * @param queries the Queries that will executed and mark there resulting documents as deleted.
-     * 
-     * @param options
-     * @param queries
-     */
-    public List<Generation> deleteDocumentsByQueries(MutateOptions options, List<Query> queries) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Delete Documents to the given table in the provided shard.  If the table
-     * or shard is not found on this shard server a BlurException will be thrown.
-     * @param options the MutateOptions provide the table name, shard index, etc.
-     * @param queries the Terms that will be found and mark deleted all the documents to be deleted.
-     * 
-     * @param options
-     * @param terms
-     */
-    public List<Generation> deleteDocuments(MutateOptions options, List<Term> terms) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Update Documents to the given table in the provided shard.  If the table
-     * or shard is not found on this shard server a BlurException will be thrown.
-     * @param options the MutateOptions provide the table name, shard index, etc.
-     * @param updatePackages the documents to be updated.  NOTE: All documents
-     * within a update document object are indexed in a single segment.
-     * 
-     * @param options
-     * @param updatePackages
-     */
-    public List<Generation> updateDocuments(MutateOptions options, List<UpdatePackage> updatePackages) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * This method blocks until all the given generations are visible for reading.
-     * @param generations the list of Generation objects.
-     * @param forceRefresh forces a refresh of the indexes if true, if false will
-     * block until natural refresh occurs.
-     * 
-     * @param generations
-     * @param forceRefresh
-     */
-    public void blockUntilGenerationIsVisible(List<Generation> generations, boolean forceRefresh) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Returns a list of all current running servers.
-     * @return list of servers, e.g. node1:40020.
-     */
-    public List<String> serverList() throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Gets a list shard ids for the given server and table.
-     * @param table the table name.
-     * @param server the server name, e.g. node1:40020
-     * @return list of shard ids.
-     * 
-     * @param table
-     * @param server
-     */
-    public List<Integer> serverLayout(String table, String server) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Gets the shard layout for each server in the cluster for the given table.
-     * @param table the table name.
-     * @return map of servers to shard layout object.
-     * 
-     * @param table
-     */
-    public Map<String,ShardLayout> shardLayout(String table) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Gets a list of the table names.
-     * @return list of table names.
-     */
-    public List<String> tableList() throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Is cluster in safe mode.
-     * @return safe mode boolean.
-     */
-    public boolean isInSafeMode() throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Create a table with the given table descriptor.
-     * @param tableDescriptor the TableDescriptor.
-     * 
-     * @param tableDescriptor
-     */
-    public void createTable(TableDescriptor tableDescriptor) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Enables a table with the given table name.
-     * @param table the table name.
-     * 
-     * @param table
-     */
-    public void enableTable(String table) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Disables a table with the given table name.
-     * @param table the table name.
-     * 
-     * @param table
-     */
-    public void disableTable(String table) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Removes a table with the given table name.
-     * @param table the table name.
-     * @param deleteIndexFiles boolean, whether or not to remove the indexes from the HDFS system.
-     * 
-     * @param table
-     * @param deleteIndexFiles
-     */
-    public void removeTable(String table, boolean deleteIndexFiles) 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;
-
-    /**
-     * Cancels a query that is executing within the given session.
-     * @param session the Session.
-     * @param server the server name to receive the call, null for all servers.
-     * @param id the id of the query, (QueryArgs.id).
-     * 
-     * @param session
-     * @param server
-     * @param id
-     */
-    public void cancelQuery(Session session, String server, String id) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Returns a list of the query ids of queries that have recently been executed within the given session.
-     * @param session the Session.
-     * @param server the server name to receive the call, null for all servers.
-     * @return the ids of the query objects, (QueryArgs.id).
-     * 
-     * @param session
-     * @param server
-     */
-    public Map<String,List<String>> queryStatusIdList(Session session, String server) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Returns the query status for the given session and query id, (QueryArgs.id).
-     * @param session the Session.
-     * @param server the server name to receive the call, null for all servers.
-     * @param id the id of the query, (QueryArgs.id).
-     * @return a map of server to the query status for the given session and id.
-     * 
-     * @param session
-     * @param server
-     * @param id
-     */
-    public Map<String,QueryStatus> queryStatus(Session session, String server, String id) throws BlurException, org.apache.thrift.TException;
-
-    /**
-     * Returns the the schema for the given session.
-     * @param session the Session.
-     * @return the table schema.
-     * 
-     * @param session
-     */
-    public TableSchema schema(Session session) throws BlurException, org.apache.thrift.TException;
-
-    public TableStats tableStats(String table) throws BlurException, org.apache.thrift.TException;
-
-  }
-
-  public interface AsyncIface {
-
-    public void openReadSession(String table, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.openReadSession_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void search(Session session, QueryArgs queryArgs, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.search_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void doc(Session session, List<Long> docLocations, Set<String> fields, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.doc_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void closeReadSession(Session session, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.closeReadSession_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void addDocuments(MutateOptions options, List<Document> documents, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.addDocuments_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void deleteDocumentsByQueries(MutateOptions options, List<Query> queries, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteDocumentsByQueries_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void deleteDocuments(MutateOptions options, List<Term> terms, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteDocuments_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void updateDocuments(MutateOptions options, List<UpdatePackage> updatePackages, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.updateDocuments_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void blockUntilGenerationIsVisible(List<Generation> generations, boolean forceRefresh, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.blockUntilGenerationIsVisible_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void serverList(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.serverList_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void serverLayout(String table, String server, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.serverLayout_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void shardLayout(String table, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.shardLayout_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 isInSafeMode(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.isInSafeMode_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 describe(String table, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.describe_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void cancelQuery(Session session, String server, String id, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.cancelQuery_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void queryStatusIdList(Session session, String server, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.queryStatusIdList_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void queryStatus(Session session, String server, String id, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.queryStatus_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void schema(Session session, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.schema_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 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 Session openReadSession(String table) throws BlurException, org.apache.thrift.TException
-    {
-      send_openReadSession(table);
-      return recv_openReadSession();
-    }
-
-    public void send_openReadSession(String table) throws org.apache.thrift.TException
-    {
-      openReadSession_args args = new openReadSession_args();
-      args.setTable(table);
-      sendBase("openReadSession", args);
-    }
-
-    public Session recv_openReadSession() throws BlurException, org.apache.thrift.TException
-    {
-      openReadSession_result result = new openReadSession_result();
-      receiveBase(result, "openReadSession");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.e != null) {
-        throw result.e;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "openReadSession failed: unknown result");
-    }
-
-    public List<TopFieldDocs> search(Session session, QueryArgs queryArgs) throws BlurException, org.apache.thrift.TException
-    {
-      send_search(session, queryArgs);
-      return recv_search();
-    }
-
-    public void send_search(Session session, QueryArgs queryArgs) throws org.apache.thrift.TException
-    {
-      search_args args = new search_args();
-      args.setSession(session);
-      args.setQueryArgs(queryArgs);
-      sendBase("search", args);
-    }
-
-    public List<TopFieldDocs> recv_search() throws BlurException, org.apache.thrift.TException
-    {
-      search_result result = new search_result();
-      receiveBase(result, "search");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.e != null) {
-        throw result.e;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "search failed: unknown result");
-    }
-
-    public List<Document> doc(Session session, List<Long> docLocations, Set<String> fields) throws BlurException, org.apache.thrift.TException
-    {
-      send_doc(session, docLocations, fields);
-      return recv_doc();
-    }
-
-    public void send_doc(Session session, List<Long> docLocations, Set<String> fields) throws org.apache.thrift.TException
-    {
-      doc_args args = new doc_args();
-      args.setSession(session);
-      args.setDocLocations(docLocations);
-      args.setFields(fields);
-      sendBase("doc", args);
-    }
-
-    public List<Document> recv_doc() throws BlurException, org.apache.thrift.TException
-    {
-      doc_result result = new doc_result();
-      receiveBase(result, "doc");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.e != null) {
-        throw result.e;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "doc failed: unknown result");
-    }
-
-    public void closeReadSession(Session session) throws BlurException, org.apache.thrift.TException
-    {
-      send_closeReadSession(session);
-      recv_closeReadSession();
-    }
-
-    public void send_closeReadSession(Session session) throws org.apache.thrift.TException
-    {
-      closeReadSession_args args = new closeReadSession_args();
-      args.setSession(session);
-      sendBase("closeReadSession", args);
-    }
-
-    public void recv_closeReadSession() throws BlurException, org.apache.thrift.TException
-    {
-      closeReadSession_result result = new closeReadSession_result();
-      receiveBase(result, "closeReadSession");
-      if (result.e != null) {
-        throw result.e;
-      }
-      return;
-    }
-
-    public List<Generation> addDocuments(MutateOptions options, List<Document> documents) throws BlurException, org.apache.thrift.TException
-    {
-      send_addDocuments(options, documents);
-      return recv_addDocuments();
-    }
-
-    public void send_addDocuments(MutateOptions options, List<Document> documents) throws org.apache.thrift.TException
-    {
-      addDocuments_args args = new addDocuments_args();
-      args.setOptions(options);
-      args.setDocuments(documents);
-      sendBase("addDocuments", args);
-    }
-
-    public List<Generation> recv_addDocuments() throws BlurException, org.apache.thrift.TException
-    {
-      addDocuments_result result = new addDocuments_result();
-      receiveBase(result, "addDocuments");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.e != null) {
-        throw result.e;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addDocuments failed: unknown result");
-    }
-
-    public List<Generation> deleteDocumentsByQueries(MutateOptions options, List<Query> queries) throws BlurException, org.apache.thrift.TException
-    {
-      send_deleteDocumentsByQueries(options, queries);
-      return recv_deleteDocumentsByQueries();
-    }
-
-    public void send_deleteDocumentsByQueries(MutateOptions options, List<Query> queries) throws org.apache.thrift.TException
-    {
-      deleteDocumentsByQueries_args args = new deleteDocumentsByQueries_args();
-      args.setOptions(options);
-      args.setQueries(queries);
-      sendBase("deleteDocumentsByQueries", args);
-    }
-
-    public List<Generation> recv_deleteDocumentsByQueries() throws BlurException, org.apache.thrift.TException
-    {
-      deleteDocumentsByQueries_result result = new deleteDocumentsByQueries_result();
-      receiveBase(result, "deleteDocumentsByQueries");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.e != null) {
-        throw result.e;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deleteDocumentsByQueries failed: unknown result");
-    }
-
-    public List<Generation> deleteDocuments(MutateOptions options, List<Term> terms) throws BlurException, org.apache.thrift.TException
-    {
-      send_deleteDocuments(options, terms);
-      return recv_deleteDocuments();
-    }
-
-    public void send_deleteDocuments(MutateOptions options, List<Term> terms) throws org.apache.thrift.TException
-    {
-      deleteDocuments_args args = new deleteDocuments_args();
-      args.setOptions(options);
-      args.setTerms(terms);
-      sendBase("deleteDocuments", args);
-    }
-
-    public List<Generation> recv_deleteDocuments() throws BlurException, org.apache.thrift.TException
-    {
-      deleteDocuments_result result = new deleteDocuments_result();
-      receiveBase(result, "deleteDocuments");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.e != null) {
-        throw result.e;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deleteDocuments failed: unknown result");
-    }
-
-    public List<Generation> updateDocuments(MutateOptions options, List<UpdatePackage> updatePackages) throws BlurException, org.apache.thrift.TException
-    {
-      send_updateDocuments(options, updatePackages);
-      return recv_updateDocuments();
-    }
-
-    public void send_updateDocuments(MutateOptions options, List<UpdatePackage> updatePackages) throws org.apache.thrift.TException
-    {
-      updateDocuments_args args = new updateDocuments_args();
-      args.setOptions(options);
-      args.setUpdatePackages(updatePackages);
-      sendBase("updateDocuments", args);
-    }
-
-    public List<Generation> recv_updateDocuments() throws BlurException, org.apache.thrift.TException
-    {
-      updateDocuments_result result = new updateDocuments_result();
-      receiveBase(result, "updateDocuments");
-      if (result.isSetSuccess()) {
-        return result.success;
-      }
-      if (result.e != null) {
-        throw result.e;
-      }
-      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "updateDocuments failed: unknown result");
-    }
-
-    public void blockUntilGenerationIsVisible(List<Generation> generations, boolean forceRefresh) throws BlurException, org.apache.thrift.TException
-    {
-      send_blockUntilGenerationIsVisible(generations, forceRefresh);
-      recv_blockUntilGenerationIsVisible();
-    }
-
-    public void send_blockUntilGenerationIsVisible(List<Generation> generations, boolean forceRefresh) throws org.apache.thrift.TException
-    {
-      blockUntilGenerationIsVisible_args args = new blockUntilGenerationIsVisible_args();
-      args.setGenerations(generations);
-      args.setForceRefresh(forceRefresh);
-      sendBase("blockUntilGenerationIsVisible", args);
-    }
-
-    public void recv_blockUntilGenerationIsVisible() throws BlurException, org.apache.thrift.TException
-    {
-      blockUntilGenerationIsVisible_result result = new blockUntilGenerationIsVisible_result();
-      receiveBase(result, "blockUntilGenerationIsVisible");
-      if (result.e != null) {
-        throw result.e;
-      }
-      return;
-    }
-
-    public List<String> serverList() throws BlurException, org.apache.thrift.TException
-    {
-      send_serverList();
-      return recv_serverList();
-    }
-
-    public void send_serverList() throws org.apache.thrift.TException
-    {
-      serverList_args args = new serverList_args();
-      sendBase("serverList", args);
-    }
-
-    public List<String> recv_serverList() throws BlurException, org.apache.thrift.TException
-    {
-      serverList_result result = new serverList_result();
-      receiveBase(result, "serverList");
-      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, "serverList failed: unknown result");
-    }
-
-    public List<Integer> serverLayout(String table, String server) throws BlurException, org.apache.thrift.TException
-    {
-      send_serverLayout(table, server);
-      return recv_serverLayout();
-    }
-
-    public void send_serverLayout(String table, String server) throws org.apache.thrift.TException
-    {
-      serverLayout_args args = new serverLayout_args();
-      args.setTable(table);
-      args.setServer(server);
-      sendBase("serverLayout", args);
-    }
-
-    public List<Integer> recv_serverLayout() throws BlurException, org.apache.thrift.TException
-    {
-      serverLayout_result result = new serverLayout_result();
-      receiveBase(result, "serverLayout");
-      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, "serverLayout failed: unknown result");
-    }
-
-    public Map<String,ShardLayout> shardLayout(String table) throws BlurException, org.apache.thrift.TException
-    {
-      send_shardLayout(table);
-      return recv_shardLayout();
-    }
-
-    public void send_shardLayout(String table) throws org.apache.thrift.TException
-    {
-      shardLayout_args args = new shardLayout_args();
-      args.setTable(table);
-      sendBase("shardLayout", args);
-    }
-
-    public Map<String,ShardLayout> recv_shardLayout() throws BlurException, org.apache.thrift.TException
-    {
-      shardLayout_result result = new shardLayout_result();
-      receiveBase(result, "shardLayout");
-      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, "shardLayout 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 boolean isInSafeMode() throws BlurException, org.apache.thrift.TException
-    {
-      send_isInSafeMode();
-      return recv_isInSafeMode();
-    }
-
-    public void send_isInSafeMode() throws org.apache.thrift.TException
-    {
-      isInSafeMode_args args = new isInSafeMode_args();
-      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 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 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 void cancelQuery(Session session, String server, String id) throws BlurException, org.apache.thrift.TException
-    {
-      send_cancelQuery(session, server, id);
-      recv_cancelQuery();
-    }
-
-    public void send_cancelQuery(Session session, String server, String id) throws org.apache.thrift.TException
-    {
-      cancelQuery_args args = new cancelQuery_args();
-      args.setSession(session);
-      args.setServer(server);
-      args.setId(id);
-      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 Map<String,List<String>> queryStatusIdList(Session session, String server) throws BlurException, org.apache.thrift.TException
-    {
-      send_queryStatusIdList(session, server);
-      return recv_queryStatusIdList();
-    }
-
-    public void send_queryStatusIdList(Session session, String server) throws org.apache.thrift.TException
-    {
-      queryStatusIdList_args args = new queryStatusIdList_args();
-      args.setSession(session);
-      args.setServer(server);
-      sendBase("queryStatusIdList", args);
-    }
-
-    public Map<String,List<String>> 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 Map<String,QueryStatus> queryStatus(Session session, String server, String id) throws BlurException, org.apache.thrift.TException
-    {
-      send_queryStatus(session, server, id);
-      return recv_queryStatus();
-    }
-
-    public void send_queryStatus(Session session, String server, String id) throws org.apache.thrift.TException
-    {
-      queryStatus_args args = new queryStatus_args();
-      args.setSession(session);
-      args.setServer(server);
-      args.setId(id);
-      sendBase("queryStatus", args);
-    }
-
-    public Map<String,QueryStatus> recv_queryStatus() throws BlurException, org.apache.thrift.TException
-    {
-      queryStatus_result result = new queryStatus_result();
-      receiveBase(result, "queryStatus");
-      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, "queryStatus failed: unknown result");
-    }
-
-    public TableSchema schema(Session session) throws BlurException, org.apache.thrift.TException
-    {
-      send_schema(session);
-      return recv_schema();
-    }
-
-    public void send_schema(Session session) throws org.apache.thrift.TException
-    {
-      schema_args args = new schema_args();
-      args.setSession(session);
-      sendBase("schema", args);
-    }
-
-    public TableSchema 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 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 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 openReadSession(String table, org.apache.thrift.async.AsyncMethodCallback<openReadSession_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      openReadSession_call method_call = new openReadSession_call(table, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class openReadSession_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      public openReadSession_call(String table, org.apache.thrift.async.AsyncMethodCallback<openReadSession_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("openReadSession", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        openReadSession_args args = new openReadSession_args();
-        args.setTable(table);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Session 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_openReadSession();
-      }
-    }
-
-    public void search(Session session, QueryArgs queryArgs, org.apache.thrift.async.AsyncMethodCallback<search_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      search_call method_call = new search_call(session, queryArgs, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class search_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private Session session;
-      private QueryArgs queryArgs;
-      public search_call(Session session, QueryArgs queryArgs, org.apache.thrift.async.AsyncMethodCallback<search_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.session = session;
-        this.queryArgs = queryArgs;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("search", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        search_args args = new search_args();
-        args.setSession(session);
-        args.setQueryArgs(queryArgs);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public List<TopFieldDocs> 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_search();
-      }
-    }
-
-    public void doc(Session session, List<Long> docLocations, Set<String> fields, org.apache.thrift.async.AsyncMethodCallback<doc_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      doc_call method_call = new doc_call(session, docLocations, fields, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class doc_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private Session session;
-      private List<Long> docLocations;
-      private Set<String> fields;
-      public doc_call(Session session, List<Long> docLocations, Set<String> fields, org.apache.thrift.async.AsyncMethodCallback<doc_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.session = session;
-        this.docLocations = docLocations;
-        this.fields = fields;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("doc", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        doc_args args = new doc_args();
-        args.setSession(session);
-        args.setDocLocations(docLocations);
-        args.setFields(fields);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public List<Document> 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_doc();
-      }
-    }
-
-    public void closeReadSession(Session session, org.apache.thrift.async.AsyncMethodCallback<closeReadSession_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      closeReadSession_call method_call = new closeReadSession_call(session, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class closeReadSession_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private Session session;
-      public closeReadSession_call(Session session, org.apache.thrift.async.AsyncMethodCallback<closeReadSession_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.session = session;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("closeReadSession", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        closeReadSession_args args = new closeReadSession_args();
-        args.setSession(session);
-        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_closeReadSession();
-      }
-    }
-
-    public void addDocuments(MutateOptions options, List<Document> documents, org.apache.thrift.async.AsyncMethodCallback<addDocuments_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      addDocuments_call method_call = new addDocuments_call(options, documents, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class addDocuments_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private MutateOptions options;
-      private List<Document> documents;
-      public addDocuments_call(MutateOptions options, List<Document> documents, org.apache.thrift.async.AsyncMethodCallback<addDocuments_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.options = options;
-        this.documents = documents;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addDocuments", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        addDocuments_args args = new addDocuments_args();
-        args.setOptions(options);
-        args.setDocuments(documents);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public List<Generation> 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_addDocuments();
-      }
-    }
-
-    public void deleteDocumentsByQueries(MutateOptions options, List<Query> queries, org.apache.thrift.async.AsyncMethodCallback<deleteDocumentsByQueries_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      deleteDocumentsByQueries_call method_call = new deleteDocumentsByQueries_call(options, queries, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class deleteDocumentsByQueries_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private MutateOptions options;
-      private List<Query> queries;
-      public deleteDocumentsByQueries_call(MutateOptions options, List<Query> queries, org.apache.thrift.async.AsyncMethodCallback<deleteDocumentsByQueries_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.options = options;
-        this.queries = queries;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteDocumentsByQueries", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        deleteDocumentsByQueries_args args = new deleteDocumentsByQueries_args();
-        args.setOptions(options);
-        args.setQueries(queries);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public List<Generation> 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_deleteDocumentsByQueries();
-      }
-    }
-
-    public void deleteDocuments(MutateOptions options, List<Term> terms, org.apache.thrift.async.AsyncMethodCallback<deleteDocuments_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      deleteDocuments_call method_call = new deleteDocuments_call(options, terms, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class deleteDocuments_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private MutateOptions options;
-      private List<Term> terms;
-      public deleteDocuments_call(MutateOptions options, List<Term> terms, org.apache.thrift.async.AsyncMethodCallback<deleteDocuments_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.options = options;
-        this.terms = terms;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteDocuments", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        deleteDocuments_args args = new deleteDocuments_args();
-        args.setOptions(options);
-        args.setTerms(terms);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public List<Generation> 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_deleteDocuments();
-      }
-    }
-
-    public void updateDocuments(MutateOptions options, List<UpdatePackage> updatePackages, org.apache.thrift.async.AsyncMethodCallback<updateDocuments_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      updateDocuments_call method_call = new updateDocuments_call(options, updatePackages, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class updateDocuments_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private MutateOptions options;
-      private List<UpdatePackage> updatePackages;
-      public updateDocuments_call(MutateOptions options, List<UpdatePackage> updatePackages, org.apache.thrift.async.AsyncMethodCallback<updateDocuments_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.options = options;
-        this.updatePackages = updatePackages;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("updateDocuments", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        updateDocuments_args args = new updateDocuments_args();
-        args.setOptions(options);
-        args.setUpdatePackages(updatePackages);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public List<Generation> 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_updateDocuments();
-      }
-    }
-
-    public void blockUntilGenerationIsVisible(List<Generation> generations, boolean forceRefresh, org.apache.thrift.async.AsyncMethodCallback<blockUntilGenerationIsVisible_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      blockUntilGenerationIsVisible_call method_call = new blockUntilGenerationIsVisible_call(generations, forceRefresh, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class blockUntilGenerationIsVisible_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private List<Generation> generations;
-      private boolean forceRefresh;
-      public blockUntilGenerationIsVisible_call(List<Generation> generations, boolean forceRefresh, org.apache.thrift.async.AsyncMethodCallback<blockUntilGenerationIsVisible_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.generations = generations;
-        this.forceRefresh = forceRefresh;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("blockUntilGenerationIsVisible", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        blockUntilGenerationIsVisible_args args = new blockUntilGenerationIsVisible_args();
-        args.setGenerations(generations);
-        args.setForceRefresh(forceRefresh);
-        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_blockUntilGenerationIsVisible();
-      }
-    }
-
-    public void serverList(org.apache.thrift.async.AsyncMethodCallback<serverList_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      serverList_call method_call = new serverList_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class serverList_call extends org.apache.thrift.async.TAsyncMethodCall {
-      public serverList_call(org.apache.thrift.async.AsyncMethodCallback<serverList_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("serverList", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        serverList_args args = new serverList_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_serverList();
-      }
-    }
-
-    public void serverLayout(String table, String server, org.apache.thrift.async.AsyncMethodCallback<serverLayout_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      serverLayout_call method_call = new serverLayout_call(table, server, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class serverLayout_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      private String server;
-      public serverLayout_call(String table, String server, org.apache.thrift.async.AsyncMethodCallback<serverLayout_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.server = server;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("serverLayout", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        serverLayout_args args = new serverLayout_args();
-        args.setTable(table);
-        args.setServer(server);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public List<Integer> 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_serverLayout();
-      }
-    }
-
-    public void shardLayout(String table, org.apache.thrift.async.AsyncMethodCallback<shardLayout_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      shardLayout_call method_call = new shardLayout_call(table, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class shardLayout_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      public shardLayout_call(String table, org.apache.thrift.async.AsyncMethodCallback<shardLayout_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("shardLayout", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        shardLayout_args args = new shardLayout_args();
-        args.setTable(table);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Map<String,ShardLayout> 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_shardLayout();
-      }
-    }
-
-    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 isInSafeMode(org.apache.thrift.async.AsyncMethodCallback<isInSafeMode_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      isInSafeMode_call method_call = new isInSafeMode_call(resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class isInSafeMode_call extends org.apache.thrift.async.TAsyncMethodCall {
-      public isInSafeMode_call(org.apache.thrift.async.AsyncMethodCallback<isInSafeMode_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("isInSafeMode", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        isInSafeMode_args args = new isInSafeMode_args();
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public boolean 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_isInSafeMode();
-      }
-    }
-
-    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 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 cancelQuery(Session session, String server, String id, org.apache.thrift.async.AsyncMethodCallback<cancelQuery_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      cancelQuery_call method_call = new cancelQuery_call(session, server, id, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class cancelQuery_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private Session session;
-      private String server;
-      private String id;
-      public cancelQuery_call(Session session, String server, String id, 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.session = session;
-        this.server = server;
-        this.id = id;
-      }
-
-      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.setSession(session);
-        args.setServer(server);
-        args.setId(id);
-        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 queryStatusIdList(Session session, String server, org.apache.thrift.async.AsyncMethodCallback<queryStatusIdList_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      queryStatusIdList_call method_call = new queryStatusIdList_call(session, server, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class queryStatusIdList_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private Session session;
-      private String server;
-      public queryStatusIdList_call(Session session, String server, 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.session = session;
-        this.server = server;
-      }
-
-      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.setSession(session);
-        args.setServer(server);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Map<String,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_queryStatusIdList();
-      }
-    }
-
-    public void queryStatus(Session session, String server, String id, org.apache.thrift.async.AsyncMethodCallback<queryStatus_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      queryStatus_call method_call = new queryStatus_call(session, server, id, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class queryStatus_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private Session session;
-      private String server;
-      private String id;
-      public queryStatus_call(Session session, String server, String id, org.apache.thrift.async.AsyncMethodCallback<queryStatus_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.session = session;
-        this.server = server;
-        this.id = id;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("queryStatus", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        queryStatus_args args = new queryStatus_args();
-        args.setSession(session);
-        args.setServer(server);
-        args.setId(id);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public Map<String,QueryStatus> 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_queryStatus();
-      }
-    }
-
-    public void schema(Session session, org.apache.thrift.async.AsyncMethodCallback<schema_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      schema_call method_call = new schema_call(session, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class schema_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private Session session;
-      public schema_call(Session session, 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.session = session;
-      }
-
-      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.setSession(session);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public TableSchema 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 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.ap

<TRUNCATED>

Mime
View raw message