incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [29/39] Massive changes to the thrift RPC defs, see mail list for details subject (Rows, Records, Session oh my).
Date Thu, 28 Feb 2013 03:07:37 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/11f5141c/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
new file mode 100644
index 0000000..983c17e
--- /dev/null
+++ b/src/distribution/src/main/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java
@@ -0,0 +1,23493 @@
+/**
+ * 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 extends org.apache.blur.thrift.generated.DocumentGroupService.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 org.apache.blur.thrift.generated.Session openReadSession(String table) throws org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.TopFieldDocs> search(org.apache.blur.thrift.generated.Session session, org.apache.blur.thrift.generated.QueryArgs queryArgs) throws org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.Document> doc(org.apache.blur.thrift.generated.Session session, List<Long> docLocations, Set<String> fields) throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException;
+
+    /**
+     * Closes the session and allows the readers to be closed.
+     * @param session the Session.
+     * 
+     * @param session
+     */
+    public void closeReadSession(org.apache.blur.thrift.generated.Session session) throws org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.Generation> addDocuments(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.Document> documents) throws org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.Generation> deleteDocumentsByQueries(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.Query> queries) throws org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.Generation> deleteDocuments(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.Term> terms) throws org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.Generation> updateDocuments(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.UpdatePackage> updatePackages) throws org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.Generation> generations, boolean forceRefresh) throws org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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,org.apache.blur.thrift.generated.ShardLayout> shardLayout(String table) throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException;
+
+    /**
+     * Gets a list of the table names.
+     * @return list of table names.
+     */
+    public List<String> tableList() throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException;
+
+    /**
+     * Is cluster in safe mode.
+     * @return safe mode boolean.
+     */
+    public boolean isInSafeMode() throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException;
+
+    /**
+     * Create a table with the given table descriptor.
+     * @param tableDescriptor the TableDescriptor.
+     * 
+     * @param tableDescriptor
+     */
+    public void createTable(org.apache.blur.thrift.generated.TableDescriptor tableDescriptor) throws org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException;
+
+    /**
+     * Returns a table descriptor for the given table.
+     * @param table the table name.
+     * 
+     * @param table
+     */
+    public org.apache.blur.thrift.generated.TableDescriptor describe(String table) throws org.apache.blur.thrift.generated.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(org.apache.blur.thrift.generated.Session session, String server, String id) throws org.apache.blur.thrift.generated.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(org.apache.blur.thrift.generated.Session session, String server) throws org.apache.blur.thrift.generated.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,org.apache.blur.thrift.generated.QueryStatus> queryStatus(org.apache.blur.thrift.generated.Session session, String server, String id) throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException;
+
+    /**
+     * Returns the the schema for the given session.
+     * @param session the Session.
+     * @return the table schema.
+     * 
+     * @param session
+     */
+    public org.apache.blur.thrift.generated.TableSchema schema(org.apache.blur.thrift.generated.Session session) throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException;
+
+    public org.apache.blur.thrift.generated.TableStats tableStats(String table) throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException;
+
+  }
+
+  public interface AsyncIface extends org.apache.blur.thrift.generated.DocumentGroupService .AsyncIface {
+
+    public void openReadSession(String table, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.openReadSession_call> resultHandler) throws org.apache.thrift.TException;
+
+    public void search(org.apache.blur.thrift.generated.Session session, org.apache.blur.thrift.generated.QueryArgs queryArgs, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.search_call> resultHandler) throws org.apache.thrift.TException;
+
+    public void doc(org.apache.blur.thrift.generated.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(org.apache.blur.thrift.generated.Session session, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.closeReadSession_call> resultHandler) throws org.apache.thrift.TException;
+
+    public void addDocuments(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.Document> documents, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.addDocuments_call> resultHandler) throws org.apache.thrift.TException;
+
+    public void deleteDocumentsByQueries(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.Query> queries, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteDocumentsByQueries_call> resultHandler) throws org.apache.thrift.TException;
+
+    public void deleteDocuments(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.Term> terms, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteDocuments_call> resultHandler) throws org.apache.thrift.TException;
+
+    public void updateDocuments(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.UpdatePackage> updatePackages, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.updateDocuments_call> resultHandler) throws org.apache.thrift.TException;
+
+    public void blockUntilGenerationIsVisible(List<org.apache.blur.thrift.generated.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(org.apache.blur.thrift.generated.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(org.apache.blur.thrift.generated.Session session, String server, String id, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.cancelQuery_call> resultHandler) throws org.apache.thrift.TException;
+
+    public void queryStatusIdList(org.apache.blur.thrift.generated.Session session, String server, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.queryStatusIdList_call> resultHandler) throws org.apache.thrift.TException;
+
+    public void queryStatus(org.apache.blur.thrift.generated.Session session, String server, String id, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.queryStatus_call> resultHandler) throws org.apache.thrift.TException;
+
+    public void schema(org.apache.blur.thrift.generated.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.blur.thrift.generated.DocumentGroupService.Client 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 org.apache.blur.thrift.generated.Session openReadSession(String table) throws org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.Session recv_openReadSession() throws org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.TopFieldDocs> search(org.apache.blur.thrift.generated.Session session, org.apache.blur.thrift.generated.QueryArgs queryArgs) throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException
+    {
+      send_search(session, queryArgs);
+      return recv_search();
+    }
+
+    public void send_search(org.apache.blur.thrift.generated.Session session, org.apache.blur.thrift.generated.QueryArgs queryArgs) throws org.apache.thrift.TException
+    {
+      search_args args = new search_args();
+      args.setSession(session);
+      args.setQueryArgs(queryArgs);
+      sendBase("search", args);
+    }
+
+    public List<org.apache.blur.thrift.generated.TopFieldDocs> recv_search() throws org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.Document> doc(org.apache.blur.thrift.generated.Session session, List<Long> docLocations, Set<String> fields) throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException
+    {
+      send_doc(session, docLocations, fields);
+      return recv_doc();
+    }
+
+    public void send_doc(org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.Document> recv_doc() throws org.apache.blur.thrift.generated.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(org.apache.blur.thrift.generated.Session session) throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException
+    {
+      send_closeReadSession(session);
+      recv_closeReadSession();
+    }
+
+    public void send_closeReadSession(org.apache.blur.thrift.generated.Session session) throws org.apache.thrift.TException
+    {
+      closeReadSession_args args = new closeReadSession_args();
+      args.setSession(session);
+      sendBase("closeReadSession", args);
+    }
+
+    public void recv_closeReadSession() throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException
+    {
+      closeReadSession_result result = new closeReadSession_result();
+      receiveBase(result, "closeReadSession");
+      if (result.e != null) {
+        throw result.e;
+      }
+      return;
+    }
+
+    public List<org.apache.blur.thrift.generated.Generation> addDocuments(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.Document> documents) throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException
+    {
+      send_addDocuments(options, documents);
+      return recv_addDocuments();
+    }
+
+    public void send_addDocuments(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.Document> documents) throws org.apache.thrift.TException
+    {
+      addDocuments_args args = new addDocuments_args();
+      args.setOptions(options);
+      args.setDocuments(documents);
+      sendBase("addDocuments", args);
+    }
+
+    public List<org.apache.blur.thrift.generated.Generation> recv_addDocuments() throws org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.Generation> deleteDocumentsByQueries(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.Query> queries) throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException
+    {
+      send_deleteDocumentsByQueries(options, queries);
+      return recv_deleteDocumentsByQueries();
+    }
+
+    public void send_deleteDocumentsByQueries(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.Query> queries) throws org.apache.thrift.TException
+    {
+      deleteDocumentsByQueries_args args = new deleteDocumentsByQueries_args();
+      args.setOptions(options);
+      args.setQueries(queries);
+      sendBase("deleteDocumentsByQueries", args);
+    }
+
+    public List<org.apache.blur.thrift.generated.Generation> recv_deleteDocumentsByQueries() throws org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.Generation> deleteDocuments(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.Term> terms) throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException
+    {
+      send_deleteDocuments(options, terms);
+      return recv_deleteDocuments();
+    }
+
+    public void send_deleteDocuments(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.Term> terms) throws org.apache.thrift.TException
+    {
+      deleteDocuments_args args = new deleteDocuments_args();
+      args.setOptions(options);
+      args.setTerms(terms);
+      sendBase("deleteDocuments", args);
+    }
+
+    public List<org.apache.blur.thrift.generated.Generation> recv_deleteDocuments() throws org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.Generation> updateDocuments(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.UpdatePackage> updatePackages) throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException
+    {
+      send_updateDocuments(options, updatePackages);
+      return recv_updateDocuments();
+    }
+
+    public void send_updateDocuments(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.UpdatePackage> updatePackages) throws org.apache.thrift.TException
+    {
+      updateDocuments_args args = new updateDocuments_args();
+      args.setOptions(options);
+      args.setUpdatePackages(updatePackages);
+      sendBase("updateDocuments", args);
+    }
+
+    public List<org.apache.blur.thrift.generated.Generation> recv_updateDocuments() throws org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.Generation> generations, boolean forceRefresh) throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException
+    {
+      send_blockUntilGenerationIsVisible(generations, forceRefresh);
+      recv_blockUntilGenerationIsVisible();
+    }
+
+    public void send_blockUntilGenerationIsVisible(List<org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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,org.apache.blur.thrift.generated.ShardLayout> shardLayout(String table) throws org.apache.blur.thrift.generated.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,org.apache.blur.thrift.generated.ShardLayout> recv_shardLayout() throws org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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(org.apache.blur.thrift.generated.TableDescriptor tableDescriptor) throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException
+    {
+      send_createTable(tableDescriptor);
+      recv_createTable();
+    }
+
+    public void send_createTable(org.apache.blur.thrift.generated.TableDescriptor tableDescriptor) throws org.apache.thrift.TException
+    {
+      createTable_args args = new createTable_args();
+      args.setTableDescriptor(tableDescriptor);
+      sendBase("createTable", args);
+    }
+
+    public void recv_createTable() throws org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException
+    {
+      removeTable_result result = new removeTable_result();
+      receiveBase(result, "removeTable");
+      if (result.ex != null) {
+        throw result.ex;
+      }
+      return;
+    }
+
+    public org.apache.blur.thrift.generated.TableDescriptor describe(String table) throws org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.TableDescriptor recv_describe() throws org.apache.blur.thrift.generated.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(org.apache.blur.thrift.generated.Session session, String server, String id) throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException
+    {
+      send_cancelQuery(session, server, id);
+      recv_cancelQuery();
+    }
+
+    public void send_cancelQuery(org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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(org.apache.blur.thrift.generated.Session session, String server) throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException
+    {
+      send_queryStatusIdList(session, server);
+      return recv_queryStatusIdList();
+    }
+
+    public void send_queryStatusIdList(org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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,org.apache.blur.thrift.generated.QueryStatus> queryStatus(org.apache.blur.thrift.generated.Session session, String server, String id) throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException
+    {
+      send_queryStatus(session, server, id);
+      return recv_queryStatus();
+    }
+
+    public void send_queryStatus(org.apache.blur.thrift.generated.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,org.apache.blur.thrift.generated.QueryStatus> recv_queryStatus() throws org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.TableSchema schema(org.apache.blur.thrift.generated.Session session) throws org.apache.blur.thrift.generated.BlurException, org.apache.thrift.TException
+    {
+      send_schema(session);
+      return recv_schema();
+    }
+
+    public void send_schema(org.apache.blur.thrift.generated.Session session) throws org.apache.thrift.TException
+    {
+      schema_args args = new schema_args();
+      args.setSession(session);
+      sendBase("schema", args);
+    }
+
+    public org.apache.blur.thrift.generated.TableSchema recv_schema() throws org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.TableStats tableStats(String table) throws org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.TableStats recv_tableStats() throws org.apache.blur.thrift.generated.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.blur.thrift.generated.DocumentGroupService.AsyncClient 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 org.apache.blur.thrift.generated.Session getResult() throws org.apache.blur.thrift.generated.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(org.apache.blur.thrift.generated.Session session, org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.Session session;
+      private org.apache.blur.thrift.generated.QueryArgs queryArgs;
+      public search_call(org.apache.blur.thrift.generated.Session session, org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.TopFieldDocs> getResult() throws org.apache.blur.thrift.generated.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(org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.Session session;
+      private List<Long> docLocations;
+      private Set<String> fields;
+      public doc_call(org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.Document> getResult() throws org.apache.blur.thrift.generated.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(org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.Session session;
+      public closeReadSession_call(org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.MutateOptions options;
+      private List<org.apache.blur.thrift.generated.Document> documents;
+      public addDocuments_call(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.Generation> getResult() throws org.apache.blur.thrift.generated.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(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.MutateOptions options;
+      private List<org.apache.blur.thrift.generated.Query> queries;
+      public deleteDocumentsByQueries_call(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.Generation> getResult() throws org.apache.blur.thrift.generated.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(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.MutateOptions options;
+      private List<org.apache.blur.thrift.generated.Term> terms;
+      public deleteDocuments_call(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.Generation> getResult() throws org.apache.blur.thrift.generated.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(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.MutateOptions options;
+      private List<org.apache.blur.thrift.generated.UpdatePackage> updatePackages;
+      public updateDocuments_call(org.apache.blur.thrift.generated.MutateOptions options, List<org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.Generation> getResult() throws org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.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<org.apache.blur.thrift.generated.Generation> generations;
+      private boolean forceRefresh;
+      public blockUntilGenerationIsVisible_call(List<org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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,org.apache.blur.thrift.generated.ShardLayout> getResult() throws org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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(org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.TableDescriptor tableDescriptor;
+      public createTable_call(org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.TableDescriptor getResult() throws org.apache.blur.thrift.generated.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(org.apache.blur.thrift.generated.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 org.apache.blur.thrift.generated.Session session;
+      private String server;
+      private String id;
+      public cancelQuery_call(org.apache.blur.thrift.generated.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

<TRUNCATED>

Mime
View raw message