incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [13/14] Small changes to RPC and the addDocuments method is now implemented.
Date Sun, 04 Nov 2012 02:17:15 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/beb7527a/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Lucene.java
----------------------------------------------------------------------
diff --git a/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Lucene.java b/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Lucene.java
index d1ac11c..f0e8bea 100644
--- a/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Lucene.java
+++ b/src/blur-thrift/src/main/java/org/apache/blur/thrift/generated/Lucene.java
@@ -61,19 +61,13 @@ public class Lucene {
 
     public void closeReadSession(Session session) throws BlurException, org.apache.thrift.TException;
 
-    public Session openWriteSession(String table) throws BlurException, org.apache.thrift.TException;
+    public void addDocuments(String table, int shardIndex, List<Document> document) throws BlurException, org.apache.thrift.TException;
 
-    public void addDocuments(Session session, int shardIndex, List<Document> document) throws BlurException, org.apache.thrift.TException;
+    public void deleteDocumentsByQueries(String table, int shardIndex, List<QueryArgs> queries) throws BlurException, org.apache.thrift.TException;
 
-    public void deleteDocumentsByQueries(Session session, int shardIndex, List<QueryArgs> queries) throws BlurException, org.apache.thrift.TException;
+    public void deleteDocuments(String table, int shardIndex, List<Term> terms) throws BlurException, org.apache.thrift.TException;
 
-    public void deleteDocuments(Session session, int shardIndex, List<Term> terms) throws BlurException, org.apache.thrift.TException;
-
-    public void updateDocuments(Session session, int shardIndex, List<Term> terms, List<Document> document) throws BlurException, org.apache.thrift.TException;
-
-    public void commit(Session session) throws BlurException, org.apache.thrift.TException;
-
-    public void rollback(Session session) throws BlurException, org.apache.thrift.TException;
+    public void updateDocuments(String table, int shardIndex, List<Term> terms, List<Document> document) throws BlurException, org.apache.thrift.TException;
 
   }
 
