incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [2/3] More changes to simplify.
Date Fri, 05 Oct 2012 02:33:34 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/320f9de8/src/blur-new-api-prototype/src/main/java/org/apache/blur/thrift/generated/BlurTuple.java
----------------------------------------------------------------------
diff --git a/src/blur-new-api-prototype/src/main/java/org/apache/blur/thrift/generated/BlurTuple.java b/src/blur-new-api-prototype/src/main/java/org/apache/blur/thrift/generated/BlurTuple.java
index 4250d75..987fc07 100644
--- a/src/blur-new-api-prototype/src/main/java/org/apache/blur/thrift/generated/BlurTuple.java
+++ b/src/blur-new-api-prototype/src/main/java/org/apache/blur/thrift/generated/BlurTuple.java
@@ -24,29 +24,23 @@ public class BlurTuple {
 
   public interface Iface {
 
-    public ReadSession openReadSession() throws BlurException, org.apache.thrift.TException;
+    public Session openReadSession() throws BlurException, org.apache.thrift.TException;
 
-    public void executeQuery(ReadSession session, String query) throws BlurException, org.apache.thrift.TException;
+    public void executeQuery(Session session, String query) throws BlurException, org.apache.thrift.TException;
 
-    public ReadResult nextMetaDataResult(ReadSession session) throws BlurException, org.apache.thrift.TException;
+    public List<Tuple> nextMetaDataResults(Session session, int batchSize) throws BlurException, org.apache.thrift.TException;
 
-    public List<ReadResult> nextMetaDataResults(ReadSession session, int batchSize) throws BlurException, org.apache.thrift.TException;
+    public List<Tuple> nextResults(Session session, int batchSize) throws BlurException, org.apache.thrift.TException;
 
-    public ReadResult nextResult(ReadSession session) throws BlurException, org.apache.thrift.TException;
+    public void closeReadSession(Session session) throws BlurException, org.apache.thrift.TException;
 
-    public List<ReadResult> nextResults(ReadSession session, int batchSize) throws BlurException, org.apache.thrift.TException;
+    public Session openWriteSession() throws BlurException, org.apache.thrift.TException;
 
-    public void closeReadSession(ReadSession session) throws BlurException, org.apache.thrift.TException;
+    public void writeTuples(Session session, List<Tuple> tuples) throws BlurException, org.apache.thrift.TException;
 
-    public WriteSession openWriteSession() throws BlurException, org.apache.thrift.TException;
+    public void commitWriteSession(Session session) throws BlurException, org.apache.thrift.TException;
 
-    public void writeTuple(WriteSession session, Tuple tuple) throws BlurException, org.apache.thrift.TException;
-
-    public void writeTuples(WriteSession session, List<Tuple> tuples) throws BlurException, org.apache.thrift.TException;
-
-    public void commitWriteSession(WriteSession session) throws BlurException, org.apache.thrift.TException;
-
-    public void rollbackWriteSession(WriteSession session) throws BlurException, org.apache.thrift.TException;
+    public void rollbackWriteSession(Session session) throws BlurException, org.apache.thrift.TException;
 
   }
 
@@ -54,27 +48,21 @@ public class BlurTuple {
 
     public void openReadSession(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.openReadSession_call> resultHandler) throws org.apache.thrift.TException;
 
-    public void executeQuery(ReadSession session, String query, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.executeQuery_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void nextMetaDataResult(ReadSession session, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.nextMetaDataResult_call> resultHandler) throws org.apache.thrift.TException;
+    public void executeQuery(Session session, String query, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.executeQuery_call> resultHandler) throws org.apache.thrift.TException;
 
-    public void nextMetaDataResults(ReadSession session, int batchSize, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.nextMetaDataResults_call> resultHandler) throws org.apache.thrift.TException;
+    public void nextMetaDataResults(Session session, int batchSize, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.nextMetaDataResults_call> resultHandler) throws org.apache.thrift.TException;
 
-    public void nextResult(ReadSession session, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.nextResult_call> resultHandler) throws org.apache.thrift.TException;
+    public void nextResults(Session session, int batchSize, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.nextResults_call> resultHandler) throws org.apache.thrift.TException;
 
-    public void nextResults(ReadSession session, int batchSize, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.nextResults_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void closeReadSession(ReadSession session, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.closeReadSession_call> resultHandler) throws org.apache.thrift.TException;
+    public void closeReadSession(Session session, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.closeReadSession_call> resultHandler) throws org.apache.thrift.TException;
 
     public void openWriteSession(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.openWriteSession_call> resultHandler) throws org.apache.thrift.TException;
 
-    public void writeTuple(WriteSession session, Tuple tuple, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.writeTuple_call> resultHandler) throws org.apache.thrift.TException;
-
-    public void writeTuples(WriteSession session, List<Tuple> tuples, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.writeTuples_call> resultHandler) throws org.apache.thrift.TException;
+    public void writeTuples(Session session, List<Tuple> tuples, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.writeTuples_call> resultHandler) throws org.apache.thrift.TException;
 
-    public void commitWriteSession(WriteSession session, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.commitWriteSession_call> resultHandler) throws org.apache.thrift.TException;
+    public void commitWriteSession(Session session, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.commitWriteSession_call> resultHandler) throws org.apache.thrift.TException;
 
-    public void rollbackWriteSession(WriteSession session, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.rollbackWriteSession_call> resultHandler) throws org.apache.thrift.TException;
+    public void rollbackWriteSession(Session session, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.rollbackWriteSession_call> resultHandler) throws org.apache.thrift.TException;
 
   }
 
@@ -98,7 +86,7 @@ public class BlurTuple {
       super(iprot, oprot);
     }
 
-    public ReadSession openReadSession() throws BlurException, org.apache.thrift.TException
+    public Session openReadSession() throws BlurException, org.apache.thrift.TException
     {
       send_openReadSession();
       return recv_openReadSession();
@@ -110,7 +98,7 @@ public class BlurTuple {
       sendBase("openReadSession", args);
     }
 
-    public ReadSession recv_openReadSession() throws BlurException, org.apache.thrift.TException
+    public Session recv_openReadSession() throws BlurException, org.apache.thrift.TException
     {
       openReadSession_result result = new openReadSession_result();
       receiveBase(result, "openReadSession");
@@ -123,13 +111,13 @@ public class BlurTuple {
       throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "openReadSession failed: unknown result");
     }
 
-    public void executeQuery(ReadSession session, String query) throws BlurException, org.apache.thrift.TException
+    public void executeQuery(Session session, String query) throws BlurException, org.apache.thrift.TException
     {
       send_executeQuery(session, query);
       recv_executeQuery();
     }
 
-    public void send_executeQuery(ReadSession session, String query) throws org.apache.thrift.TException
+    public void send_executeQuery(Session session, String query) throws org.apache.thrift.TException
     {
       executeQuery_args args = new executeQuery_args();
       args.setSession(session);
@@ -147,39 +135,13 @@ public class BlurTuple {
       return;
     }
 
-    public ReadResult nextMetaDataResult(ReadSession session) throws BlurException, org.apache.thrift.TException
-    {
-      send_nextMetaDataResult(session);
-      return recv_nextMetaDataResult();
-    }
-
-    public void send_nextMetaDataResult(ReadSession session) throws org.apache.thrift.TException
-    {
-      nextMetaDataResult_args args = new nextMetaDataResult_args();
-      args.setSession(session);
-      sendBase("nextMetaDataResult", args);
-    }
-
-    public ReadResult recv_nextMetaDataResult() throws BlurException, org.apache.thrift.TException
-    {
-      nextMetaDataResult_result result = new nextMetaDataResult_result();
-      receiveBase(result, "nextMetaDataResult");
-      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, "nextMetaDataResult failed: unknown result");
-    }
-
-    public List<ReadResult> nextMetaDataResults(ReadSession session, int batchSize) throws BlurException, org.apache.thrift.TException
+    public List<Tuple> nextMetaDataResults(Session session, int batchSize) throws BlurException, org.apache.thrift.TException
     {
       send_nextMetaDataResults(session, batchSize);
       return recv_nextMetaDataResults();
     }
 
-    public void send_nextMetaDataResults(ReadSession session, int batchSize) throws org.apache.thrift.TException
+    public void send_nextMetaDataResults(Session session, int batchSize) throws org.apache.thrift.TException
     {
       nextMetaDataResults_args args = new nextMetaDataResults_args();
       args.setSession(session);
@@ -187,7 +149,7 @@ public class BlurTuple {
       sendBase("nextMetaDataResults", args);
     }
 
-    public List<ReadResult> recv_nextMetaDataResults() throws BlurException, org.apache.thrift.TException
+    public List<Tuple> recv_nextMetaDataResults() throws BlurException, org.apache.thrift.TException
     {
       nextMetaDataResults_result result = new nextMetaDataResults_result();
       receiveBase(result, "nextMetaDataResults");
@@ -200,39 +162,13 @@ public class BlurTuple {
       throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "nextMetaDataResults failed: unknown result");
     }
 
-    public ReadResult nextResult(ReadSession session) throws BlurException, org.apache.thrift.TException
-    {
-      send_nextResult(session);
-      return recv_nextResult();
-    }
-
-    public void send_nextResult(ReadSession session) throws org.apache.thrift.TException
-    {
-      nextResult_args args = new nextResult_args();
-      args.setSession(session);
-      sendBase("nextResult", args);
-    }
-
-    public ReadResult recv_nextResult() throws BlurException, org.apache.thrift.TException
-    {
-      nextResult_result result = new nextResult_result();
-      receiveBase(result, "nextResult");
-      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, "nextResult failed: unknown result");
-    }
-
-    public List<ReadResult> nextResults(ReadSession session, int batchSize) throws BlurException, org.apache.thrift.TException
+    public List<Tuple> nextResults(Session session, int batchSize) throws BlurException, org.apache.thrift.TException
     {
       send_nextResults(session, batchSize);
       return recv_nextResults();
     }
 
-    public void send_nextResults(ReadSession session, int batchSize) throws org.apache.thrift.TException
+    public void send_nextResults(Session session, int batchSize) throws org.apache.thrift.TException
     {
       nextResults_args args = new nextResults_args();
       args.setSession(session);
@@ -240,7 +176,7 @@ public class BlurTuple {
       sendBase("nextResults", args);
     }
 
-    public List<ReadResult> recv_nextResults() throws BlurException, org.apache.thrift.TException
+    public List<Tuple> recv_nextResults() throws BlurException, org.apache.thrift.TException
     {
       nextResults_result result = new nextResults_result();
       receiveBase(result, "nextResults");
@@ -253,13 +189,13 @@ public class BlurTuple {
       throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "nextResults failed: unknown result");
     }
 
-    public void closeReadSession(ReadSession session) throws BlurException, org.apache.thrift.TException
+    public void closeReadSession(Session session) throws BlurException, org.apache.thrift.TException
     {
       send_closeReadSession(session);
       recv_closeReadSession();
     }
 
-    public void send_closeReadSession(ReadSession session) throws org.apache.thrift.TException
+    public void send_closeReadSession(Session session) throws org.apache.thrift.TException
     {
       closeReadSession_args args = new closeReadSession_args();
       args.setSession(session);
@@ -276,7 +212,7 @@ public class BlurTuple {
       return;
     }
 
-    public WriteSession openWriteSession() throws BlurException, org.apache.thrift.TException
+    public Session openWriteSession() throws BlurException, org.apache.thrift.TException
     {
       send_openWriteSession();
       return recv_openWriteSession();
@@ -288,7 +224,7 @@ public class BlurTuple {
       sendBase("openWriteSession", args);
     }
 
-    public WriteSession recv_openWriteSession() throws BlurException, org.apache.thrift.TException
+    public Session recv_openWriteSession() throws BlurException, org.apache.thrift.TException
     {
       openWriteSession_result result = new openWriteSession_result();
       receiveBase(result, "openWriteSession");
@@ -301,37 +237,13 @@ public class BlurTuple {
       throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "openWriteSession failed: unknown result");
     }
 
-    public void writeTuple(WriteSession session, Tuple tuple) throws BlurException, org.apache.thrift.TException
-    {
-      send_writeTuple(session, tuple);
-      recv_writeTuple();
-    }
-
-    public void send_writeTuple(WriteSession session, Tuple tuple) throws org.apache.thrift.TException
-    {
-      writeTuple_args args = new writeTuple_args();
-      args.setSession(session);
-      args.setTuple(tuple);
-      sendBase("writeTuple", args);
-    }
-
-    public void recv_writeTuple() throws BlurException, org.apache.thrift.TException
-    {
-      writeTuple_result result = new writeTuple_result();
-      receiveBase(result, "writeTuple");
-      if (result.e != null) {
-        throw result.e;
-      }
-      return;
-    }
-
-    public void writeTuples(WriteSession session, List<Tuple> tuples) throws BlurException, org.apache.thrift.TException
+    public void writeTuples(Session session, List<Tuple> tuples) throws BlurException, org.apache.thrift.TException
     {
       send_writeTuples(session, tuples);
       recv_writeTuples();
     }
 
-    public void send_writeTuples(WriteSession session, List<Tuple> tuples) throws org.apache.thrift.TException
+    public void send_writeTuples(Session session, List<Tuple> tuples) throws org.apache.thrift.TException
     {
       writeTuples_args args = new writeTuples_args();
       args.setSession(session);
@@ -349,13 +261,13 @@ public class BlurTuple {
       return;
     }
 
-    public void commitWriteSession(WriteSession session) throws BlurException, org.apache.thrift.TException
+    public void commitWriteSession(Session session) throws BlurException, org.apache.thrift.TException
     {
       send_commitWriteSession(session);
       recv_commitWriteSession();
     }
 
-    public void send_commitWriteSession(WriteSession session) throws org.apache.thrift.TException
+    public void send_commitWriteSession(Session session) throws org.apache.thrift.TException
     {
       commitWriteSession_args args = new commitWriteSession_args();
       args.setSession(session);
@@ -372,13 +284,13 @@ public class BlurTuple {
       return;
     }
 
-    public void rollbackWriteSession(WriteSession session) throws BlurException, org.apache.thrift.TException
+    public void rollbackWriteSession(Session session) throws BlurException, org.apache.thrift.TException
     {
       send_rollbackWriteSession(session);
       recv_rollbackWriteSession();
     }
 
-    public void send_rollbackWriteSession(WriteSession session) throws org.apache.thrift.TException
+    public void send_rollbackWriteSession(Session session) throws org.apache.thrift.TException
     {
       rollbackWriteSession_args args = new rollbackWriteSession_args();
       args.setSession(session);
@@ -432,7 +344,7 @@ public class BlurTuple {
         prot.writeMessageEnd();
       }
 
-      public ReadSession getResult() throws BlurException, org.apache.thrift.TException {
+      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!");
         }
@@ -442,7 +354,7 @@ public class BlurTuple {
       }
     }
 
-    public void executeQuery(ReadSession session, String query, org.apache.thrift.async.AsyncMethodCallback<executeQuery_call> resultHandler) throws org.apache.thrift.TException {
+    public void executeQuery(Session session, String query, org.apache.thrift.async.AsyncMethodCallback<executeQuery_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
       executeQuery_call method_call = new executeQuery_call(session, query, resultHandler, this, ___protocolFactory, ___transport);
       this.___currentMethod = method_call;
@@ -450,9 +362,9 @@ public class BlurTuple {
     }
 
     public static class executeQuery_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private ReadSession session;
+      private Session session;
       private String query;
-      public executeQuery_call(ReadSession session, String query, org.apache.thrift.async.AsyncMethodCallback<executeQuery_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 executeQuery_call(Session session, String query, org.apache.thrift.async.AsyncMethodCallback<executeQuery_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.query = query;
@@ -477,39 +389,7 @@ public class BlurTuple {
       }
     }
 
-    public void nextMetaDataResult(ReadSession session, org.apache.thrift.async.AsyncMethodCallback<nextMetaDataResult_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      nextMetaDataResult_call method_call = new nextMetaDataResult_call(session, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class nextMetaDataResult_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private ReadSession session;
-      public nextMetaDataResult_call(ReadSession session, org.apache.thrift.async.AsyncMethodCallback<nextMetaDataResult_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("nextMetaDataResult", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        nextMetaDataResult_args args = new nextMetaDataResult_args();
-        args.setSession(session);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public ReadResult 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_nextMetaDataResult();
-      }
-    }
-
-    public void nextMetaDataResults(ReadSession session, int batchSize, org.apache.thrift.async.AsyncMethodCallback<nextMetaDataResults_call> resultHandler) throws org.apache.thrift.TException {
+    public void nextMetaDataResults(Session session, int batchSize, org.apache.thrift.async.AsyncMethodCallback<nextMetaDataResults_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
       nextMetaDataResults_call method_call = new nextMetaDataResults_call(session, batchSize, resultHandler, this, ___protocolFactory, ___transport);
       this.___currentMethod = method_call;
@@ -517,9 +397,9 @@ public class BlurTuple {
     }
 
     public static class nextMetaDataResults_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private ReadSession session;
+      private Session session;
       private int batchSize;
-      public nextMetaDataResults_call(ReadSession session, int batchSize, org.apache.thrift.async.AsyncMethodCallback<nextMetaDataResults_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 nextMetaDataResults_call(Session session, int batchSize, org.apache.thrift.async.AsyncMethodCallback<nextMetaDataResults_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.batchSize = batchSize;
@@ -534,7 +414,7 @@ public class BlurTuple {
         prot.writeMessageEnd();
       }
 
-      public List<ReadResult> getResult() throws BlurException, org.apache.thrift.TException {
+      public List<Tuple> getResult() throws BlurException, org.apache.thrift.TException {
         if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
           throw new IllegalStateException("Method call not finished!");
         }
@@ -544,39 +424,7 @@ public class BlurTuple {
       }
     }
 
-    public void nextResult(ReadSession session, org.apache.thrift.async.AsyncMethodCallback<nextResult_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      nextResult_call method_call = new nextResult_call(session, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class nextResult_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private ReadSession session;
-      public nextResult_call(ReadSession session, org.apache.thrift.async.AsyncMethodCallback<nextResult_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("nextResult", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        nextResult_args args = new nextResult_args();
-        args.setSession(session);
-        args.write(prot);
-        prot.writeMessageEnd();
-      }
-
-      public ReadResult 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_nextResult();
-      }
-    }
-
-    public void nextResults(ReadSession session, int batchSize, org.apache.thrift.async.AsyncMethodCallback<nextResults_call> resultHandler) throws org.apache.thrift.TException {
+    public void nextResults(Session session, int batchSize, org.apache.thrift.async.AsyncMethodCallback<nextResults_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
       nextResults_call method_call = new nextResults_call(session, batchSize, resultHandler, this, ___protocolFactory, ___transport);
       this.___currentMethod = method_call;
@@ -584,9 +432,9 @@ public class BlurTuple {
     }
 
     public static class nextResults_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private ReadSession session;
+      private Session session;
       private int batchSize;
-      public nextResults_call(ReadSession session, int batchSize, org.apache.thrift.async.AsyncMethodCallback<nextResults_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 nextResults_call(Session session, int batchSize, org.apache.thrift.async.AsyncMethodCallback<nextResults_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.batchSize = batchSize;
@@ -601,7 +449,7 @@ public class BlurTuple {
         prot.writeMessageEnd();
       }
 
-      public List<ReadResult> getResult() throws BlurException, org.apache.thrift.TException {
+      public List<Tuple> getResult() throws BlurException, org.apache.thrift.TException {
         if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
           throw new IllegalStateException("Method call not finished!");
         }
@@ -611,7 +459,7 @@ public class BlurTuple {
       }
     }
 
-    public void closeReadSession(ReadSession session, org.apache.thrift.async.AsyncMethodCallback<closeReadSession_call> resultHandler) throws org.apache.thrift.TException {
+    public void closeReadSession(Session session, org.apache.thrift.async.AsyncMethodCallback<closeReadSession_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
       closeReadSession_call method_call = new closeReadSession_call(session, resultHandler, this, ___protocolFactory, ___transport);
       this.___currentMethod = method_call;
@@ -619,8 +467,8 @@ public class BlurTuple {
     }
 
     public static class closeReadSession_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private ReadSession session;
-      public closeReadSession_call(ReadSession 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 {
+      private Session session;
+      public closeReadSession_call(Session session, org.apache.thrift.async.AsyncMethodCallback<closeReadSession_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
         super(client, protocolFactory, transport, resultHandler, false);
         this.session = session;
       }
@@ -662,7 +510,7 @@ public class BlurTuple {
         prot.writeMessageEnd();
       }
 
-      public WriteSession getResult() throws BlurException, org.apache.thrift.TException {
+      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!");
         }
@@ -672,42 +520,7 @@ public class BlurTuple {
       }
     }
 
-    public void writeTuple(WriteSession session, Tuple tuple, org.apache.thrift.async.AsyncMethodCallback<writeTuple_call> resultHandler) throws org.apache.thrift.TException {
-      checkReady();
-      writeTuple_call method_call = new writeTuple_call(session, tuple, resultHandler, this, ___protocolFactory, ___transport);
-      this.___currentMethod = method_call;
-      ___manager.call(method_call);
-    }
-
-    public static class writeTuple_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private WriteSession session;
-      private Tuple tuple;
-      public writeTuple_call(WriteSession session, Tuple tuple, org.apache.thrift.async.AsyncMethodCallback<writeTuple_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.tuple = tuple;
-      }
-
-      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
-        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("writeTuple", org.apache.thrift.protocol.TMessageType.CALL, 0));
-        writeTuple_args args = new writeTuple_args();
-        args.setSession(session);
-        args.setTuple(tuple);
-        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_writeTuple();
-      }
-    }
-
-    public void writeTuples(WriteSession session, List<Tuple> tuples, org.apache.thrift.async.AsyncMethodCallback<writeTuples_call> resultHandler) throws org.apache.thrift.TException {
+    public void writeTuples(Session session, List<Tuple> tuples, org.apache.thrift.async.AsyncMethodCallback<writeTuples_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
       writeTuples_call method_call = new writeTuples_call(session, tuples, resultHandler, this, ___protocolFactory, ___transport);
       this.___currentMethod = method_call;
@@ -715,9 +528,9 @@ public class BlurTuple {
     }
 
     public static class writeTuples_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private WriteSession session;
+      private Session session;
       private List<Tuple> tuples;
-      public writeTuples_call(WriteSession session, List<Tuple> tuples, org.apache.thrift.async.AsyncMethodCallback<writeTuples_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 writeTuples_call(Session session, List<Tuple> tuples, org.apache.thrift.async.AsyncMethodCallback<writeTuples_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.tuples = tuples;
@@ -742,7 +555,7 @@ public class BlurTuple {
       }
     }
 
-    public void commitWriteSession(WriteSession session, org.apache.thrift.async.AsyncMethodCallback<commitWriteSession_call> resultHandler) throws org.apache.thrift.TException {
+    public void commitWriteSession(Session session, org.apache.thrift.async.AsyncMethodCallback<commitWriteSession_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
       commitWriteSession_call method_call = new commitWriteSession_call(session, resultHandler, this, ___protocolFactory, ___transport);
       this.___currentMethod = method_call;
@@ -750,8 +563,8 @@ public class BlurTuple {
     }
 
     public static class commitWriteSession_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private WriteSession session;
-      public commitWriteSession_call(WriteSession session, org.apache.thrift.async.AsyncMethodCallback<commitWriteSession_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 {
+      private Session session;
+      public commitWriteSession_call(Session session, org.apache.thrift.async.AsyncMethodCallback<commitWriteSession_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;
       }
@@ -774,7 +587,7 @@ public class BlurTuple {
       }
     }
 
-    public void rollbackWriteSession(WriteSession session, org.apache.thrift.async.AsyncMethodCallback<rollbackWriteSession_call> resultHandler) throws org.apache.thrift.TException {
+    public void rollbackWriteSession(Session session, org.apache.thrift.async.AsyncMethodCallback<rollbackWriteSession_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
       rollbackWriteSession_call method_call = new rollbackWriteSession_call(session, resultHandler, this, ___protocolFactory, ___transport);
       this.___currentMethod = method_call;
@@ -782,8 +595,8 @@ public class BlurTuple {
     }
 
     public static class rollbackWriteSession_call extends org.apache.thrift.async.TAsyncMethodCall {
-      private WriteSession session;
-      public rollbackWriteSession_call(WriteSession session, org.apache.thrift.async.AsyncMethodCallback<rollbackWriteSession_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 {
+      private Session session;
+      public rollbackWriteSession_call(Session session, org.apache.thrift.async.AsyncMethodCallback<rollbackWriteSession_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;
       }
@@ -821,13 +634,10 @@ public class BlurTuple {
     private static <I extends Iface> Map<String,  org.apache.thrift.ProcessFunction<I, ? extends  org.apache.thrift.TBase>> getProcessMap(Map<String,  org.apache.thrift.ProcessFunction<I, ? extends  org.apache.thrift.TBase>> processMap) {
       processMap.put("openReadSession", new openReadSession());
       processMap.put("executeQuery", new executeQuery());
-      processMap.put("nextMetaDataResult", new nextMetaDataResult());
       processMap.put("nextMetaDataResults", new nextMetaDataResults());
-      processMap.put("nextResult", new nextResult());
       processMap.put("nextResults", new nextResults());
       processMap.put("closeReadSession", new closeReadSession());
       processMap.put("openWriteSession", new openWriteSession());
-      processMap.put("writeTuple", new writeTuple());
       processMap.put("writeTuples", new writeTuples());
       processMap.put("commitWriteSession", new commitWriteSession());
       processMap.put("rollbackWriteSession", new rollbackWriteSession());
@@ -874,26 +684,6 @@ public class BlurTuple {
       }
     }
 
-    private static class nextMetaDataResult<I extends Iface> extends org.apache.thrift.ProcessFunction<I, nextMetaDataResult_args> {
-      public nextMetaDataResult() {
-        super("nextMetaDataResult");
-      }
-
-      protected nextMetaDataResult_args getEmptyArgsInstance() {
-        return new nextMetaDataResult_args();
-      }
-
-      protected nextMetaDataResult_result getResult(I iface, nextMetaDataResult_args args) throws org.apache.thrift.TException {
-        nextMetaDataResult_result result = new nextMetaDataResult_result();
-        try {
-          result.success = iface.nextMetaDataResult(args.session);
-        } catch (BlurException e) {
-          result.e = e;
-        }
-        return result;
-      }
-    }
-
     private static class nextMetaDataResults<I extends Iface> extends org.apache.thrift.ProcessFunction<I, nextMetaDataResults_args> {
       public nextMetaDataResults() {
         super("nextMetaDataResults");
@@ -914,26 +704,6 @@ public class BlurTuple {
       }
     }
 
-    private static class nextResult<I extends Iface> extends org.apache.thrift.ProcessFunction<I, nextResult_args> {
-      public nextResult() {
-        super("nextResult");
-      }
-
-      protected nextResult_args getEmptyArgsInstance() {
-        return new nextResult_args();
-      }
-
-      protected nextResult_result getResult(I iface, nextResult_args args) throws org.apache.thrift.TException {
-        nextResult_result result = new nextResult_result();
-        try {
-          result.success = iface.nextResult(args.session);
-        } catch (BlurException e) {
-          result.e = e;
-        }
-        return result;
-      }
-    }
-
     private static class nextResults<I extends Iface> extends org.apache.thrift.ProcessFunction<I, nextResults_args> {
       public nextResults() {
         super("nextResults");
@@ -994,26 +764,6 @@ public class BlurTuple {
       }
     }
 
-    private static class writeTuple<I extends Iface> extends org.apache.thrift.ProcessFunction<I, writeTuple_args> {
-      public writeTuple() {
-        super("writeTuple");
-      }
-
-      protected writeTuple_args getEmptyArgsInstance() {
-        return new writeTuple_args();
-      }
-
-      protected writeTuple_result getResult(I iface, writeTuple_args args) throws org.apache.thrift.TException {
-        writeTuple_result result = new writeTuple_result();
-        try {
-          iface.writeTuple(args.session, args.tuple);
-        } catch (BlurException e) {
-          result.e = e;
-        }
-        return result;
-      }
-    }
-
     private static class writeTuples<I extends Iface> extends org.apache.thrift.ProcessFunction<I, writeTuples_args> {
       public writeTuples() {
         super("writeTuples");
@@ -1284,7 +1034,7 @@ public class BlurTuple {
     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);
 
-    public ReadSession success; // required
+    public Session success; // required
     public BlurException e; // required
 
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
@@ -1354,7 +1104,7 @@ public class BlurTuple {
     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, ReadSession.class)));
+          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);
@@ -1365,7 +1115,7 @@ public class BlurTuple {
     }
 
     public openReadSession_result(
-      ReadSession success,
+      Session success,
       BlurException e)
     {
       this();
@@ -1378,7 +1128,7 @@ public class BlurTuple {
      */
     public openReadSession_result(openReadSession_result other) {
       if (other.isSetSuccess()) {
-        this.success = new ReadSession(other.success);
+        this.success = new Session(other.success);
       }
       if (other.isSetE()) {
         this.e = new BlurException(other.e);
@@ -1395,11 +1145,11 @@ public class BlurTuple {
       this.e = null;
     }
 
-    public ReadSession getSuccess() {
+    public Session getSuccess() {
       return this.success;
     }
 
-    public openReadSession_result setSuccess(ReadSession success) {
+    public openReadSession_result setSuccess(Session success) {
       this.success = success;
       return this;
     }
@@ -1449,7 +1199,7 @@ public class BlurTuple {
         if (value == null) {
           unsetSuccess();
         } else {
-          setSuccess((ReadSession)value);
+          setSuccess((Session)value);
         }
         break;
 
@@ -1577,7 +1327,7 @@ public class BlurTuple {
         switch (field.id) {
           case 0: // SUCCESS
             if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
-              this.success = new ReadSession();
+              this.success = new Session();
               this.success.read(iprot);
             } else { 
               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
@@ -1670,7 +1420,7 @@ public class BlurTuple {
     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 QUERY_FIELD_DESC = new org.apache.thrift.protocol.TField("query", org.apache.thrift.protocol.TType.STRING, (short)2);
 
-    public ReadSession session; // required
+    public Session session; // required
     public String query; // required
 
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
@@ -1740,7 +1490,7 @@ public class BlurTuple {
     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, ReadSession.class)));
+          new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Session.class)));
       tmpMap.put(_Fields.QUERY, new org.apache.thrift.meta_data.FieldMetaData("query", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
@@ -1751,7 +1501,7 @@ public class BlurTuple {
     }
 
     public executeQuery_args(
-      ReadSession session,
+      Session session,
       String query)
     {
       this();
@@ -1764,7 +1514,7 @@ public class BlurTuple {
      */
     public executeQuery_args(executeQuery_args other) {
       if (other.isSetSession()) {
-        this.session = new ReadSession(other.session);
+        this.session = new Session(other.session);
       }
       if (other.isSetQuery()) {
         this.query = other.query;
@@ -1781,11 +1531,11 @@ public class BlurTuple {
       this.query = null;
     }
 
-    public ReadSession getSession() {
+    public Session getSession() {
       return this.session;
     }
 
-    public executeQuery_args setSession(ReadSession session) {
+    public executeQuery_args setSession(Session session) {
       this.session = session;
       return this;
     }
@@ -1835,7 +1585,7 @@ public class BlurTuple {
         if (value == null) {
           unsetSession();
         } else {
-          setSession((ReadSession)value);
+          setSession((Session)value);
         }
         break;
 
@@ -1963,7 +1713,7 @@ public class BlurTuple {
         switch (field.id) {
           case 1: // SESSION
             if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
-              this.session = new ReadSession();
+              this.session = new Session();
               this.session.read(iprot);
             } else { 
               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
@@ -2348,16 +2098,19 @@ public class BlurTuple {
 
   }
 
-  public static class nextMetaDataResult_args implements org.apache.thrift.TBase<nextMetaDataResult_args, nextMetaDataResult_args._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("nextMetaDataResult_args");
+  public static class nextMetaDataResults_args implements org.apache.thrift.TBase<nextMetaDataResults_args, nextMetaDataResults_args._Fields>, java.io.Serializable, Cloneable   {
+    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("nextMetaDataResults_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 BATCH_SIZE_FIELD_DESC = new org.apache.thrift.protocol.TField("batchSize", org.apache.thrift.protocol.TType.I32, (short)2);
 
-    public ReadSession session; // required
+    public Session session; // required
+    public int batchSize; // 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");
+      SESSION((short)1, "session"),
+      BATCH_SIZE((short)2, "batchSize");
 
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
 
@@ -2374,6 +2127,8 @@ public class BlurTuple {
         switch(fieldId) {
           case 1: // SESSION
             return SESSION;
+          case 2: // BATCH_SIZE
+            return BATCH_SIZE;
           default:
             return null;
         }
@@ -2414,49 +2169,61 @@ public class BlurTuple {
     }
 
     // isset id assignments
+    private static final int __BATCHSIZE_ISSET_ID = 0;
+    private BitSet __isset_bit_vector = new BitSet(1);
 
     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, ReadSession.class)));
+          new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Session.class)));
+      tmpMap.put(_Fields.BATCH_SIZE, new org.apache.thrift.meta_data.FieldMetaData("batchSize", org.apache.thrift.TFieldRequirementType.DEFAULT, 
+          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(nextMetaDataResult_args.class, metaDataMap);
+      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(nextMetaDataResults_args.class, metaDataMap);
     }
 
-    public nextMetaDataResult_args() {
+    public nextMetaDataResults_args() {
     }
 
-    public nextMetaDataResult_args(
-      ReadSession session)
+    public nextMetaDataResults_args(
+      Session session,
+      int batchSize)
     {
       this();
       this.session = session;
+      this.batchSize = batchSize;
+      setBatchSizeIsSet(true);
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public nextMetaDataResult_args(nextMetaDataResult_args other) {
+    public nextMetaDataResults_args(nextMetaDataResults_args other) {
+      __isset_bit_vector.clear();
+      __isset_bit_vector.or(other.__isset_bit_vector);
       if (other.isSetSession()) {
-        this.session = new ReadSession(other.session);
+        this.session = new Session(other.session);
       }
+      this.batchSize = other.batchSize;
     }
 
-    public nextMetaDataResult_args deepCopy() {
-      return new nextMetaDataResult_args(this);
+    public nextMetaDataResults_args deepCopy() {
+      return new nextMetaDataResults_args(this);
     }
 
     @Override
     public void clear() {
       this.session = null;
+      setBatchSizeIsSet(false);
+      this.batchSize = 0;
     }
 
-    public ReadSession getSession() {
+    public Session getSession() {
       return this.session;
     }
 
-    public nextMetaDataResult_args setSession(ReadSession session) {
+    public nextMetaDataResults_args setSession(Session session) {
       this.session = session;
       return this;
     }
@@ -2476,13 +2243,44 @@ public class BlurTuple {
       }
     }
 
+    public int getBatchSize() {
+      return this.batchSize;
+    }
+
+    public nextMetaDataResults_args setBatchSize(int batchSize) {
+      this.batchSize = batchSize;
+      setBatchSizeIsSet(true);
+      return this;
+    }
+
+    public void unsetBatchSize() {
+      __isset_bit_vector.clear(__BATCHSIZE_ISSET_ID);
+    }
+
+    /** Returns true if field batchSize is set (has been assigned a value) and false otherwise */
+    public boolean isSetBatchSize() {
+      return __isset_bit_vector.get(__BATCHSIZE_ISSET_ID);
+    }
+
+    public void setBatchSizeIsSet(boolean value) {
+      __isset_bit_vector.set(__BATCHSIZE_ISSET_ID, value);
+    }
+
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
       case SESSION:
         if (value == null) {
           unsetSession();
         } else {
-          setSession((ReadSession)value);
+          setSession((Session)value);
+        }
+        break;
+
+      case BATCH_SIZE:
+        if (value == null) {
+          unsetBatchSize();
+        } else {
+          setBatchSize((Integer)value);
         }
         break;
 
@@ -2494,6 +2292,9 @@ public class BlurTuple {
       case SESSION:
         return getSession();
 
+      case BATCH_SIZE:
+        return Integer.valueOf(getBatchSize());
+
       }
       throw new IllegalStateException();
     }
@@ -2507,6 +2308,8 @@ public class BlurTuple {
       switch (field) {
       case SESSION:
         return isSetSession();
+      case BATCH_SIZE:
+        return isSetBatchSize();
       }
       throw new IllegalStateException();
     }
@@ -2515,12 +2318,12 @@ public class BlurTuple {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof nextMetaDataResult_args)
-        return this.equals((nextMetaDataResult_args)that);
+      if (that instanceof nextMetaDataResults_args)
+        return this.equals((nextMetaDataResults_args)that);
       return false;
     }
 
-    public boolean equals(nextMetaDataResult_args that) {
+    public boolean equals(nextMetaDataResults_args that) {
       if (that == null)
         return false;
 
@@ -2533,6 +2336,15 @@ public class BlurTuple {
           return false;
       }
 
+      boolean this_present_batchSize = true;
+      boolean that_present_batchSize = true;
+      if (this_present_batchSize || that_present_batchSize) {
+        if (!(this_present_batchSize && that_present_batchSize))
+          return false;
+        if (this.batchSize != that.batchSize)
+          return false;
+      }
+
       return true;
     }
 
@@ -2541,13 +2353,13 @@ public class BlurTuple {
       return 0;
     }
 
-    public int compareTo(nextMetaDataResult_args other) {
+    public int compareTo(nextMetaDataResults_args other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
-      nextMetaDataResult_args typedOther = (nextMetaDataResult_args)other;
+      nextMetaDataResults_args typedOther = (nextMetaDataResults_args)other;
 
       lastComparison = Boolean.valueOf(isSetSession()).compareTo(typedOther.isSetSession());
       if (lastComparison != 0) {
@@ -2559,6 +2371,16 @@ public class BlurTuple {
           return lastComparison;
         }
       }
+      lastComparison = Boolean.valueOf(isSetBatchSize()).compareTo(typedOther.isSetBatchSize());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      if (isSetBatchSize()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.batchSize, typedOther.batchSize);
+        if (lastComparison != 0) {
+          return lastComparison;
+        }
+      }
       return 0;
     }
 
@@ -2578,12 +2400,20 @@ public class BlurTuple {
         switch (field.id) {
           case 1: // SESSION
             if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
-              this.session = new ReadSession();
+              this.session = new Session();
               this.session.read(iprot);
             } else { 
               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
             }
             break;
+          case 2: // BATCH_SIZE
+            if (field.type == org.apache.thrift.protocol.TType.I32) {
+              this.batchSize = iprot.readI32();
+              setBatchSizeIsSet(true);
+            } else { 
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
           default:
             org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
         }
@@ -2604,13 +2434,16 @@ public class BlurTuple {
         this.session.write(oprot);
         oprot.writeFieldEnd();
       }
+      oprot.writeFieldBegin(BATCH_SIZE_FIELD_DESC);
+      oprot.writeI32(this.batchSize);
+      oprot.writeFieldEnd();
       oprot.writeFieldStop();
       oprot.writeStructEnd();
     }
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("nextMetaDataResult_args(");
+      StringBuilder sb = new StringBuilder("nextMetaDataResults_args(");
       boolean first = true;
 
       sb.append("session:");
@@ -2620,6 +2453,10 @@ public class BlurTuple {
         sb.append(this.session);
       }
       first = false;
+      if (!first) sb.append(", ");
+      sb.append("batchSize:");
+      sb.append(this.batchSize);
+      first = false;
       sb.append(")");
       return sb.toString();
     }
@@ -2638,6 +2475,8 @@ public class BlurTuple {
 
     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_bit_vector = new BitSet(1);
         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);
@@ -2646,13 +2485,13 @@ public class BlurTuple {
 
   }
 
-  public static class nextMetaDataResult_result implements org.apache.thrift.TBase<nextMetaDataResult_result, nextMetaDataResult_result._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("nextMetaDataResult_result");
+  public static class nextMetaDataResults_result implements org.apache.thrift.TBase<nextMetaDataResults_result, nextMetaDataResults_result._Fields>, java.io.Serializable, Cloneable   {
+    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("nextMetaDataResults_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 SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.LIST, (short)0);
     private static final org.apache.thrift.protocol.TField E_FIELD_DESC = new org.apache.thrift.protocol.TField("e", org.apache.thrift.protocol.TType.STRUCT, (short)1);
 
-    public ReadResult success; // required
+    public List<Tuple> success; // required
     public BlurException e; // required
 
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
@@ -2722,18 +2561,19 @@ public class BlurTuple {
     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, ReadResult.class)));
+          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, Tuple.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(nextMetaDataResult_result.class, metaDataMap);
+      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(nextMetaDataResults_result.class, metaDataMap);
     }
 
-    public nextMetaDataResult_result() {
+    public nextMetaDataResults_result() {
     }
 
-    public nextMetaDataResult_result(
-      ReadResult success,
+    public nextMetaDataResults_result(
+      List<Tuple> success,
       BlurException e)
     {
       this();
@@ -2744,17 +2584,21 @@ public class BlurTuple {
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public nextMetaDataResult_result(nextMetaDataResult_result other) {
+    public nextMetaDataResults_result(nextMetaDataResults_result other) {
       if (other.isSetSuccess()) {
-        this.success = new ReadResult(other.success);
+        List<Tuple> __this__success = new ArrayList<Tuple>();
+        for (Tuple other_element : other.success) {
+          __this__success.add(new Tuple(other_element));
+        }
+        this.success = __this__success;
       }
       if (other.isSetE()) {
         this.e = new BlurException(other.e);
       }
     }
 
-    public nextMetaDataResult_result deepCopy() {
-      return new nextMetaDataResult_result(this);
+    public nextMetaDataResults_result deepCopy() {
+      return new nextMetaDataResults_result(this);
     }
 
     @Override
@@ -2763,11 +2607,26 @@ public class BlurTuple {
       this.e = null;
     }
 
-    public ReadResult getSuccess() {
+    public int getSuccessSize() {
+      return (this.success == null) ? 0 : this.success.size();
+    }
+
+    public java.util.Iterator<Tuple> getSuccessIterator() {
+      return (this.success == null) ? null : this.success.iterator();
+    }
+
+    public void addToSuccess(Tuple elem) {
+      if (this.success == null) {
+        this.success = new ArrayList<Tuple>();
+      }
+      this.success.add(elem);
+    }
+
+    public List<Tuple> getSuccess() {
       return this.success;
     }
 
-    public nextMetaDataResult_result setSuccess(ReadResult success) {
+    public nextMetaDataResults_result setSuccess(List<Tuple> success) {
       this.success = success;
       return this;
     }
@@ -2791,7 +2650,7 @@ public class BlurTuple {
       return this.e;
     }
 
-    public nextMetaDataResult_result setE(BlurException e) {
+    public nextMetaDataResults_result setE(BlurException e) {
       this.e = e;
       return this;
     }
@@ -2817,7 +2676,7 @@ public class BlurTuple {
         if (value == null) {
           unsetSuccess();
         } else {
-          setSuccess((ReadResult)value);
+          setSuccess((List<Tuple>)value);
         }
         break;
 
@@ -2863,12 +2722,12 @@ public class BlurTuple {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof nextMetaDataResult_result)
-        return this.equals((nextMetaDataResult_result)that);
+      if (that instanceof nextMetaDataResults_result)
+        return this.equals((nextMetaDataResults_result)that);
       return false;
     }
 
-    public boolean equals(nextMetaDataResult_result that) {
+    public boolean equals(nextMetaDataResults_result that) {
       if (that == null)
         return false;
 
@@ -2898,13 +2757,13 @@ public class BlurTuple {
       return 0;
     }
 
-    public int compareTo(nextMetaDataResult_result other) {
+    public int compareTo(nextMetaDataResults_result other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
-      nextMetaDataResult_result typedOther = (nextMetaDataResult_result)other;
+      nextMetaDataResults_result typedOther = (nextMetaDataResults_result)other;
 
       lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess());
       if (lastComparison != 0) {
@@ -2944,9 +2803,19 @@ public class BlurTuple {
         }
         switch (field.id) {
           case 0: // SUCCESS
-            if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
-              this.success = new ReadResult();
-              this.success.read(iprot);
+            if (field.type == org.apache.thrift.protocol.TType.LIST) {
+              {
+                org.apache.thrift.protocol.TList _list4 = iprot.readListBegin();
+                this.success = new ArrayList<Tuple>(_list4.size);
+                for (int _i5 = 0; _i5 < _list4.size; ++_i5)
+                {
+                  Tuple _elem6; // required
+                  _elem6 = new Tuple();
+                  _elem6.read(iprot);
+                  this.success.add(_elem6);
+                }
+                iprot.readListEnd();
+              }
             } else { 
               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
             }
@@ -2975,7 +2844,14 @@ public class BlurTuple {
 
       if (this.isSetSuccess()) {
         oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
-        this.success.write(oprot);
+        {
+          oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.success.size()));
+          for (Tuple _iter7 : this.success)
+          {
+            _iter7.write(oprot);
+          }
+          oprot.writeListEnd();
+        }
         oprot.writeFieldEnd();
       } else if (this.isSetE()) {
         oprot.writeFieldBegin(E_FIELD_DESC);
@@ -2988,7 +2864,7 @@ public class BlurTuple {
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("nextMetaDataResult_result(");
+      StringBuilder sb = new StringBuilder("nextMetaDataResults_result(");
       boolean first = true;
 
       sb.append("success:");
@@ -3032,13 +2908,13 @@ public class BlurTuple {
 
   }
 
-  public static class nextMetaDataResults_args implements org.apache.thrift.TBase<nextMetaDataResults_args, nextMetaDataResults_args._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("nextMetaDataResults_args");
+  public static class nextResults_args implements org.apache.thrift.TBase<nextResults_args, nextResults_args._Fields>, java.io.Serializable, Cloneable   {
+    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("nextResults_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 BATCH_SIZE_FIELD_DESC = new org.apache.thrift.protocol.TField("batchSize", org.apache.thrift.protocol.TType.I32, (short)2);
 
-    public ReadSession session; // required
+    public Session session; // required
     public int batchSize; // required
 
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
@@ -3110,18 +2986,18 @@ public class BlurTuple {
     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, ReadSession.class)));
+          new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Session.class)));
       tmpMap.put(_Fields.BATCH_SIZE, new org.apache.thrift.meta_data.FieldMetaData("batchSize", org.apache.thrift.TFieldRequirementType.DEFAULT, 
           new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(nextMetaDataResults_args.class, metaDataMap);
+      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(nextResults_args.class, metaDataMap);
     }
 
-    public nextMetaDataResults_args() {
+    public nextResults_args() {
     }
 
-    public nextMetaDataResults_args(
-      ReadSession session,
+    public nextResults_args(
+      Session session,
       int batchSize)
     {
       this();
@@ -3133,17 +3009,17 @@ public class BlurTuple {
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public nextMetaDataResults_args(nextMetaDataResults_args other) {
+    public nextResults_args(nextResults_args other) {
       __isset_bit_vector.clear();
       __isset_bit_vector.or(other.__isset_bit_vector);
       if (other.isSetSession()) {
-        this.session = new ReadSession(other.session);
+        this.session = new Session(other.session);
       }
       this.batchSize = other.batchSize;
     }
 
-    public nextMetaDataResults_args deepCopy() {
-      return new nextMetaDataResults_args(this);
+    public nextResults_args deepCopy() {
+      return new nextResults_args(this);
     }
 
     @Override
@@ -3153,11 +3029,11 @@ public class BlurTuple {
       this.batchSize = 0;
     }
 
-    public ReadSession getSession() {
+    public Session getSession() {
       return this.session;
     }
 
-    public nextMetaDataResults_args setSession(ReadSession session) {
+    public nextResults_args setSession(Session session) {
       this.session = session;
       return this;
     }
@@ -3181,7 +3057,7 @@ public class BlurTuple {
       return this.batchSize;
     }
 
-    public nextMetaDataResults_args setBatchSize(int batchSize) {
+    public nextResults_args setBatchSize(int batchSize) {
       this.batchSize = batchSize;
       setBatchSizeIsSet(true);
       return this;
@@ -3206,7 +3082,7 @@ public class BlurTuple {
         if (value == null) {
           unsetSession();
         } else {
-          setSession((ReadSession)value);
+          setSession((Session)value);
         }
         break;
 
@@ -3252,12 +3128,12 @@ public class BlurTuple {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof nextMetaDataResults_args)
-        return this.equals((nextMetaDataResults_args)that);
+      if (that instanceof nextResults_args)
+        return this.equals((nextResults_args)that);
       return false;
     }
 
-    public boolean equals(nextMetaDataResults_args that) {
+    public boolean equals(nextResults_args that) {
       if (that == null)
         return false;
 
@@ -3287,13 +3163,13 @@ public class BlurTuple {
       return 0;
     }
 
-    public int compareTo(nextMetaDataResults_args other) {
+    public int compareTo(nextResults_args other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
-      nextMetaDataResults_args typedOther = (nextMetaDataResults_args)other;
+      nextResults_args typedOther = (nextResults_args)other;
 
       lastComparison = Boolean.valueOf(isSetSession()).compareTo(typedOther.isSetSession());
       if (lastComparison != 0) {
@@ -3334,7 +3210,7 @@ public class BlurTuple {
         switch (field.id) {
           case 1: // SESSION
             if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
-              this.session = new ReadSession();
+              this.session = new Session();
               this.session.read(iprot);
             } else { 
               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
@@ -3377,7 +3253,7 @@ public class BlurTuple {
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("nextMetaDataResults_args(");
+      StringBuilder sb = new StringBuilder("nextResults_args(");
       boolean first = true;
 
       sb.append("session:");
@@ -3419,13 +3295,13 @@ public class BlurTuple {
 
   }
 
-  public static class nextMetaDataResults_result implements org.apache.thrift.TBase<nextMetaDataResults_result, nextMetaDataResults_result._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("nextMetaDataResults_result");
+  public static class nextResults_result implements org.apache.thrift.TBase<nextResults_result, nextResults_result._Fields>, java.io.Serializable, Cloneable   {
+    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("nextResults_result");
 
     private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.LIST, (short)0);
     private static final org.apache.thrift.protocol.TField E_FIELD_DESC = new org.apache.thrift.protocol.TField("e", org.apache.thrift.protocol.TType.STRUCT, (short)1);
 
-    public List<ReadResult> success; // required
+    public List<Tuple> success; // required
     public BlurException e; // required
 
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
@@ -3496,18 +3372,18 @@ public class BlurTuple {
       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.ListMetaData(org.apache.thrift.protocol.TType.LIST, 
-              new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ReadResult.class))));
+              new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Tuple.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(nextMetaDataResults_result.class, metaDataMap);
+      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(nextResults_result.class, metaDataMap);
     }
 
-    public nextMetaDataResults_result() {
+    public nextResults_result() {
     }
 
-    public nextMetaDataResults_result(
-      List<ReadResult> success,
+    public nextResults_result(
+      List<Tuple> success,
       BlurException e)
     {
       this();
@@ -3518,11 +3394,11 @@ public class BlurTuple {
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public nextMetaDataResults_result(nextMetaDataResults_result other) {
+    public nextResults_result(nextResults_result other) {
       if (other.isSetSuccess()) {
-        List<ReadResult> __this__success = new ArrayList<ReadResult>();
-        for (ReadResult other_element : other.success) {
-          __this__success.add(new ReadResult(other_element));
+        List<Tuple> __this__success = new ArrayList<Tuple>();
+        for (Tuple other_element : other.success) {
+          __this__success.add(new Tuple(other_element));
         }
         this.success = __this__success;
       }
@@ -3531,8 +3407,8 @@ public class BlurTuple {
       }
     }
 
-    public nextMetaDataResults_result deepCopy() {
-      return new nextMetaDataResults_result(this);
+    public nextResults_result deepCopy() {
+      return new nextResults_result(this);
     }
 
     @Override
@@ -3545,22 +3421,22 @@ public class BlurTuple {
       return (this.success == null) ? 0 : this.success.size();
     }
 
-    public java.util.Iterator<ReadResult> getSuccessIterator() {
+    public java.util.Iterator<Tuple> getSuccessIterator() {
       return (this.success == null) ? null : this.success.iterator();
     }
 
-    public void addToSuccess(ReadResult elem) {
+    public void addToSuccess(Tuple elem) {
       if (this.success == null) {
-        this.success = new ArrayList<ReadResult>();
+        this.success = new ArrayList<Tuple>();
       }
       this.success.add(elem);
     }
 
-    public List<ReadResult> getSuccess() {
+    public List<Tuple> getSuccess() {
       return this.success;
     }
 
-    public nextMetaDataResults_result setSuccess(List<ReadResult> success) {
+    public nextResults_result setSuccess(List<Tuple> success) {
       this.success = success;
       return this;
     }
@@ -3584,7 +3460,7 @@ public class BlurTuple {
       return this.e;
     }
 
-    public nextMetaDataResults_result setE(BlurException e) {
+    public nextResults_result setE(BlurException e) {
       this.e = e;
       return this;
     }
@@ -3610,7 +3486,7 @@ public class BlurTuple {
         if (value == null) {
           unsetSuccess();
         } else {
-          setSuccess((List<ReadResult>)value);
+          setSuccess((List<Tuple>)value);
         }
         break;
 
@@ -3656,12 +3532,12 @@ public class BlurTuple {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof nextMetaDataResults_result)
-        return this.equals((nextMetaDataResults_result)that);
+      if (that instanceof nextResults_result)
+        return this.equals((nextResults_result)that);
       return false;
     }
 
-    public boolean equals(nextMetaDataResults_result that) {
+    public boolean equals(nextResults_result that) {
       if (that == null)
         return false;
 
@@ -3691,13 +3567,13 @@ public class BlurTuple {
       return 0;
     }
 
-    public int compareTo(nextMetaDataResults_result other) {
+    public int compareTo(nextResults_result other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
-      nextMetaDataResults_result typedOther = (nextMetaDataResults_result)other;
+      nextResults_result typedOther = (nextResults_result)other;
 
       lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess());
       if (lastComparison != 0) {
@@ -3739,14 +3615,14 @@ public class BlurTuple {
           case 0: // SUCCESS
             if (field.type == org.apache.thrift.protocol.TType.LIST) {
               {
-                org.apache.thrift.protocol.TList _list4 = iprot.readListBegin();
-                this.success = new ArrayList<ReadResult>(_list4.size);
-                for (int _i5 = 0; _i5 < _list4.size; ++_i5)
+                org.apache.thrift.protocol.TList _list8 = iprot.readListBegin();
+                this.success = new ArrayList<Tuple>(_list8.size);
+                for (int _i9 = 0; _i9 < _list8.size; ++_i9)
                 {
-                  ReadResult _elem6; // required
-                  _elem6 = new ReadResult();
-                  _elem6.read(iprot);
-                  this.success.add(_elem6);
+                  Tuple _elem10; // required
+                  _elem10 = new Tuple();
+                  _elem10.read(iprot);
+                  this.success.add(_elem10);
                 }
                 iprot.readListEnd();
               }
@@ -3780,9 +3656,9 @@ public class BlurTuple {
         oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
         {
           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, this.success.size()));
-          for (ReadResult _iter7 : this.success)
+          for (Tuple _iter11 : this.success)
           {
-            _iter7.write(oprot);
+            _iter11.write(oprot);
           }
           oprot.writeListEnd();
         }
@@ -3798,7 +3674,7 @@ public class BlurTuple {
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("nextMetaDataResults_result(");
+      StringBuilder sb = new StringBuilder("nextResults_result(");
       boolean first = true;
 
       sb.append("success:");
@@ -3842,12 +3718,12 @@ public class BlurTuple {
 
   }
 
-  public static class nextResult_args implements org.apache.thrift.TBase<nextResult_args, nextResult_args._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("nextResult_args");
+  public static class closeReadSession_args implements org.apache.thrift.TBase<closeReadSession_args, closeReadSession_args._Fields>, java.io.Serializable, Cloneable   {
+    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("closeReadSession_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);
 
-    public ReadSession session; // required
+    public Session session; // 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 {
@@ -3913,16 +3789,16 @@ public class BlurTuple {
     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, ReadSession.class)));
+          new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, Session.class)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
-      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(nextResult_args.class, metaDataMap);
+      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(closeReadSession_args.class, metaDataMap);
     }
 
-    public nextResult_args() {
+    public closeReadSession_args() {
     }
 
-    public nextResult_args(
-      ReadSession session)
+    public closeReadSession_args(
+      Session session)
     {
       this();
       this.session = session;
@@ -3931,14 +3807,14 @@ public class BlurTuple {
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public nextResult_args(nextResult_args other) {
+    public closeReadSession_args(closeReadSession_args other) {
       if (other.isSetSession()) {
-        this.session = new ReadSession(other.session);
+        this.session = new Session(other.session);
       }
     }
 
-    public nextResult_args deepCopy() {
-      return new nextResult_args(this);
+    public closeReadSession_args deepCopy() {
+      return new closeReadSession_args(this);
     }
 
     @Override
@@ -3946,11 +3822,11 @@ public class BlurTuple {
       this.session = null;
     }
 
-    public ReadSession getSession() {
+    public Session getSession() {
       return this.session;
     }
 
-    public nextResult_args setSession(ReadSession session) {
+    public closeReadSession_args setSession(Session session) {
       this.session = session;
       return this;
     }
@@ -3976,7 +3852,7 @@ public class BlurTuple {
         if (value == null) {
           unsetSession();
         } else {
-          setSession((ReadSession)value);
+          setSession((Session)value);
         }
         break;
 
@@ -4009,12 +3885,12 @@ public class BlurTuple {
     public boolean equals(Object that) {
       if (that == null)
         return false;
-      if (that instanceof nextResult_args)
-        return this.equals((nextResult_args)that);
+      if (that instanceof closeReadSession_args)
+        return this.equals((closeReadSession_args)that);
       return false;
     }
 
-    public boolean equals(nextResult_args that) {
+    public boolean equals(closeReadSession_args that) {
       if (that == null)
         return false;
 
@@ -4035,13 +3911,13 @@ public class BlurTuple {
       return 0;
     }
 
-    public int compareTo(nextResult_args other) {
+    public int compareTo(closeReadSession_args other) {
       if (!getClass().equals(other.getClass())) {
         return getClass().getName().compareTo(other.getClass().getName());
       }
 
       int lastComparison = 0;
-      nextResult_args typedOther = (nextResult_args)other;
+      closeReadSession_args typedOther = (closeReadSession_args)other;
 
       lastComparison = Boolean.valueOf(isSetSession()).compareTo(typedOther.isSetSession());
       if (lastComparison != 0) {
@@ -4072,7 +3948,7 @@ public class BlurTuple {
         switch (field.id) {
           case 1: // SESSION
             if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
-              this.session = new ReadSession();
+              this.session = new Session();
               this.session.read(iprot);
             } else { 
               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
@@ -4104,7 +3980,7 @@ public class BlurTuple {
 
     @Override
     public String toString() {
-      StringBuilder sb = new StringBuilder("nextResult_args(");
+      StringBuilder sb = new StringBuilder("closeReadSession_args(");
       boolean first = true;
 
       sb.append("session:");
@@ -4140,18 +4016,15 @@ public class BlurTuple {
 
   }
 
-  public static class nextResult_result implements org.apache.thrift.TBase<nextResult_result, nextResult_result._Fields>, java.io.Serializable, Cloneable   {
-    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("nextResult_result");
+  public static class closeReadSession_result implements org.apache.thrift.TBase<closeReadSession_result, closeReadSession_result._Fields>, java.io.Serializable, Cloneable   {
+    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("closeReadSession_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);
 
-    public ReadResult 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>();
@@ -4167,8 +4040,6 @@ public class BlurTuple {
        */
       public static _Fields findByThriftId(int fieldId) {
         switch(fieldId) {
-          case 0: // SUCCESS
-            return SUCCESS;
           case 1: // E
             return E;
           default:
@@ -4215,77 +4086,45 @@ public class BlurTuple {
     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, ReadResult.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(nextResult_result.class, metaDataMap);
+      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(closeReadSession_result.class, metaDataMap);
     }
 
-    public nextResult_result() {
+    public closeReadSession_result() {
     }
 
-    public nextResult_result(
-      ReadResult success,
+    public closeReadSession_result(
       BlurException e)
     {
       this();
-      this.success = success;
       this.e = e;
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
-    public nextResult_result(nextResult_result other) {
-      if (other.isSetSuccess()) {
-        this.success = new ReadResult(other.success);
-      }
+    public closeReadSession_result(closeR

<TRUNCATED>

Mime
View raw message