@@ -87,19 +81,13 @@ public class Lucene {
 
     public void closeReadSession(Session session, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.closeReadSession_call> resultHandler) throws org.apache.thrift.TException;
 
-    public void openWriteSession(String table, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.openWriteSession_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void addDocuments(Session session, int shardIndex, List<Document> document, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.addDocuments_call> resultHandler) throws org.apache.thrift.TException;
+    public void addDocuments(String table, int shardIndex, List<Document> document, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.addDocuments_call> resultHandler) throws org.apache.thrift.TException;
 
-    public void deleteDocumentsByQueries(Session session, int shardIndex, List<QueryArgs> queries, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteDocumentsByQueries_call> resultHandler) throws org.apache.thrift.TException;
+    public void deleteDocumentsByQueries(String table, int shardIndex, List<QueryArgs> queries, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteDocumentsByQueries_call> resultHandler) throws org.apache.thrift.TException;
 
-    public void deleteDocuments(Session session, int shardIndex, List<Term> terms, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteDocuments_call> resultHandler) throws org.apache.thrift.TException;
+    public void deleteDocuments(String table, int shardIndex, List<Term> terms, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteDocuments_call> resultHandler) throws org.apache.thrift.TException;
 
-    public void updateDocuments(Session session, int shardIndex, List<Term> terms, List<Document> document, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.updateDocuments_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void commit(Session session, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.commit_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void rollback(Session session, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.rollback_call> resultHandler) throws org.apache.thrift.TException;
+    public void updateDocuments(String table, int shardIndex, List<Term> terms, List<Document> document, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.updateDocuments_call> resultHandler) throws org.apache.thrift.TException;
 
   }
 
@@ -227,42 +215,16 @@ public class Lucene {
       return;
     }
 
-    public Session openWriteSession(String table) throws BlurException, org.apache.thrift.TException
-    {
-      send_openWriteSession(table);
-      return recv_openWriteSession();
-    }
-
-    public void send_openWriteSession(String table) throws org.apache.thrift.TException
-    {
-      openWriteSession_args args = new openWriteSession_args();
-      args.setTable(table);
-      sendBase("openWriteSession", args);
-    }
-
-    public Session recv_openWriteSession() throws BlurException, org.apache.thrift.TException
-    {
-      openWriteSession_result result = new openWriteSession_result();
-      receiveBase(result, "openWriteSession");
-      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, "openWriteSession failed: unknown result");
-    }
-
-    public void addDocuments(Session session, int shardIndex, List<Document> document) throws BlurException, org.apache.thrift.TException
+    public void addDocuments(String table, int shardIndex, List<Document> document) throws BlurException, org.apache.thrift.TException
     {
-      send_addDocuments(session, shardIndex, document);
+      send_addDocuments(table, shardIndex, document);
       recv_addDocuments();
     }
 
-    public void send_addDocuments(Session session, int shardIndex, List<Document> document) throws org.apache.thrift.TException
+    public void send_addDocuments(String table, int shardIndex, List<Document> document) throws org.apache.thrift.TException
     {
       addDocuments_args args = new addDocuments_args();
-      args.setSession(session);
+      args.setTable(table);
       args.setShardIndex(shardIndex);
       args.setDocument(document);
       sendBase("addDocuments", args);
@@ -278,16 +240,16 @@ public class Lucene {
       return;
     }
 
-    public void deleteDocumentsByQueries(Session session, int shardIndex, List<QueryArgs> queries) throws BlurException, org.apache.thrift.TException
+    public void deleteDocumentsByQueries(String table, int shardIndex, List<QueryArgs> queries) throws BlurException, org.apache.thrift.TException
     {
-      send_deleteDocumentsByQueries(session, shardIndex, queries);
+      send_deleteDocumentsByQueries(table, shardIndex, queries);
       recv_deleteDocumentsByQueries();
     }
 
-    public void send_deleteDocumentsByQueries(Session session, int shardIndex, List<QueryArgs> queries) throws org.apache.thrift.TException
+    public void send_deleteDocumentsByQueries(String table, int shardIndex, List<QueryArgs> queries) throws org.apache.thrift.TException
     {
       deleteDocumentsByQueries_args args = new deleteDocumentsByQueries_args();
-      args.setSession(session);
+      args.setTable(table);
       args.setShardIndex(shardIndex);
       args.setQueries(queries);
       sendBase("deleteDocumentsByQueries", args);
@@ -303,16 +265,16 @@ public class Lucene {
       return;
     }
 
-    public void deleteDocuments(Session session, int shardIndex, List<Term> terms) throws BlurException, org.apache.thrift.TException
+    public void deleteDocuments(String table, int shardIndex, List<Term> terms) throws BlurException, org.apache.thrift.TException
     {
-      send_deleteDocuments(session, shardIndex, terms);
+      send_deleteDocuments(table, shardIndex, terms);
       recv_deleteDocuments();
     }
 
-    public void send_deleteDocuments(Session session, int shardIndex, List<Term> terms) throws org.apache.thrift.TException
+    public void send_deleteDocuments(String table, int shardIndex, List<Term> terms) throws org.apache.thrift.TException
     {
       deleteDocuments_args args = new deleteDocuments_args();
-      args.setSession(session);
+      args.setTable(table);
       args.setShardIndex(shardIndex);
       args.setTerms(terms);
       sendBase("deleteDocuments", args);
@@ -328,16 +290,16 @@ public class Lucene {
       return;
     }
 
-    public void updateDocuments(Session session, int shardIndex, List<Term> terms, List<Document> document) throws BlurException, org.apache.thrift.TException
+    public void updateDocuments(String table, int shardIndex, List<Term> terms, List<Document> document) throws BlurException, org.apache.thrift.TException
     {
-      send_updateDocuments(session, shardIndex, terms, document);
+      send_updateDocuments(table, shardIndex, terms, document);
       recv_updateDocuments();
     }
 
-    public void send_updateDocuments(Session session, int shardIndex, List<Term> terms, List<Document> document) throws org.apache.thrift.TException
+    public void send_updateDocuments(String table, int shardIndex, List<Term> terms, List<Document> document) throws org.apache.thrift.TException
     {
       updateDocuments_args args = new updateDocuments_args();
-      args.setSession(session);
+      args.setTable(table);
       args.setShardIndex(shardIndex);
       args.setTerms(terms);
       args.setDocument(document);
@@ -354,52 +316,6 @@ public class Lucene {
       return;
     }
 
-    public void commit(Session session) throws BlurException, org.apache.thrift.TException
-    {
-      send_commit(session);
-      recv_commit();
-    }
-
-    public void send_commit(Session session) throws org.apache.thrift.TException
-    {
-      commit_args args = new commit_args();
-      args.setSession(session);
-      sendBase("commit", args);
-    }
-
-    public void recv_commit() throws BlurException, org.apache.thrift.TException
-    {
-      commit_result result = new commit_result();
-      receiveBase(result, "commit");
-      if (result.e != null) {
-        throw result.e;
-      }
-      return;
-    }
-
-    public void rollback(Session session) throws BlurException, org.apache.thrift.TException
-    {
-      send_rollback(session);
-      recv_rollback();
-    }
-
-    public void send_rollback(Session session) throws org.apache.thrift.TException
-    {
-      rollback_args args = new rollback_args();
-      args.setSession(session);
-      sendBase("rollback", args);
-    }
-
-    public void recv_rollback() throws BlurException, org.apache.thrift.TException
-    {
-      rollback_result result = new rollback_result();
-      receiveBase(result, "rollback");
-      if (result.e != null) {
-        throw result.e;
-      }
-      return;
-    }
-
   }
   public static class AsyncClient extends Blur.AsyncClient implements AsyncIface {
     public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {
@@ -555,52 +471,20 @@ public class Lucene {
       }
     }
 
-    public void openWriteSession(String table, org.apache.thrift.async.AsyncMethodCallback<openWriteSession_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      openWriteSession_call method_call = new openWriteSession_call(table, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class openWriteSession_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private String table;
-      public openWriteSession_call(String table, org.apache.thrift.async.AsyncMethodCallback<openWriteSession_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("openWriteSession", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        openWriteSession_args args = new openWriteSession_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_openWriteSession();
-      }
-    }
-
-    public void addDocuments(Session session, int shardIndex, List<Document> document, org.apache.thrift.async.AsyncMethodCallback<addDocuments_call> resultHandler) throws org.apache.thrift.TException {
+    public void addDocuments(String table, int shardIndex, List<Document> document, org.apache.thrift.async.AsyncMethodCallback<addDocuments_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
-      addDocuments_call method_call = new addDocuments_call(session, shardIndex, document, resultHandler, this, ___protocolFactory, ___transport);
+      addDocuments_call method_call = new addDocuments_call(table, shardIndex, document, resultHandler, this, ___protocolFactory, ___transport);
       this.___currentMethod = method_call;
       ___manager.call(method_call);
     }
 
     public static class addDocuments_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private Session session;
+      private String table;
       private int shardIndex;
       private List<Document> document;
-      public addDocuments_call(Session session, int shardIndex, List<Document> document, 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 {
+      public addDocuments_call(String table, int shardIndex, List<Document> document, 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.session = session;
+        this.table = table;
         this.shardIndex = shardIndex;
         this.document = document;
       }
@@ -608,7 +492,7 @@ public class Lucene {
       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.setSession(session);
+        args.setTable(table);
         args.setShardIndex(shardIndex);
         args.setDocument(document);
         args.write(prot);
@@ -625,20 +509,20 @@ public class Lucene {
       }
     }
 
-    public void deleteDocumentsByQueries(Session session, int shardIndex, List<QueryArgs> queries, org.apache.thrift.async.AsyncMethodCallback<deleteDocumentsByQueries_call> resultHandler) throws org.apache.thrift.TException {
+    public void deleteDocumentsByQueries(String table, int shardIndex, List<QueryArgs> queries, org.apache.thrift.async.AsyncMethodCallback<deleteDocumentsByQueries_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
-      deleteDocumentsByQueries_call method_call = new deleteDocumentsByQueries_call(session, shardIndex, queries, resultHandler, this, ___protocolFactory, ___transport);
+      deleteDocumentsByQueries_call method_call = new deleteDocumentsByQueries_call(table, shardIndex, 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 Session session;
+      private String table;
       private int shardIndex;
       private List<QueryArgs> queries;
-      public deleteDocumentsByQueries_call(Session session, int shardIndex, List<QueryArgs> 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 {
+      public deleteDocumentsByQueries_call(String table, int shardIndex, List<QueryArgs> 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.session = session;
+        this.table = table;
         this.shardIndex = shardIndex;
         this.queries = queries;
       }
@@ -646,7 +530,7 @@ public class Lucene {
       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.setSession(session);
+        args.setTable(table);
         args.setShardIndex(shardIndex);
         args.setQueries(queries);
         args.write(prot);
@@ -663,20 +547,20 @@ public class Lucene {
       }
     }
 
-    public void deleteDocuments(Session session, int shardIndex, List<Term> terms, org.apache.thrift.async.AsyncMethodCallback<deleteDocuments_call> resultHandler) throws org.apache.thrift.TException {
+    public void deleteDocuments(String table, int shardIndex, List<Term> terms, org.apache.thrift.async.AsyncMethodCallback<deleteDocuments_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
-      deleteDocuments_call method_call = new deleteDocuments_call(session, shardIndex, terms, resultHandler, this, ___protocolFactory, ___transport);
+      deleteDocuments_call method_call = new deleteDocuments_call(table, shardIndex, 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 Session session;
+      private String table;
       private int shardIndex;
       private List<Term> terms;
-      public deleteDocuments_call(Session session, int shardIndex, 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 {
+      public deleteDocuments_call(String table, int shardIndex, 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.session = session;
+        this.table = table;
         this.shardIndex = shardIndex;
         this.terms = terms;
       }
@@ -684,7 +568,7 @@ public class Lucene {
       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.setSession(session);
+        args.setTable(table);
         args.setShardIndex(shardIndex);
         args.setTerms(terms);
         args.write(prot);
@@ -701,21 +585,21 @@ public class Lucene {
       }
     }
 
-    public void updateDocuments(Session session, int shardIndex, List<Term> terms, List<Document> document, org.apache.thrift.async.AsyncMethodCallback<updateDocuments_call> resultHandler) throws org.apache.thrift.TException {
+    public void updateDocuments(String table, int shardIndex, List<Term> terms, List<Document> document, org.apache.thrift.async.AsyncMethodCallback<updateDocuments_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
-      updateDocuments_call method_call = new updateDocuments_call(session, shardIndex, terms, document, resultHandler, this, ___protocolFactory, ___transport);
+      updateDocuments_call method_call = new updateDocuments_call(table, shardIndex, terms, document, resultHandler, this, ___protocolFactory, ___transport);
       this.___currentMethod = method_call;
       ___manager.call(method_call);
     }
 
     public static class updateDocuments_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private Session session;
+      private String table;
       private int shardIndex;
       private List<Term> terms;
       private List<Document> document;
-      public updateDocuments_call(Session session, int shardIndex, List<Term> terms, List<Document> document, 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 {
+      public updateDocuments_call(String table, int shardIndex, List<Term> terms, List<Document> document, 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.session = session;
+        this.table = table;
         this.shardIndex = shardIndex;
         this.terms = terms;
         this.document = document;
@@ -724,7 +608,7 @@ public class Lucene {
       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.setSession(session);
+        args.setTable(table);
         args.setShardIndex(shardIndex);
         args.setTerms(terms);
         args.setDocument(document);
@@ -742,70 +626,6 @@ public class Lucene {
       }
     }
 
-    public void commit(Session session, org.apache.thrift.async.AsyncMethodCallback<commit_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      commit_call method_call = new commit_call(session, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class commit_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private Session session;
-      public commit_call(Session session, org.apache.thrift.async.AsyncMethodCallback<commit_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("commit", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        commit_args args = new commit_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_commit();
-      }
-    }
-
-    public void rollback(Session session, org.apache.thrift.async.AsyncMethodCallback<rollback_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      rollback_call method_call = new rollback_call(session, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class rollback_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private Session session;
-      public rollback_call(Session session, org.apache.thrift.async.AsyncMethodCallback<rollback_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("rollback", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        rollback_args args = new rollback_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_rollback();
-      }
-    }
-
   }
 
   public static class Processor<I extends Iface> extends Blur.Processor<I> implements org.apache.thrift.TProcessor {
@@ -823,13 +643,10 @@ public class Lucene {
       processMap.put("search", new search());
       processMap.put("doc", new doc());
       processMap.put("closeReadSession", new closeReadSession());
-      processMap.put("openWriteSession", new openWriteSession());
       processMap.put("addDocuments", new addDocuments());
       processMap.put("deleteDocumentsByQueries", new deleteDocumentsByQueries());
       processMap.put("deleteDocuments", new deleteDocuments());
       processMap.put("updateDocuments", new updateDocuments());
-      processMap.put("commit", new commit());
-      processMap.put("rollback", new rollback());
       return processMap;
     }
 
@@ -929,30 +746,6 @@ public class Lucene {
       }
     }
 
-    public static class openWriteSession<I extends Iface> extends org.apache.thrift.ProcessFunction<I, openWriteSession_args> {
-      public openWriteSession() {
-        super("openWriteSession");
-      }
-
-      public openWriteSession_args getEmptyArgsInstance() {
-        return new openWriteSession_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public openWriteSession_result getResult(I iface, openWriteSession_args args) throws org.apache.thrift.TException {
-        openWriteSession_result result = new openWriteSession_result();
-        try {
-          result.success = iface.openWriteSession(args.table);
-        } catch (BlurException e) {
-          result.e = e;
-        }
-        return result;
-      }
-    }
-
     public static class addDocuments<I extends Iface> extends org.apache.thrift.ProcessFunction<I, addDocuments_args> {
       public addDocuments() {
         super("addDocuments");
@@ -969,7 +762,7 @@ public class Lucene {
       public addDocuments_result getResult(I iface, addDocuments_args args) throws org.apache.thrift.TException {
         addDocuments_result result = new addDocuments_result();
         try {
-          iface.addDocuments(args.session, args.shardIndex, args.document);
+          iface.addDocuments(args.table, args.shardIndex, args.document);
         } catch (BlurException e) {
           result.e = e;
         }
@@ -993,7 +786,7 @@ public class Lucene {
       public deleteDocumentsByQueries_result getResult(I iface, deleteDocumentsByQueries_args args) throws org.apache.thrift.TException {
         deleteDocumentsByQueries_result result = new deleteDocumentsByQueries_result();
         try {
-          iface.deleteDocumentsByQueries(args.session, args.shardIndex, args.queries);
+          iface.deleteDocumentsByQueries(args.table, args.shardIndex, args.queries);
         } catch (BlurException e) {
           result.e = e;
         }
@@ -1017,7 +810,7 @@ public class Lucene {
       public deleteDocuments_result getResult(I iface, deleteDocuments_args args) throws org.apache.thrift.TException {
         deleteDocuments_result result = new deleteDocuments_result();
         try {
-          iface.deleteDocuments(args.session, args.shardIndex, args.terms);
+          iface.deleteDocuments(args.table, args.shardIndex, args.terms);
         } catch (BlurException e) {
           result.e = e;
         }
@@ -1041,55 +834,7 @@ public class Lucene {
       public updateDocuments_result getResult(I iface, updateDocuments_args args) throws org.apache.thrift.TException {
         updateDocuments_result result = new updateDocuments_result();
         try {
-          iface.updateDocuments(args.session, args.shardIndex, args.terms, args.document);
-        } catch (BlurException e) {
-          result.e = e;
-        }
-        return result;
-      }
-    }
-
-    public static class commit<I extends Iface> extends org.apache.thrift.ProcessFunction<I, commit_args> {
-      public commit() {
-        super("commit");
-      }
-
-      public commit_args getEmptyArgsInstance() {
-        return new commit_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public commit_result getResult(I iface, commit_args args) throws org.apache.thrift.TException {
-        commit_result result = new commit_result();
-        try {
-          iface.commit(args.session);
-        } catch (BlurException e) {
-          result.e = e;
-        }
-        return result;
-      }
-    }
-
-    public static class rollback<I extends Iface> extends org.apache.thrift.ProcessFunction<I, rollback_args> {
-      public rollback() {
-        super("rollback");
-      }
-
-      public rollback_args getEmptyArgsInstance() {
-        return new rollback_args();
-      }
-
-      protected boolean isOneway() {
-        return false;
-      }
-
-      public rollback_result getResult(I iface, rollback_args args) throws org.apache.thrift.TException {
-        rollback_result result = new rollback_result();
-        try {
-          iface.rollback(args.session);
+          iface.updateDocuments(args.table, args.shardIndex, args.terms, args.document);
         } catch (BlurException e) {
           result.e = e;
         }
@@ -4778,22 +4523,28 @@ public class Lucene {
 
   }
 
-  public static class openWriteSession_args implements org.apache.thrift.TBase<openWriteSession_args, openWriteSession_args._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("openWriteSession_args");
+  public static class addDocuments_args implements org.apache.thrift.TBase<addDocuments_args, addDocuments_args._Fields>, java.io.Serializable, Cloneable   {
+    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("addDocuments_args");
 
     private static final org.apache.thrift.protocol.TField TABLE_FIELD_DESC = new org.apache.thrift.protocol.TField("table", org.apache.thrift.protocol.TType.STRING, (short)1);
+    private static final org.apache.thrift.protocol.TField SHARD_INDEX_FIELD_DESC = new org.apache.thrift.protocol.TField("shardIndex", org.apache.thrift.protocol.TType.I32, (short)2);
+    private static final org.apache.thrift.protocol.TField DOCUMENT_FIELD_DESC = new org.apache.thrift.protocol.TField("document", org.apache.thrift.protocol.TType.LIST, (short)3);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
-      schemes.put(StandardScheme.class, new openWriteSession_argsStandardSchemeFactory());
-      schemes.put(TupleScheme.class, new openWriteSession_argsTupleSchemeFactory());
+      schemes.put(StandardScheme.class, new addDocuments_argsStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new addDocuments_argsTupleSchemeFactory());
     }
 
     public String table; // required
+    public int shardIndex; // required
+    public List<Document> document; // required
 
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
     public enum _Fields implements org.apache.thrift.TFieldIdEnum {
-      TABLE((short)1, "table");
+      TABLE((short)1, "table"),
+      SHARD_INDEX((short)2, "shardIndex"),
+      DOCUMENT((short)3, "document");
 
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -4810,6 +4561,10 @@ public class Lucene {
         switch(fieldId) {
           case 1: // TABLE
             return TABLE;
+          case 2: // SHARD_INDEX
+            return SHARD_INDEX;
+          case 3: // DOCUMENT
+            return DOCUMENT;
           default:
             return null;
         }
@@ -4850,48 +4605,72 @@ public class Lucene {
     }
 
     // isset id assignments
+    private static final int __SHARDINDEX_ISSET_ID = 0;
+    private byte __isset_bitfield = 0;
     public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
     static {
       Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
       tmpMap.put(_Fields.TABLE, new org.apache.thrift.meta_data.FieldMetaData("table", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+      tmpMap.put(_Fields.SHARD_INDEX, new org.apache.thrift.meta_data.FieldMetaData("shardIndex", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
+      tmpMap.put(_Fields.DOCUMENT, new org.apache.thrift.meta_data.FieldMetaData("document", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+          new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, 
+              new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Document.class))));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(openWriteSession_args.class, metaDataMap);
+      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(addDocuments_args.class, metaDataMap);
     }
 
-    public openWriteSession_args() {
+    public addDocuments_args() {
     }
 
-    public openWriteSession_args(
-      String table)
+    public addDocuments_args(
+      String table,
+      int shardIndex,
+      List<Document> document)
     {
       this();
       this.table = table;
+      this.shardIndex = shardIndex;
+      setShardIndexIsSet(true);
+      this.document = document;
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public openWriteSession_args(openWriteSession_args other) {
+    public addDocuments_args(addDocuments_args other) {
+      __isset_bitfield = other.__isset_bitfield;
       if (other.isSetTable()) {
         this.table = other.table;
       }
+      this.shardIndex = other.shardIndex;
+      if (other.isSetDocument()) {
+        List<Document> __this__document = new ArrayList<Document>();
+        for (Document other_element : other.document) {
+          __this__document.add(new Document(other_element));
+        }
+        this.document = __this__document;
+      }
     }
 
-    public openWriteSession_args deepCopy() {
-      return new openWriteSession_args(this);
+    public addDocuments_args deepCopy() {
+      return new addDocuments_args(this);
     }
 
     @Override
     public void clear() {
       this.table = null;
+      setShardIndexIsSet(false);
+      this.shardIndex = 0;
+      this.document = null;
     }
 
     public String getTable() {
       return this.table;
     }
 
-    public openWriteSession_args setTable(String table) {
+    public addDocuments_args setTable(String table) {
       this.table = table;
       return this;
     }
@@ -4911,16 +4690,94 @@ public class Lucene {
       }
     }
 
-    public void setFieldValue(_Fields field, Object value) {
-      switch (field) {
-      case TABLE:
-        if (value == null) {
-          unsetTable();
+    public int getShardIndex() {
+      return this.shardIndex;
+    }
+
+    public addDocuments_args setShardIndex(int shardIndex) {
+      this.shardIndex = shardIndex;
+      setShardIndexIsSet(true);
+      return this;
+    }
+
+    public void unsetShardIndex() {
+      __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __SHARDINDEX_ISSET_ID);
+    }
+
+    /** Returns true if field shardIndex is set (has been assigned a value) and false otherwise */
+    public boolean isSetShardIndex() {
+      return EncodingUtils.testBit(__isset_bitfield, __SHARDINDEX_ISSET_ID);
+    }
+
+    public void setShardIndexIsSet(boolean value) {
+      __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SHARDINDEX_ISSET_ID, value);
+    }
+
+    public int getDocumentSize() {
+      return (this.document == null) ? 0 : this.document.size();
+    }
+
+    public java.util.Iterator<Document> getDocumentIterator() {
+      return (this.document == null) ? null : this.document.iterator();
+    }
+
+    public void addToDocument(Document elem) {
+      if (this.document == null) {
+        this.document = new ArrayList<Document>();
+      }
+      this.document.add(elem);
+    }
+
+    public List<Document> getDocument() {
+      return this.document;
+    }
+
+    public addDocuments_args setDocument(List<Document> document) {
+      this.document = document;
+      return this;
+    }
+
+    public void unsetDocument() {
+      this.document = null;
+    }
+
+    /** Returns true if field document is set (has been assigned a value) and false otherwise */
+    public boolean isSetDocument() {
+      return this.document != null;
+    }
+
+    public void setDocumentIsSet(boolean value) {
+      if (!value) {
+        this.document = null;
+      }
+    }
+
+    public void setFieldValue(_Fields field, Object value) {
+      switch (field) {
+      case TABLE:
+        if (value == null) {
+          unsetTable();
         } else {
           setTable((String)value);
         }
         break;
 
+      case SHARD_INDEX:
+        if (value == null) {
+          unsetShardIndex();
+        } else {
+          setShardIndex((Integer)value);
+        }
+        break;
+
+      case DOCUMENT:
+        if (value == null) {
+          unsetDocument();
+        } else {
+          setDocument((List<Document>)value);
+        }
+        break;
+
       }
     }
 
@@ -4929,6 +4786,12 @@ public class Lucene {
       case TABLE:
         return getTable();
 
+      case SHARD_INDEX:
+        return Integer.valueOf(getShardIndex());
+
+      case DOCUMENT:
+        return getDocument();
+
       }
       throw new IllegalStateException();
     }
@@ -4942,6 +4805,10 @@ public class Lucene {
       switch (field) {
       case TABLE:
         return isSetTable();
+      case SHARD_INDEX:
+        return isSetShardIndex();
+      case DOCUMENT:
+        return isSetDocument();
       }
       throw new IllegalStateException();
     }
@@ -4950,12 +4817,12 @@ public class Lucene {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof openWriteSession_args)
-        return this.equals((openWriteSession_args)that);
+      if (that instanceof addDocuments_args)
+        return this.equals((addDocuments_args)that);
       return false;
     }
 
-    public boolean equals(openWriteSession_args that) {
+    public boolean equals(addDocuments_args that) {
       if (that == null)
         return false;
 
@@ -4968,6 +4835,24 @@ public class Lucene {
           return false;
       }
 
+      boolean this_present_shardIndex = true;
+      boolean that_present_shardIndex = true;
+      if (this_present_shardIndex || that_present_shardIndex) {
+        if (!(this_present_shardIndex && that_present_shardIndex))
+          return false;
+        if (this.shardIndex != that.shardIndex)
+          return false;
+      }
+
+      boolean this_present_document = true && this.isSetDocument();
+      boolean that_present_document = true && that.isSetDocument();
+      if (this_present_document || that_present_document) {
+        if (!(this_present_document && that_present_document))
+          return false;
+        if (!this.document.equals(that.document))
+          return false;
+      }
+
       return true;
     }
 
@@ -4976,13 +4861,13 @@ public class Lucene {
       return 0;
     }
 
-    public int compareTo(openWriteSession_args other) {
+    public int compareTo(addDocuments_args other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
-      openWriteSession_args typedOther = (openWriteSession_args)other;
+      addDocuments_args typedOther = (addDocuments_args)other;
 
       lastComparison = Boolean.valueOf(isSetTable()).compareTo(typedOther.isSetTable());
       if (lastComparison != 0) {
@@ -4994,6 +4879,26 @@ public class Lucene {
           return lastComparison;
         }
       }
+      lastComparison = Boolean.valueOf(isSetShardIndex()).compareTo(typedOther.isSetShardIndex());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      if (isSetShardIndex()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.shardIndex, typedOther.shardIndex);
+        if (lastComparison != 0) {
+          return lastComparison;
+        }
+      }
+      lastComparison = Boolean.valueOf(isSetDocument()).compareTo(typedOther.isSetDocument());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      if (isSetDocument()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.document, typedOther.document);
+        if (lastComparison != 0) {
+          return lastComparison;
+        }
+      }
       return 0;
     }
 
@@ -5011,7 +4916,7 @@ public class Lucene {
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("openWriteSession_args(");
+      StringBuilder sb = new StringBuilder("addDocuments_args(");
       boolean first = true;
 
       sb.append("table:");
@@ -5021,6 +4926,18 @@ public class Lucene {
         sb.append(this.table);
       }
       first = false;
+      if (!first) sb.append(", ");
+      sb.append("shardIndex:");
+      sb.append(this.shardIndex);
+      first = false;
+      if (!first) sb.append(", ");
+      sb.append("document:");
+      if (this.document == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.document);
+      }
+      first = false;
       sb.append(")");
       return sb.toString();
     }
@@ -5040,21 +4957,23 @@ public class Lucene {
 
     private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
       try {
+        // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+        __isset_bitfield = 0;
         read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
       } catch (org.apache.thrift.TException te) {
         throw new java.io.IOException(te);
       }
     }
 
-    private static class openWriteSession_argsStandardSchemeFactory implements SchemeFactory {
-      public openWriteSession_argsStandardScheme getScheme() {
-        return new openWriteSession_argsStandardScheme();
+    private static class addDocuments_argsStandardSchemeFactory implements SchemeFactory {
+      public addDocuments_argsStandardScheme getScheme() {
+        return new addDocuments_argsStandardScheme();
       }
     }
 
-    private static class openWriteSession_argsStandardScheme extends StandardScheme<openWriteSession_args> {
+    private static class addDocuments_argsStandardScheme extends StandardScheme<addDocuments_args> {
 
-      public void read(org.apache.thrift.protocol.TProtocol iprot, openWriteSession_args struct) throws org.apache.thrift.TException {
+      public void read(org.apache.thrift.protocol.TProtocol iprot, addDocuments_args struct) throws org.apache.thrift.TException {
         org.apache.thrift.protocol.TField schemeField;
         iprot.readStructBegin();
         while (true)
@@ -5072,6 +4991,33 @@ public class Lucene {
                 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
               }
               break;
+            case 2: // SHARD_INDEX
+              if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
+                struct.shardIndex = iprot.readI32();
+                struct.setShardIndexIsSet(true);
+              } else { 
+                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
+            case 3: // DOCUMENT
+              if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+                {
+                  org.apache.thrift.protocol.TList _list348 = iprot.readListBegin();
+                  struct.document = new ArrayList<Document>(_list348.size);
+                  for (int _i349 = 0; _i349 < _list348.size; ++_i349)
+                  {
+                    Document _elem350; // required
+                    _elem350 = new Document();
+                    _elem350.read(iprot);
+                    struct.document.add(_elem350);
+                  }
+                  iprot.readListEnd();
+                }
+                struct.setDocumentIsSet(true);
+              } else { 
+                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+              }
+              break;
             default:
               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
           }
@@ -5083,7 +5029,7 @@ public class Lucene {
         struct.validate();
       }
 
-      public void write(org.apache.thrift.protocol.TProtocol oprot, openWriteSession_args struct) throws org.apache.thrift.TException {
+      public void write(org.apache.thrift.protocol.TProtocol oprot, addDocuments_args struct) throws org.apache.thrift.TException {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
@@ -5092,64 +5038,112 @@ public class Lucene {
           oprot.writeString(struct.table);
           oprot.writeFieldEnd();
         }
+        oprot.writeFieldBegin(SHARD_INDEX_FIELD_DESC);
+        oprot.writeI32(struct.shardIndex);
+        oprot.writeFieldEnd();
+        if (struct.document != null) {
+          oprot.writeFieldBegin(DOCUMENT_FIELD_DESC);
+          {
+            oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.document.size()));
+            for (Document _iter351 : struct.document)
+            {
+              _iter351.write(oprot);
+            }
+            oprot.writeListEnd();
+          }
+          oprot.writeFieldEnd();
+        }
         oprot.writeFieldStop();
         oprot.writeStructEnd();
       }
 
     }
 
-    private static class openWriteSession_argsTupleSchemeFactory implements SchemeFactory {
-      public openWriteSession_argsTupleScheme getScheme() {
-        return new openWriteSession_argsTupleScheme();
+    private static class addDocuments_argsTupleSchemeFactory implements SchemeFactory {
+      public addDocuments_argsTupleScheme getScheme() {
+        return new addDocuments_argsTupleScheme();
       }
     }
 
-    private static class openWriteSession_argsTupleScheme extends TupleScheme<openWriteSession_args> {
+    private static class addDocuments_argsTupleScheme extends TupleScheme<addDocuments_args> {
 
       @Override
-      public void write(org.apache.thrift.protocol.TProtocol prot, openWriteSession_args struct) throws org.apache.thrift.TException {
+      public void write(org.apache.thrift.protocol.TProtocol prot, addDocuments_args struct) throws org.apache.thrift.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
         if (struct.isSetTable()) {
           optionals.set(0);
         }
-        oprot.writeBitSet(optionals, 1);
+        if (struct.isSetShardIndex()) {
+          optionals.set(1);
+        }
+        if (struct.isSetDocument()) {
+          optionals.set(2);
+        }
+        oprot.writeBitSet(optionals, 3);
         if (struct.isSetTable()) {
           oprot.writeString(struct.table);
         }
+        if (struct.isSetShardIndex()) {
+          oprot.writeI32(struct.shardIndex);
+        }
+        if (struct.isSetDocument()) {
+          {
+            oprot.writeI32(struct.document.size());
+            for (Document _iter352 : struct.document)
+            {
+              _iter352.write(oprot);
+            }
+          }
+        }
       }
 
       @Override
-      public void read(org.apache.thrift.protocol.TProtocol prot, openWriteSession_args struct) throws org.apache.thrift.TException {
+      public void read(org.apache.thrift.protocol.TProtocol prot, addDocuments_args struct) throws org.apache.thrift.TException {
         TTupleProtocol iprot = (TTupleProtocol) prot;
-        BitSet incoming = iprot.readBitSet(1);
+        BitSet incoming = iprot.readBitSet(3);
         if (incoming.get(0)) {
           struct.table = iprot.readString();
           struct.setTableIsSet(true);
         }
+        if (incoming.get(1)) {
+          struct.shardIndex = iprot.readI32();
+          struct.setShardIndexIsSet(true);
+        }
+        if (incoming.get(2)) {
+          {
+            org.apache.thrift.protocol.TList _list353 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+            struct.document = new ArrayList<Document>(_list353.size);
+            for (int _i354 = 0; _i354 < _list353.size; ++_i354)
+            {
+              Document _elem355; // required
+              _elem355 = new Document();
+              _elem355.read(iprot);
+              struct.document.add(_elem355);
+            }
+          }
+          struct.setDocumentIsSet(true);
+        }
       }
     }
 
   }
 
-  public static class openWriteSession_result implements org.apache.thrift.TBase<openWriteSession_result, openWriteSession_result._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("openWriteSession_result");
+  public static class addDocuments_result implements org.apache.thrift.TBase<addDocuments_result, addDocuments_result._Fields>, java.io.Serializable, Cloneable   {
+    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("addDocuments_result");
 
-    private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRUCT, (short)0);
     private static final org.apache.thrift.protocol.TField E_FIELD_DESC = new org.apache.thrift.protocol.TField("e", org.apache.thrift.protocol.TType.STRUCT, (short)1);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
-      schemes.put(StandardScheme.class, new openWriteSession_resultStandardSchemeFactory());
-      schemes.put(TupleScheme.class, new openWriteSession_resultTupleSchemeFactory());
+      schemes.put(StandardScheme.class, new addDocuments_resultStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new addDocuments_resultTupleSchemeFactory());
     }
 
-    public Session success; // required
     public BlurException e; // required
 
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
     public enum _Fields implements org.apache.thrift.TFieldIdEnum {
-      SUCCESS((short)0, "success"),
       E((short)1, "e");
 
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -5165,8 +5159,6 @@ public class Lucene {
        */
       public static _Fields findByThriftId(int fieldId) {
         switch(fieldId) {
-          case 0: // SUCCESS
-            return SUCCESS;
           case 1: // E
             return E;
           default:
@@ -5212,77 +5204,45 @@ public class Lucene {
     public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
     static {
       Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
-      tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT, 
-          new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Session.class)));
       tmpMap.put(_Fields.E, new org.apache.thrift.meta_data.FieldMetaData("e", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(openWriteSession_result.class, metaDataMap);
+      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(addDocuments_result.class, metaDataMap);
     }
 
-    public openWriteSession_result() {
+    public addDocuments_result() {
     }
 
-    public openWriteSession_result(
-      Session success,
+    public addDocuments_result(
       BlurException e)
     {
       this();
-      this.success = success;
       this.e = e;
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public openWriteSession_result(openWriteSession_result other) {
-      if (other.isSetSuccess()) {
-        this.success = new Session(other.success);
-      }
+    public addDocuments_result(addDocuments_result other) {
       if (other.isSetE()) {
         this.e = new BlurException(other.e);
       }
     }
 
-    public openWriteSession_result deepCopy() {
-      return new openWriteSession_result(this);
+    public addDocuments_result deepCopy() {
+      return new addDocuments_result(this);
     }
 
     @Override
     public void clear() {
-      this.success = null;
       this.e = null;
     }
 
-    public Session getSuccess() {
-      return this.success;
-    }
-
-    public openWriteSession_result setSuccess(Session success) {
-      this.success = success;
-      return this;
-    }
-
-    public void unsetSuccess() {
-      this.success = null;
-    }
-
-    /** Returns true if field success is set (has been assigned a value) and false otherwise */
-    public boolean isSetSuccess() {
-      return this.success != null;
-    }
-
-    public void setSuccessIsSet(boolean value) {
-      if (!value) {
-        this.success = null;
-      }
-    }
-
     public BlurException getE() {
       return this.e;
     }
 
-    public openWriteSession_result setE(BlurException e) {
+    public addDocuments_result setE(BlurException e) {
       this.e = e;
       return this;
     }
@@ -5304,14 +5264,6 @@ public class Lucene {
 
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
-      case SUCCESS:
-        if (value == null) {
-          unsetSuccess();
-        } else {
-          setSuccess((Session)value);
-        }
-        break;
-
       case E:
         if (value == null) {
           unsetE();
@@ -5325,9 +5277,6 @@ public class Lucene {
 
     public Object getFieldValue(_Fields field) {
       switch (field) {
-      case SUCCESS:
-        return getSuccess();
-
       case E:
         return getE();
 
@@ -5342,8 +5291,6 @@ public class Lucene {
       }
 
       switch (field) {
-      case SUCCESS:
-        return isSetSuccess();
       case E:
         return isSetE();
       }
@@ -5354,24 +5301,15 @@ public class Lucene {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof openWriteSession_result)
-        return this.equals((openWriteSession_result)that);
+      if (that instanceof addDocuments_result)
+        return this.equals((addDocuments_result)that);
       return false;
     }
 
-    public boolean equals(openWriteSession_result that) {
+    public boolean equals(addDocuments_result that) {
       if (that == null)
         return false;
 
-      boolean this_present_success = true && this.isSetSuccess();
-      boolean that_present_success = true && that.isSetSuccess();
-      if (this_present_success || that_present_success) {
-        if (!(this_present_success && that_present_success))
-          return false;
-        if (!this.success.equals(that.success))
-          return false;
-      }
-
       boolean this_present_e = true && this.isSetE();
       boolean that_present_e = true && that.isSetE();
       if (this_present_e || that_present_e) {
@@ -5389,24 +5327,14 @@ public class Lucene {
       return 0;
     }
 
-    public int compareTo(openWriteSession_result other) {
+    public int compareTo(addDocuments_result other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
-      openWriteSession_result typedOther = (openWriteSession_result)other;
+      addDocuments_result typedOther = (addDocuments_result)other;
 
-      lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess());
-      if (lastComparison != 0) {
-        return lastComparison;
-      }
-      if (isSetSuccess()) {
-        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, typedOther.success);
-        if (lastComparison != 0) {
-          return lastComparison;
-        }
-      }
       lastComparison = Boolean.valueOf(isSetE()).compareTo(typedOther.isSetE());
       if (lastComparison != 0) {
         return lastComparison;
@@ -5434,17 +5362,9 @@ public class Lucene {
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("openWriteSession_result(");
+      StringBuilder sb = new StringBuilder("addDocuments_result(");
       boolean first = true;
 
-      sb.append("success:");
-      if (this.success == null) {
-        sb.append("null");
-      } else {
-        sb.append(this.success);
-      }
-      first = false;
-      if (!first) sb.append(", ");
       sb.append("e:");
       if (this.e == null) {
         sb.append("null");
@@ -5459,9 +5379,6 @@ public class Lucene {
     public void validate() throws org.apache.thrift.TException {
       // check for required fields
       // check for sub-struct validity
-      if (success != null) {
-        success.validate();
-      }
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -5480,15 +5397,15 @@ public class Lucene {
       }
     }
 
-    private static class openWriteSession_resultStandardSchemeFactory implements SchemeFactory {
-      public openWriteSession_resultStandardScheme getScheme() {
-        return new openWriteSession_resultStandardScheme();
+    private static class addDocuments_resultStandardSchemeFactory implements SchemeFactory {
+      public addDocuments_resultStandardScheme getScheme() {
+        return new addDocuments_resultStandardScheme();
       }
     }
 
-    private static class openWriteSession_resultStandardScheme extends StandardScheme<openWriteSession_result> {
+    private static class addDocuments_resultStandardScheme extends StandardScheme<addDocuments_result> {
 
-      public void read(org.apache.thrift.protocol.TProtocol iprot, openWriteSession_result struct) throws org.apache.thrift.TException {
+      public void read(org.apache.thrift.protocol.TProtocol iprot, addDocuments_result struct) throws org.apache.thrift.TException {
         org.apache.thrift.protocol.TField schemeField;
         iprot.readStructBegin();
         while (true)
@@ -5498,15 +5415,6 @@ public class Lucene {
             break;
           }
           switch (schemeField.id) {
-            case 0: // SUCCESS
-              if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
-                struct.success = new Session();
-                struct.success.read(iprot);
-                struct.setSuccessIsSet(true);
-              } else { 
-                org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
-              }
-              break;
             case 1: // E
               if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
                 struct.e = new BlurException();
@@ -5527,15 +5435,10 @@ public class Lucene {
         struct.validate();
       }
 
-      public void write(org.apache.thrift.protocol.TProtocol oprot, openWriteSession_result struct) throws org.apache.thrift.TException {
+      public void write(org.apache.thrift.protocol.TProtocol oprot, addDocuments_result struct) throws org.apache.thrift.TException {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
-        if (struct.success != null) {
-          oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
-          struct.success.write(oprot);
-          oprot.writeFieldEnd();
-        }
         if (struct.e != null) {
           oprot.writeFieldBegin(E_FIELD_DESC);
           struct.e.write(oprot);
@@ -5547,43 +5450,32 @@ public class Lucene {
 
     }
 
-    private static class openWriteSession_resultTupleSchemeFactory implements SchemeFactory {
-      public openWriteSession_resultTupleScheme getScheme() {
-        return new openWriteSession_resultTupleScheme();
+    private static class addDocuments_resultTupleSchemeFactory implements SchemeFactory {
+      public addDocuments_resultTupleScheme getScheme() {
+        return new addDocuments_resultTupleScheme();
       }
     }
 
-    private static class openWriteSession_resultTupleScheme extends TupleScheme<openWriteSession_result> {
+    private static class addDocuments_resultTupleScheme extends TupleScheme<addDocuments_result> {
 
       @Override
-      public void write(org.apache.thrift.protocol.TProtocol prot, openWriteSession_result struct) throws org.apache.thrift.TException {
+      public void write(org.apache.thrift.protocol.TProtocol prot, addDocuments_result struct) throws org.apache.thrift.TException {
         TTupleProtocol oprot = (TTupleProtocol) prot;
         BitSet optionals = new BitSet();
-        if (struct.isSetSuccess()) {
-          optionals.set(0);
-        }
         if (struct.isSetE()) {
-          optionals.set(1);
-        }
-        oprot.writeBitSet(optionals, 2);
-        if (struct.isSetSuccess()) {
-          struct.success.write(oprot);
+          optionals.set(0);
         }
+        oprot.writeBitSet(optionals, 1);
         if (struct.isSetE()) {
           struct.e.write(oprot);
         }
       }
 
       @Override
-      public void read(org.apache.thrift.protocol.TProtocol prot, openWriteSession_result struct) throws org.apache.thrift.TException {
+      public void read(org.apache.thrift.protocol.TProtocol prot, addDocuments_result struct) throws org.apache.thrift.TException {
         TTupleProtocol iprot = (TTupleProtocol) prot;
-        BitSet incoming = iprot.readBitSet(2);
+        BitSet incoming = iprot.readBitSet(1);
         if (incoming.get(0)) {
-          struct.success = new Session();
-          struct.success.read(iprot);
-          struct.setSuccessIsSet(true);
-        }
-        if (incoming.get(1)) {
           struct.e = new BlurException();
           struct.e.read(iprot);
           struct.setEIsSet(true);
@@ -5593,28 +5485,28 @@ public class Lucene {
 
   }
 
-  public static class addDocuments_args implements org.apache.thrift.TBase<addDocuments_args, addDocuments_args._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("addDocuments_args");
+  public static class deleteDocumentsByQueries_args implements org.apache.thrift.TBase<deleteDocumentsByQueries_args, deleteDocumentsByQueries_args._Fields>, java.io.Serializable, Cloneable   {
+    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("deleteDocumentsByQueries_args");
 
-    private static final org.apache.thrift.protocol.TField SESSION_FIELD_DESC = new org.apache.thrift.protocol.TField("session", org.apache.thrift.protocol.TType.STRUCT, (short)1);
+    private static final org.apache.thrift.protocol.TField TABLE_FIELD_DESC = new org.apache.thrift.protocol.TField("table", org.apache.thrift.protocol.TType.STRING, (short)1);
     private static final org.apache.thrift.protocol.TField SHARD_INDEX_FIELD_DESC = new org.apache.thrift.protocol.TField("shardIndex", org.apache.thrift.protocol.TType.I32, (short)2);
-    private static final org.apache.thrift.protocol.TField DOCUMENT_FIELD_DESC = new org.apache.thrift.protocol.TField("document", org.apache.thrift.protocol.TType.LIST, (short)3);
+    private static final org.apache.thrift.protocol.TField QUERIES_FIELD_DESC = new org.apache.thrift.protocol.TField("queries", org.apache.thrift.protocol.TType.LIST, (short)3);
 
     private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
     static {
-      schemes.put(StandardScheme.class, new addDocuments_argsStandardSchemeFactory());
-      schemes.put(TupleScheme.class, new addDocuments_argsTupleSchemeFactory());
+      schemes.put(StandardScheme.class, new deleteDocumentsByQueries_argsStandardSchemeFactory());
+      schemes.put(TupleScheme.class, new deleteDocumentsByQueries_argsTupleSchemeFactory());
     }
 
-    public Session session; // required
+    public String table; // required
     public int shardIndex; // required
-    public List<Document> document; // required
+    public List<QueryArgs> queries; // required
 
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
     public enum _Fields implements org.apache.thrift.TFieldIdEnum {
-      SESSION((short)1, "session"),
+      TABLE((short)1, "table"),
       SHARD_INDEX((short)2, "shardIndex"),
-      DOCUMENT((short)3, "document");
+      QUERIES((short)3, "queries");
 
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -5629,12 +5521,12 @@ public class Lucene {
        */
       public static _Fields findByThriftId(int fieldId) {
         switch(fieldId) {
-          case 1: // SESSION
-            return SESSION;
+          case 1: // TABLE
+            return TABLE;
           case 2: // SHARD_INDEX
             return SHARD_INDEX;
-          case 3: // DOCUMENT
-            return DOCUMENT;
+          case 3: // QUERIES
+            return QUERIES;
           default:
             return null;
         }
@@ -5680,83 +5572,83 @@ public class Lucene {
     public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
     static {
       Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
-      tmpMap.put(_Fields.SESSION, new org.apache.thrift.meta_data.FieldMetaData("session", org.apache.thrift.TFieldRequirementType.DEFAULT, 
-          new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Session.class)));
+      tmpMap.put(_Fields.TABLE, new org.apache.thrift.meta_data.FieldMetaData("table", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
       tmpMap.put(_Fields.SHARD_INDEX, new org.apache.thrift.meta_data.FieldMetaData("shardIndex", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
-      tmpMap.put(_Fields.DOCUMENT, new org.apache.thrift.meta_data.FieldMetaData("document", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+      tmpMap.put(_Fields.QUERIES, new org.apache.thrift.meta_data.FieldMetaData("queries", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST, 
-              new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Document.class))));
+              new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, QueryArgs.class))));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(addDocuments_args.class, metaDataMap);
+      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(deleteDocumentsByQueries_args.class, metaDataMap);
     }
 
-    public addDocuments_args() {
+    public deleteDocumentsByQueries_args() {
     }
 
-    public addDocuments_args(
-      Session session,
+    public deleteDocumentsByQueries_args(
+      String table,
       int shardIndex,
-      List<Document> document)
+      List<QueryArgs> queries)
     {
       this();
-      this.session = session;
+      this.table = table;
       this.shardIndex = shardIndex;
       setShardIndexIsSet(true);
-      this.document = document;
+      this.queries = queries;
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public addDocuments_args(addDocuments_args other) {
+    public deleteDocumentsByQueries_args(deleteDocumentsByQueries_args other) {
       __isset_bitfield = other.__isset_bitfield;
-      if (other.isSetSession()) {
-        this.session = new Session(other.session);
+      if (other.isSetTable()) {
+        this.table = other.table;
       }
       this.shardIndex = other.shardIndex;
-      if (other.isSetDocument()) {
-        List<Document> __this__document = new ArrayList<Document>();
-        for (Document other_element : other.document) {
-          __this__document.add(new Document(other_element));
+      if (other.isSetQueries()) {
+        List<QueryArgs> __this__queries = new ArrayList<QueryArgs>();
+        for (QueryArgs other_element : other.queries) {
+          __this__queries.add(new QueryArgs(other_element));
         }
-        this.document = __this__document;
+        this.queries = __this__queries;
       }
     }
 
-    public addDocuments_args deepCopy() {
-      return new addDocuments_args(this);
+    public deleteDocumentsByQueries_args deepCopy() {
+      return new deleteDocumentsByQueries_args(this);
     }
 
     @Override
     public void clear() {
-      this.session = null;
+      this.table = null;
       setShardIndexIsSet(false);
       this.shardIndex = 0;
-      this.document = null;
+      this.queries = null;
     }
 
-    public Session getSession() {
-      return this.session;
+    public String getTable() {
+      return this.table;
     }
 
-    public addDocuments_args setSession(Session session) {
-      this.session = session;
+    public deleteDocumentsByQueries_args setTable(String table) {
+      this.table = table;
       return this;
     }
 
-    public void unsetSession() {
-      this.session = null;
+    public void unsetTable() {
+      this.table = null;
     }
 
-    /** Returns true if field session is set (has been assigned a value) and false otherwise */
-    public boolean isSetSession() {
-      return this.session != null;
+    /** Returns true if field table is set (has been assigned a value) and false otherwise */
+    public boolean isSetTable() {
+      return this.table != null;
     }
 
-    public void setSessionIsSet(boolean value) {
+    public void setTableIsSet(boolean value) {
       if (!value) {
-        this.session = null;
+        this.table = null;
       }
     }
 
@@ -5764,7 +5656,7 @@ public class Lucene {
       return this.shardIndex;
     }
 
-    public addDocuments_args setShardIndex(int shardIndex) {
+    public deleteDocumentsByQueries_args setShardIndex(int shardIndex) {
       this.shardIndex = shardIndex;
       setShardIndexIsSet(true);
       return this;
@@ -5783,52 +5675,52 @@ public class Lucene {
       __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __SHARDINDEX_ISSET_ID, value);
     }
 
-    public int getDocumentSize() {
-      return (this.document == null) ? 0 : this.document.size();
+    public int getQueriesSize() {
+      return (this.queries == null) ? 0 : this.queries.size();
     }
 
-    public java.util.Iterator<Document> getDocumentIterator() {
-      return (this.document == null) ? null : this.document.iterator();
+    public java.util.Iterator<QueryArgs> getQueriesIterator() {
+      return (this.queries == null) ? null : this.queries.iterator();
     }
 
-    public void addToDocument(Document elem) {
-      if (this.document == null) {
-        this.document = new ArrayList<Document>();
+    public void addToQueries(QueryArgs elem) {
+      if (this.queries == null) {
+        this.queries = new ArrayList<QueryArgs>();
       }
-      this.document.add(elem);
+      this.queries.add(elem);
     }
 
-    public List<Document> getDocument() {
-      return this.document;
+    public List<QueryArgs> getQueries() {
+      return this.queries;
     }
 
-    public addDocuments_args setDocument(List<Document> document) {
-      this.document = document;
+    public deleteDocumentsByQueries_args setQueries(List<QueryArgs> queries) {
+      this.queries = queries;
       return this;
     }
 
-    public void unsetDocument() {
-      this.document = null;
+    public void unsetQueries() {
+      this.queries = null;
     }
 
-    /** Returns true if field document is set (has been assigned a value) and false otherwise */
-    public boolean isSetDocument() {
-      return this.document != null;
+    /** Returns true if field queries is set (has been assigned a value) and false otherwise */
+    public boolean isSetQueries() {
+      return this.queries != null;
     }
 
-    public void setDocumentIsSet(boolean value) {
+    public void setQueriesIsSet(boolean value) {
       if (!value) {
-        this.document = null;
+        this.queries = null;
       }
     }
 
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
-      case SESSION:
+      case TABLE:
         if (value == null) {
-          unsetSession();
+          unsetTable();
         } else {
-          setSession((Session)value);
+          setTable((String)value);
         }
         break;
 
@@ -5840,11 +5732,11 @@ public class Lucene {
         }
         break;
 
-      case DOCUMENT:
+      case QUERIES:
         if (value == null) {
-          unsetDocument();
+          unsetQueries();
         } else {
-          setDocument((List<Document>)value);
+          setQueries((List<QueryArgs>)value);
         }
         break;
 
@@ -5853,14 +5745,14 @@ public class Lucene {
 
     public Object getFieldValue(_Fields field) {
       switch (field) {
-      case SESSION:
-        return getSession();
+      case TABLE:
+        return getTable();
 
       case SHARD_INDEX:
         return Integer.valueOf(getShardIndex());
 
-      case DOCUMENT:
-        return getDocument();
+      case QUERIES:
+        return getQueries();
 
       }
       throw new IllegalStateException();
@@ -5873,12 +5765,12 @@ public class Lucene {
       }
 
       switch (field) {
-      case SESSION:
-        return isSetSession();
+      case TABLE:
+        return isSetTable();
       case SHARD_INDEX:
         return isSetShardIndex();
-      case DOCUMENT:
-        return isSetDocument();
+      case QUERIES:
+        return isSetQueries();
       }
       throw new IllegalStateException();
     }
@@ -5887,21 +5779,21 @@ public class Lucene {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof addDocuments_args)
-        return this.equals((addDocuments_args)that);
+      if (that instanceof deleteDocumentsByQueries_args)
+        return this.equals((deleteDocumentsByQueries_args)that);
       return false;
     }
 
-    public boolean equals(addDocuments_args that) {
+    public boolean equals(deleteDocumentsByQueries_args that) {
       if (that == null)
         return false;
 
-      boolean this_present_session = true && this.isSetSession();
-      boolean that_present_session = true && that.isSetSession();
-      if (this_present_session || that_present_session) {
-        if (!(this_present_session && that_present_session))
+      boolean this_present_table = true && this.isSetTable();
+      boolean that_present_table = true && that.isSetTable();
+      if (this_present_table || that_present_table) {
+        if (!(this_present_table && that_present_table))
           return false;
-        if (!this.session.equals(that.session))
+        if (!this.table.equals(that.table))
           return false;
       }
 
@@ -5914,12 +5806,12 @@ public class Lucene {
           return false;
       }
 
-      boolean this_present_document = true && this.isSetDocument();
-      boolean that_present_document = true && that.isSetDocument();
-      if (this_present_document || that_present_document) {
-        if (!(this_present_document && that_present_document))
+      boolean this_present_queries = true && this.isSetQueries();
+      boolean that_present_queries = true && that.isSetQueries();
+      if (this_present_queries || that_present_queries) {
+        if (!(this_present_queries && that_present_queries))
           return false;
-        if (!this.document.equals(that.document))
+        if (!this.queries.equals(that.queries))
           return false;
       }
 
@@ -5931,20 +5823,20 @@ public class Lucene {
       return 0;
     }
 
-    public int compareTo(addDocuments_args other) {
+    public int compareTo(deleteDocumentsByQueries_args other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
-      addDocuments_args typedOther = (addDocuments_args)other;
+      deleteDocumentsByQueries_args typedOther = (deleteDocumentsByQueries_args)other;
 
-      lastComparison = Boolean.valueOf(isSetSession()).compareTo(typedOther.isSetSession());
+      lastComparison = Boolean.valueOf(isSetTable()).compareTo(typedOther.isSetTable());
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetSession()) {
-        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.session, typedOther.session);
+      if (isSetTable()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.table, typedOther.table);
         if (lastComparison != 0) {
           return lastComparison;
         }
@@ -5959,12 +5851,12 @@ public class Lucene {
           return lastComparison;
         }
       }
-      lastComparison = Boolean.valueOf(isSetDocument()).compareTo(typedOther.isSetDocument());
+      lastComparison = Boolean.valueOf(isSetQueries()).compareTo(typedOther.isSetQueries());
       if (lastComparison != 0) {
         return lastComparison;
       }
-      if (isSetDocument()) {
-        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.document, typedOther.document);
+      if (isSetQueries()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.queries, typedOther.queries);
         if (lastComparison != 0) {
           return lastComparison;
         }
@@ -5986,14 +5878,14 @@ public class Lucene {
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("addDocuments_args(");
+      StringBuilder sb = new StringBuilder("deleteDocumentsByQueries_args(");
       boolean first = true;
 
-      sb.append("session:");
-      if (this.session == null) {
+      sb.append("table:");
+      if (this.table == null) {
         sb.append("null");
       } else {
-        sb.append(this.session);
+        sb.append(this.table);
       }
       first = false;
       if (!first) sb.append(", ");
@@ -6001,11 +5893,11 @@ public class Lucene {
       sb.append(this.shardIndex);
       first = false;
       if (!first) sb.append(", ");
-      sb.append("document:");
-      if (this.document == null) {
+      sb.append("queries:");
+      if (this.queries == null) {
         sb.append("null");
       } else {
-        sb.append(this.document);
+        sb.append(this.queries);
       }
       first = false;
       sb.append(")");
@@ -6015,9 +5907,6 @@ public class Lucene {
     public void validate() throws org.apache.thrift.TException {
       // check for required fields
       // check for sub-struct validity
-      if (session != null) {
-        session.validate();
-      }
     }
 
     private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
@@ -6038,15 +5927,15 @@ public class Lucene {
       }
     }
 
-    private static class addDocuments_argsStandardSchemeFactory implements SchemeFactory {
-      public addDocuments_argsStandardScheme getScheme() {
-        return new addDocuments_argsStandardScheme();
+    private static class deleteDocumentsByQueries_argsStandardSchemeFactory implements SchemeFactory {
+      public deleteDocumentsByQueries_argsStandardScheme getScheme() {
+        return new deleteDocumentsByQueries_argsStandardScheme();
       }
     }
 
-    private static class addDocuments_argsStandardScheme extends StandardScheme<addDocuments_args> {
+    private static class deleteDocumentsByQueries_argsStandardScheme extends StandardScheme<deleteDocumentsByQueries_args> {
 
-      public void read(org.apache.thrift.protocol.TProtocol iprot, addDocuments_args struct) throws org.apache.thrift.TException {
+      public void read(org.apache.thrift.protocol.TProtocol iprot, deleteDocumentsByQueries_args struct) throws org.apache.thrift.TException {
         org.apache.thrift.protocol.TField schemeField;
         iprot.readStructBegin();
         while (true)
@@ -6056,11 +5945,10 @@ public class Lucene {
             break;
           }
           switch (schemeField.id) {
-            case 1: // SESSION
-              if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) {
-                struct.session = new Session();
-                struct.session.read(iprot);
-                struct.setSessionIsSet(true);
+            case 1: // TABLE
+              if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+                struct.table = iprot.readString();
+                struct.setTableIsSet(true);
               } else { 
                 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
               }
@@ -6073,21 +5961,21 @@ public class Lucene {
                 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
               }
               break;
-            case 3: // DOCUMENT
+            case 3: // QUERIES
               if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
                 {
-                  org.apache.thrift.protocol.TList _list348 = iprot.readListBegin();
-                  struct.document = new ArrayList<Document>(_list348.size);
-                  for (int _i349 = 0; _i349 < _list348.size; ++_i349)
+                  org.apache.thrift.protocol.TList _list356 = iprot.readListBegin();
+                  struct.queries = new ArrayList<QueryArgs>(_list356.size);
+                  for (int _i357 = 0; _i357 < _list356.size; ++_i357)
                   {
-                    Document _elem350; // required
-                    _elem350 = new Document();
-                    _elem350.read(iprot);
-                    struct.document.add(_elem350);
+                    QueryArgs _elem358; // required
+                    _elem358 = new QueryArgs();
+                    _elem358.read(iprot);
+                    struct.queries.add(_elem358);
                   }
                   iprot.readListEnd();
                 }
-                struct.setDocumentIsSet(true);
+                struct.setQueriesIsSet(true);
               } else { 
                 org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
               }
@@ -6103,25 +5991,25 @@ public class Lucene {
         struct.validate();
       }
 
-      public void write(org.apache.thrift.protocol.TProtocol oprot, addDocuments_args struct) throws org.apache.thrift.TException {
+      public void write(org.apache.thrift.protocol.TProtocol oprot, deleteDocumentsByQueries_args struct) throws org.apache.thrift.TException {
         struct.validate();
 
         oprot.writeStructBegin(STRUCT_DESC);
-        if (struct.session != null) {
-          oprot.writeFieldBegin(SESSION_FIELD_DESC);
-          struct.session.write(oprot);
+        if (struct.table != null) {
+          oprot.writeFieldBegin(TABLE_FIELD_DESC);
+          oprot.writeString(struct.table);
           oprot.writeFieldEnd();
         }
         oprot.writeFieldBegin(SHARD_INDEX_FIELD_DESC);
         oprot.writeI32(struct.shardIndex);
         oprot.writeFieldEnd();
-        if (struct.document != null) {
-          oprot.writeFieldBegin(DOCUMENT_FIELD_DESC);
+        if (struct.queries != null) {
+          oprot.writeFieldBegin(QUERIES_FIELD_DESC);
           {
-            oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.document.size()));
-            for (Document _iter351 : struct.document)
+            oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.queries.size()));
+            for (QueryArgs _iter359 : struct.queries)
             {
-              _iter351.write(oprot);
+              _iter359.write(oprot);
             }
             oprot.writeListEnd();
           }
@@ -6133,53 +6021,52 @@ pub

<TRUNCATED>

Mime
View raw message