cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject svn commit: r768382 [2/3] - in /incubator/cassandra/trunk: interface/ lib/ src/org/apache/cassandra/cli/ src/org/apache/cassandra/cql/driver/ src/org/apache/cassandra/service/
Date Fri, 24 Apr 2009 17:52:25 GMT
Modified: incubator/cassandra/trunk/src/org/apache/cassandra/service/Cassandra.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/org/apache/cassandra/service/Cassandra.java?rev=768382&r1=768381&r2=768382&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/org/apache/cassandra/service/Cassandra.java (original)
+++ incubator/cassandra/trunk/src/org/apache/cassandra/service/Cassandra.java Fri Apr 24 17:52:25 2009
@@ -12,39 +12,40 @@
 import java.util.Set;
 import java.util.HashSet;
 import java.util.Collections;
+
 import org.apache.thrift.*;
 import org.apache.thrift.meta_data.*;
-
 import org.apache.thrift.protocol.*;
-import org.apache.thrift.transport.*;
 
 public class Cassandra {
 
   public interface Iface {
 
-    public List<column_t> get_slice(String tablename, String key, String columnFamily_column, int start, int count) throws InvalidRequestException, NotFoundException, CassandraException, TException;
+    public List<column_t> get_slice(String tablename, String key, String columnFamily_column, int start, int count) throws InvalidRequestException, NotFoundException, TException;
 
-    public List<column_t> get_slice_by_names(String tablename, String key, String columnFamily, List<String> columnNames) throws InvalidRequestException, NotFoundException, CassandraException, TException;
+    public List<column_t> get_slice_by_names(String tablename, String key, String columnFamily, List<String> columnNames) throws InvalidRequestException, NotFoundException, TException;
 
-    public column_t get_column(String tablename, String key, String columnFamily_column) throws InvalidRequestException, NotFoundException, CassandraException, TException;
+    public column_t get_column(String tablename, String key, String columnFamily_column) throws InvalidRequestException, NotFoundException, TException;
 
-    public int get_column_count(String tablename, String key, String columnFamily_column) throws InvalidRequestException, CassandraException, TException;
+    public int get_column_count(String tablename, String key, String columnFamily_column) throws InvalidRequestException, TException;
 
     public void insert(String tablename, String key, String columnFamily_column, byte[] cellData, long timestamp) throws TException;
 
     public void batch_insert(batch_mutation_t batchMutation) throws TException;
 
+    public boolean insert_blocking(String tablename, String key, String columnFamily_column, byte[] cellData, long timestamp) throws InvalidRequestException, TException;
+
     public boolean batch_insert_blocking(batch_mutation_t batchMutation) throws InvalidRequestException, TException;
 
     public boolean remove(String tablename, String key, String columnFamily_column, long timestamp, boolean block) throws InvalidRequestException, TException;
 
-    public List<column_t> get_columns_since(String tablename, String key, String columnFamily_column, long timeStamp) throws InvalidRequestException, NotFoundException, CassandraException, TException;
+    public List<column_t> get_columns_since(String tablename, String key, String columnFamily_column, long timeStamp) throws InvalidRequestException, NotFoundException, TException;
 
-    public List<superColumn_t> get_slice_super(String tablename, String key, String columnFamily_superColumnName, int start, int count) throws InvalidRequestException, CassandraException, TException;
+    public List<superColumn_t> get_slice_super(String tablename, String key, String columnFamily_superColumnName, int start, int count) throws InvalidRequestException, TException;
 
-    public List<superColumn_t> get_slice_super_by_names(String tablename, String key, String columnFamily, List<String> superColumnNames) throws InvalidRequestException, CassandraException, TException;
+    public List<superColumn_t> get_slice_super_by_names(String tablename, String key, String columnFamily, List<String> superColumnNames) throws InvalidRequestException, TException;
 
-    public superColumn_t get_superColumn(String tablename, String key, String columnFamily) throws InvalidRequestException, NotFoundException, CassandraException, TException;
+    public superColumn_t get_superColumn(String tablename, String key, String columnFamily) throws InvalidRequestException, NotFoundException, TException;
 
     public void batch_insert_superColumn(batch_mutation_super_t batchMutationSuper) throws TException;
 
@@ -89,7 +90,7 @@
       return this.oprot_;
     }
 
-    public List<column_t> get_slice(String tablename, String key, String columnFamily_column, int start, int count) throws InvalidRequestException, NotFoundException, CassandraException, TException
+    public List<column_t> get_slice(String tablename, String key, String columnFamily_column, int start, int count) throws InvalidRequestException, NotFoundException, TException
     {
       send_get_slice(tablename, key, columnFamily_column, start, count);
       return recv_get_slice();
@@ -109,7 +110,7 @@
       oprot_.getTransport().flush();
     }
 
-    public List<column_t> recv_get_slice() throws InvalidRequestException, NotFoundException, CassandraException, TException
+    public List<column_t> recv_get_slice() throws InvalidRequestException, NotFoundException, TException
     {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
@@ -120,22 +121,19 @@
       get_slice_result result = new get_slice_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
-      if (result.__isset.success) {
+      if (result.isSetSuccess()) {
         return result.success;
       }
-      if (result.__isset.ire) {
+      if (result.ire != null) {
         throw result.ire;
       }
-      if (result.__isset.nfe) {
+      if (result.nfe != null) {
         throw result.nfe;
       }
-      if (result.__isset.ce) {
-        throw result.ce;
-      }
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_slice failed: unknown result");
     }
 
-    public List<column_t> get_slice_by_names(String tablename, String key, String columnFamily, List<String> columnNames) throws InvalidRequestException, NotFoundException, CassandraException, TException
+    public List<column_t> get_slice_by_names(String tablename, String key, String columnFamily, List<String> columnNames) throws InvalidRequestException, NotFoundException, TException
     {
       send_get_slice_by_names(tablename, key, columnFamily, columnNames);
       return recv_get_slice_by_names();
@@ -154,7 +152,7 @@
       oprot_.getTransport().flush();
     }
 
-    public List<column_t> recv_get_slice_by_names() throws InvalidRequestException, NotFoundException, CassandraException, TException
+    public List<column_t> recv_get_slice_by_names() throws InvalidRequestException, NotFoundException, TException
     {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
@@ -165,22 +163,19 @@
       get_slice_by_names_result result = new get_slice_by_names_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
-      if (result.__isset.success) {
+      if (result.isSetSuccess()) {
         return result.success;
       }
-      if (result.__isset.ire) {
+      if (result.ire != null) {
         throw result.ire;
       }
-      if (result.__isset.nfe) {
+      if (result.nfe != null) {
         throw result.nfe;
       }
-      if (result.__isset.ce) {
-        throw result.ce;
-      }
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_slice_by_names failed: unknown result");
     }
 
-    public column_t get_column(String tablename, String key, String columnFamily_column) throws InvalidRequestException, NotFoundException, CassandraException, TException
+    public column_t get_column(String tablename, String key, String columnFamily_column) throws InvalidRequestException, NotFoundException, TException
     {
       send_get_column(tablename, key, columnFamily_column);
       return recv_get_column();
@@ -198,7 +193,7 @@
       oprot_.getTransport().flush();
     }
 
-    public column_t recv_get_column() throws InvalidRequestException, NotFoundException, CassandraException, TException
+    public column_t recv_get_column() throws InvalidRequestException, NotFoundException, TException
     {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
@@ -209,22 +204,19 @@
       get_column_result result = new get_column_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
-      if (result.__isset.success) {
+      if (result.isSetSuccess()) {
         return result.success;
       }
-      if (result.__isset.ire) {
+      if (result.ire != null) {
         throw result.ire;
       }
-      if (result.__isset.nfe) {
+      if (result.nfe != null) {
         throw result.nfe;
       }
-      if (result.__isset.ce) {
-        throw result.ce;
-      }
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_column failed: unknown result");
     }
 
-    public int get_column_count(String tablename, String key, String columnFamily_column) throws InvalidRequestException, CassandraException, TException
+    public int get_column_count(String tablename, String key, String columnFamily_column) throws InvalidRequestException, TException
     {
       send_get_column_count(tablename, key, columnFamily_column);
       return recv_get_column_count();
@@ -242,7 +234,7 @@
       oprot_.getTransport().flush();
     }
 
-    public int recv_get_column_count() throws InvalidRequestException, CassandraException, TException
+    public int recv_get_column_count() throws InvalidRequestException, TException
     {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
@@ -253,15 +245,12 @@
       get_column_count_result result = new get_column_count_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
-      if (result.__isset.success) {
+      if (result.isSetSuccess()) {
         return result.success;
       }
-      if (result.__isset.ire) {
+      if (result.ire != null) {
         throw result.ire;
       }
-      if (result.__isset.ce) {
-        throw result.ce;
-      }
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_column_count failed: unknown result");
     }
 
@@ -299,6 +288,46 @@
       oprot_.getTransport().flush();
     }
 
+    public boolean insert_blocking(String tablename, String key, String columnFamily_column, byte[] cellData, long timestamp) throws InvalidRequestException, TException
+    {
+      send_insert_blocking(tablename, key, columnFamily_column, cellData, timestamp);
+      return recv_insert_blocking();
+    }
+
+    public void send_insert_blocking(String tablename, String key, String columnFamily_column, byte[] cellData, long timestamp) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("insert_blocking", TMessageType.CALL, seqid_));
+      insert_blocking_args args = new insert_blocking_args();
+      args.tablename = tablename;
+      args.key = key;
+      args.columnFamily_column = columnFamily_column;
+      args.cellData = cellData;
+      args.timestamp = timestamp;
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public boolean recv_insert_blocking() throws InvalidRequestException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      insert_blocking_result result = new insert_blocking_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
+      if (result.ire != null) {
+        throw result.ire;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "insert_blocking failed: unknown result");
+    }
+
     public boolean batch_insert_blocking(batch_mutation_t batchMutation) throws InvalidRequestException, TException
     {
       send_batch_insert_blocking(batchMutation);
@@ -326,10 +355,10 @@
       batch_insert_blocking_result result = new batch_insert_blocking_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
-      if (result.__isset.success) {
+      if (result.isSetSuccess()) {
         return result.success;
       }
-      if (result.__isset.ire) {
+      if (result.ire != null) {
         throw result.ire;
       }
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "batch_insert_blocking failed: unknown result");
@@ -366,16 +395,16 @@
       remove_result result = new remove_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
-      if (result.__isset.success) {
+      if (result.isSetSuccess()) {
         return result.success;
       }
-      if (result.__isset.ire) {
+      if (result.ire != null) {
         throw result.ire;
       }
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "remove failed: unknown result");
     }
 
-    public List<column_t> get_columns_since(String tablename, String key, String columnFamily_column, long timeStamp) throws InvalidRequestException, NotFoundException, CassandraException, TException
+    public List<column_t> get_columns_since(String tablename, String key, String columnFamily_column, long timeStamp) throws InvalidRequestException, NotFoundException, TException
     {
       send_get_columns_since(tablename, key, columnFamily_column, timeStamp);
       return recv_get_columns_since();
@@ -394,7 +423,7 @@
       oprot_.getTransport().flush();
     }
 
-    public List<column_t> recv_get_columns_since() throws InvalidRequestException, NotFoundException, CassandraException, TException
+    public List<column_t> recv_get_columns_since() throws InvalidRequestException, NotFoundException, TException
     {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
@@ -405,22 +434,19 @@
       get_columns_since_result result = new get_columns_since_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
-      if (result.__isset.success) {
+      if (result.isSetSuccess()) {
         return result.success;
       }
-      if (result.__isset.ire) {
+      if (result.ire != null) {
         throw result.ire;
       }
-      if (result.__isset.nfe) {
+      if (result.nfe != null) {
         throw result.nfe;
       }
-      if (result.__isset.ce) {
-        throw result.ce;
-      }
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_columns_since failed: unknown result");
     }
 
-    public List<superColumn_t> get_slice_super(String tablename, String key, String columnFamily_superColumnName, int start, int count) throws InvalidRequestException, CassandraException, TException
+    public List<superColumn_t> get_slice_super(String tablename, String key, String columnFamily_superColumnName, int start, int count) throws InvalidRequestException, TException
     {
       send_get_slice_super(tablename, key, columnFamily_superColumnName, start, count);
       return recv_get_slice_super();
@@ -440,7 +466,7 @@
       oprot_.getTransport().flush();
     }
 
-    public List<superColumn_t> recv_get_slice_super() throws InvalidRequestException, CassandraException, TException
+    public List<superColumn_t> recv_get_slice_super() throws InvalidRequestException, TException
     {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
@@ -451,19 +477,16 @@
       get_slice_super_result result = new get_slice_super_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
-      if (result.__isset.success) {
+      if (result.isSetSuccess()) {
         return result.success;
       }
-      if (result.__isset.ire) {
+      if (result.ire != null) {
         throw result.ire;
       }
-      if (result.__isset.ce) {
-        throw result.ce;
-      }
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_slice_super failed: unknown result");
     }
 
-    public List<superColumn_t> get_slice_super_by_names(String tablename, String key, String columnFamily, List<String> superColumnNames) throws InvalidRequestException, CassandraException, TException
+    public List<superColumn_t> get_slice_super_by_names(String tablename, String key, String columnFamily, List<String> superColumnNames) throws InvalidRequestException, TException
     {
       send_get_slice_super_by_names(tablename, key, columnFamily, superColumnNames);
       return recv_get_slice_super_by_names();
@@ -482,7 +505,7 @@
       oprot_.getTransport().flush();
     }
 
-    public List<superColumn_t> recv_get_slice_super_by_names() throws InvalidRequestException, CassandraException, TException
+    public List<superColumn_t> recv_get_slice_super_by_names() throws InvalidRequestException, TException
     {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
@@ -493,19 +516,16 @@
       get_slice_super_by_names_result result = new get_slice_super_by_names_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
-      if (result.__isset.success) {
+      if (result.isSetSuccess()) {
         return result.success;
       }
-      if (result.__isset.ire) {
+      if (result.ire != null) {
         throw result.ire;
       }
-      if (result.__isset.ce) {
-        throw result.ce;
-      }
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_slice_super_by_names failed: unknown result");
     }
 
-    public superColumn_t get_superColumn(String tablename, String key, String columnFamily) throws InvalidRequestException, NotFoundException, CassandraException, TException
+    public superColumn_t get_superColumn(String tablename, String key, String columnFamily) throws InvalidRequestException, NotFoundException, TException
     {
       send_get_superColumn(tablename, key, columnFamily);
       return recv_get_superColumn();
@@ -523,7 +543,7 @@
       oprot_.getTransport().flush();
     }
 
-    public superColumn_t recv_get_superColumn() throws InvalidRequestException, NotFoundException, CassandraException, TException
+    public superColumn_t recv_get_superColumn() throws InvalidRequestException, NotFoundException, TException
     {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
@@ -534,18 +554,15 @@
       get_superColumn_result result = new get_superColumn_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
-      if (result.__isset.success) {
+      if (result.isSetSuccess()) {
         return result.success;
       }
-      if (result.__isset.ire) {
+      if (result.ire != null) {
         throw result.ire;
       }
-      if (result.__isset.nfe) {
+      if (result.nfe != null) {
         throw result.nfe;
       }
-      if (result.__isset.ce) {
-        throw result.ce;
-      }
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_superColumn failed: unknown result");
     }
 
@@ -591,10 +608,10 @@
       batch_insert_superColumn_blocking_result result = new batch_insert_superColumn_blocking_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
-      if (result.__isset.success) {
+      if (result.isSetSuccess()) {
         return result.success;
       }
-      if (result.__isset.ire) {
+      if (result.ire != null) {
         throw result.ire;
       }
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "batch_insert_superColumn_blocking failed: unknown result");
@@ -643,7 +660,7 @@
       getStringProperty_result result = new getStringProperty_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
-      if (result.__isset.success) {
+      if (result.isSetSuccess()) {
         return result.success;
       }
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "getStringProperty failed: unknown result");
@@ -676,7 +693,7 @@
       getStringListProperty_result result = new getStringListProperty_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
-      if (result.__isset.success) {
+      if (result.isSetSuccess()) {
         return result.success;
       }
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "getStringListProperty failed: unknown result");
@@ -709,7 +726,7 @@
       describeTable_result result = new describeTable_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
-      if (result.__isset.success) {
+      if (result.isSetSuccess()) {
         return result.success;
       }
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "describeTable failed: unknown result");
@@ -742,7 +759,7 @@
       executeQuery_result result = new executeQuery_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
-      if (result.__isset.success) {
+      if (result.isSetSuccess()) {
         return result.success;
       }
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "executeQuery failed: unknown result");
@@ -759,6 +776,7 @@
       processMap_.put("get_column_count", new get_column_count());
       processMap_.put("insert", new insert());
       processMap_.put("batch_insert", new batch_insert());
+      processMap_.put("insert_blocking", new insert_blocking());
       processMap_.put("batch_insert_blocking", new batch_insert_blocking());
       processMap_.put("remove", new remove());
       processMap_.put("get_columns_since", new get_columns_since());
@@ -808,16 +826,17 @@
         get_slice_result result = new get_slice_result();
         try {
           result.success = iface_.get_slice(args.tablename, args.key, args.columnFamily_column, args.start, args.count);
-          result.__isset.success = true;
         } catch (InvalidRequestException ire) {
           result.ire = ire;
-          result.__isset.ire = true;
         } catch (NotFoundException nfe) {
           result.nfe = nfe;
-          result.__isset.nfe = true;
-        } catch (CassandraException ce) {
-          result.ce = ce;
-          result.__isset.ce = true;
+        } catch (Throwable th) {
+          TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing get_slice");
+          oprot.writeMessageBegin(new TMessage("get_slice", TMessageType.EXCEPTION, seqid));
+          x.write(oprot);
+          oprot.writeMessageEnd();
+          oprot.getTransport().flush();
+          return;
         }
         oprot.writeMessageBegin(new TMessage("get_slice", TMessageType.REPLY, seqid));
         result.write(oprot);
@@ -836,16 +855,17 @@
         get_slice_by_names_result result = new get_slice_by_names_result();
         try {
           result.success = iface_.get_slice_by_names(args.tablename, args.key, args.columnFamily, args.columnNames);
-          result.__isset.success = true;
         } catch (InvalidRequestException ire) {
           result.ire = ire;
-          result.__isset.ire = true;
         } catch (NotFoundException nfe) {
           result.nfe = nfe;
-          result.__isset.nfe = true;
-        } catch (CassandraException ce) {
-          result.ce = ce;
-          result.__isset.ce = true;
+        } catch (Throwable th) {
+          TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing get_slice_by_names");
+          oprot.writeMessageBegin(new TMessage("get_slice_by_names", TMessageType.EXCEPTION, seqid));
+          x.write(oprot);
+          oprot.writeMessageEnd();
+          oprot.getTransport().flush();
+          return;
         }
         oprot.writeMessageBegin(new TMessage("get_slice_by_names", TMessageType.REPLY, seqid));
         result.write(oprot);
@@ -864,16 +884,17 @@
         get_column_result result = new get_column_result();
         try {
           result.success = iface_.get_column(args.tablename, args.key, args.columnFamily_column);
-          result.__isset.success = true;
         } catch (InvalidRequestException ire) {
           result.ire = ire;
-          result.__isset.ire = true;
         } catch (NotFoundException nfe) {
           result.nfe = nfe;
-          result.__isset.nfe = true;
-        } catch (CassandraException ce) {
-          result.ce = ce;
-          result.__isset.ce = true;
+        } catch (Throwable th) {
+          TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing get_column");
+          oprot.writeMessageBegin(new TMessage("get_column", TMessageType.EXCEPTION, seqid));
+          x.write(oprot);
+          oprot.writeMessageEnd();
+          oprot.getTransport().flush();
+          return;
         }
         oprot.writeMessageBegin(new TMessage("get_column", TMessageType.REPLY, seqid));
         result.write(oprot);
@@ -895,10 +916,13 @@
           result.__isset.success = true;
         } catch (InvalidRequestException ire) {
           result.ire = ire;
-          result.__isset.ire = true;
-        } catch (CassandraException ce) {
-          result.ce = ce;
-          result.__isset.ce = true;
+        } catch (Throwable th) {
+          TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing get_column_count");
+          oprot.writeMessageBegin(new TMessage("get_column_count", TMessageType.EXCEPTION, seqid));
+          x.write(oprot);
+          oprot.writeMessageEnd();
+          oprot.getTransport().flush();
+          return;
         }
         oprot.writeMessageBegin(new TMessage("get_column_count", TMessageType.REPLY, seqid));
         result.write(oprot);
@@ -930,6 +954,34 @@
       }
     }
 
+    private class insert_blocking implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        insert_blocking_args args = new insert_blocking_args();
+        args.read(iprot);
+        iprot.readMessageEnd();
+        insert_blocking_result result = new insert_blocking_result();
+        try {
+          result.success = iface_.insert_blocking(args.tablename, args.key, args.columnFamily_column, args.cellData, args.timestamp);
+          result.__isset.success = true;
+        } catch (InvalidRequestException ire) {
+          result.ire = ire;
+        } catch (Throwable th) {
+          TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing insert_blocking");
+          oprot.writeMessageBegin(new TMessage("insert_blocking", TMessageType.EXCEPTION, seqid));
+          x.write(oprot);
+          oprot.writeMessageEnd();
+          oprot.getTransport().flush();
+          return;
+        }
+        oprot.writeMessageBegin(new TMessage("insert_blocking", TMessageType.REPLY, seqid));
+        result.write(oprot);
+        oprot.writeMessageEnd();
+        oprot.getTransport().flush();
+      }
+
+    }
+
     private class batch_insert_blocking implements ProcessFunction {
       public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
       {
@@ -942,7 +994,13 @@
           result.__isset.success = true;
         } catch (InvalidRequestException ire) {
           result.ire = ire;
-          result.__isset.ire = true;
+        } catch (Throwable th) {
+          TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing batch_insert_blocking");
+          oprot.writeMessageBegin(new TMessage("batch_insert_blocking", TMessageType.EXCEPTION, seqid));
+          x.write(oprot);
+          oprot.writeMessageEnd();
+          oprot.getTransport().flush();
+          return;
         }
         oprot.writeMessageBegin(new TMessage("batch_insert_blocking", TMessageType.REPLY, seqid));
         result.write(oprot);
@@ -964,7 +1022,13 @@
           result.__isset.success = true;
         } catch (InvalidRequestException ire) {
           result.ire = ire;
-          result.__isset.ire = true;
+        } catch (Throwable th) {
+          TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing remove");
+          oprot.writeMessageBegin(new TMessage("remove", TMessageType.EXCEPTION, seqid));
+          x.write(oprot);
+          oprot.writeMessageEnd();
+          oprot.getTransport().flush();
+          return;
         }
         oprot.writeMessageBegin(new TMessage("remove", TMessageType.REPLY, seqid));
         result.write(oprot);
@@ -983,16 +1047,17 @@
         get_columns_since_result result = new get_columns_since_result();
         try {
           result.success = iface_.get_columns_since(args.tablename, args.key, args.columnFamily_column, args.timeStamp);
-          result.__isset.success = true;
         } catch (InvalidRequestException ire) {
           result.ire = ire;
-          result.__isset.ire = true;
         } catch (NotFoundException nfe) {
           result.nfe = nfe;
-          result.__isset.nfe = true;
-        } catch (CassandraException ce) {
-          result.ce = ce;
-          result.__isset.ce = true;
+        } catch (Throwable th) {
+          TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing get_columns_since");
+          oprot.writeMessageBegin(new TMessage("get_columns_since", TMessageType.EXCEPTION, seqid));
+          x.write(oprot);
+          oprot.writeMessageEnd();
+          oprot.getTransport().flush();
+          return;
         }
         oprot.writeMessageBegin(new TMessage("get_columns_since", TMessageType.REPLY, seqid));
         result.write(oprot);
@@ -1011,13 +1076,15 @@
         get_slice_super_result result = new get_slice_super_result();
         try {
           result.success = iface_.get_slice_super(args.tablename, args.key, args.columnFamily_superColumnName, args.start, args.count);
-          result.__isset.success = true;
         } catch (InvalidRequestException ire) {
           result.ire = ire;
-          result.__isset.ire = true;
-        } catch (CassandraException ce) {
-          result.ce = ce;
-          result.__isset.ce = true;
+        } catch (Throwable th) {
+          TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing get_slice_super");
+          oprot.writeMessageBegin(new TMessage("get_slice_super", TMessageType.EXCEPTION, seqid));
+          x.write(oprot);
+          oprot.writeMessageEnd();
+          oprot.getTransport().flush();
+          return;
         }
         oprot.writeMessageBegin(new TMessage("get_slice_super", TMessageType.REPLY, seqid));
         result.write(oprot);
@@ -1036,13 +1103,15 @@
         get_slice_super_by_names_result result = new get_slice_super_by_names_result();
         try {
           result.success = iface_.get_slice_super_by_names(args.tablename, args.key, args.columnFamily, args.superColumnNames);
-          result.__isset.success = true;
         } catch (InvalidRequestException ire) {
           result.ire = ire;
-          result.__isset.ire = true;
-        } catch (CassandraException ce) {
-          result.ce = ce;
-          result.__isset.ce = true;
+        } catch (Throwable th) {
+          TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing get_slice_super_by_names");
+          oprot.writeMessageBegin(new TMessage("get_slice_super_by_names", TMessageType.EXCEPTION, seqid));
+          x.write(oprot);
+          oprot.writeMessageEnd();
+          oprot.getTransport().flush();
+          return;
         }
         oprot.writeMessageBegin(new TMessage("get_slice_super_by_names", TMessageType.REPLY, seqid));
         result.write(oprot);
@@ -1061,16 +1130,17 @@
         get_superColumn_result result = new get_superColumn_result();
         try {
           result.success = iface_.get_superColumn(args.tablename, args.key, args.columnFamily);
-          result.__isset.success = true;
         } catch (InvalidRequestException ire) {
           result.ire = ire;
-          result.__isset.ire = true;
         } catch (NotFoundException nfe) {
           result.nfe = nfe;
-          result.__isset.nfe = true;
-        } catch (CassandraException ce) {
-          result.ce = ce;
-          result.__isset.ce = true;
+        } catch (Throwable th) {
+          TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing get_superColumn");
+          oprot.writeMessageBegin(new TMessage("get_superColumn", TMessageType.EXCEPTION, seqid));
+          x.write(oprot);
+          oprot.writeMessageEnd();
+          oprot.getTransport().flush();
+          return;
         }
         oprot.writeMessageBegin(new TMessage("get_superColumn", TMessageType.REPLY, seqid));
         result.write(oprot);
@@ -1103,7 +1173,13 @@
           result.__isset.success = true;
         } catch (InvalidRequestException ire) {
           result.ire = ire;
-          result.__isset.ire = true;
+        } catch (Throwable th) {
+          TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing batch_insert_superColumn_blocking");
+          oprot.writeMessageBegin(new TMessage("batch_insert_superColumn_blocking", TMessageType.EXCEPTION, seqid));
+          x.write(oprot);
+          oprot.writeMessageEnd();
+          oprot.getTransport().flush();
+          return;
         }
         oprot.writeMessageBegin(new TMessage("batch_insert_superColumn_blocking", TMessageType.REPLY, seqid));
         result.write(oprot);
@@ -1132,7 +1208,6 @@
         iprot.readMessageEnd();
         getStringProperty_result result = new getStringProperty_result();
         result.success = iface_.getStringProperty(args.propertyName);
-        result.__isset.success = true;
         oprot.writeMessageBegin(new TMessage("getStringProperty", TMessageType.REPLY, seqid));
         result.write(oprot);
         oprot.writeMessageEnd();
@@ -1149,7 +1224,6 @@
         iprot.readMessageEnd();
         getStringListProperty_result result = new getStringListProperty_result();
         result.success = iface_.getStringListProperty(args.propertyName);
-        result.__isset.success = true;
         oprot.writeMessageBegin(new TMessage("getStringListProperty", TMessageType.REPLY, seqid));
         result.write(oprot);
         oprot.writeMessageEnd();
@@ -1166,7 +1240,6 @@
         iprot.readMessageEnd();
         describeTable_result result = new describeTable_result();
         result.success = iface_.describeTable(args.tableName);
-        result.__isset.success = true;
         oprot.writeMessageBegin(new TMessage("describeTable", TMessageType.REPLY, seqid));
         result.write(oprot);
         oprot.writeMessageEnd();
@@ -1183,7 +1256,6 @@
         iprot.readMessageEnd();
         executeQuery_result result = new executeQuery_result();
         result.success = iface_.executeQuery(args.query);
-        result.__isset.success = true;
         oprot.writeMessageBegin(new TMessage("executeQuery", TMessageType.REPLY, seqid));
         result.write(oprot);
         oprot.writeMessageEnd();
@@ -1196,28 +1268,25 @@
 
   public static class get_slice_args implements TBase, java.io.Serializable, Cloneable   {
     private static final TStruct STRUCT_DESC = new TStruct("get_slice_args");
-    private static final TField TABLENAME_FIELD_DESC = new TField("tablename", TType.STRING, (short)-1);
-    private static final TField KEY_FIELD_DESC = new TField("key", TType.STRING, (short)-2);
-    private static final TField COLUMN_FAMILY_COLUMN_FIELD_DESC = new TField("columnFamily_column", TType.STRING, (short)-3);
-    private static final TField START_FIELD_DESC = new TField("start", TType.I32, (short)-4);
-    private static final TField COUNT_FIELD_DESC = new TField("count", TType.I32, (short)-5);
+    private static final TField TABLENAME_FIELD_DESC = new TField("tablename", TType.STRING, (short)1);
+    private static final TField KEY_FIELD_DESC = new TField("key", TType.STRING, (short)2);
+    private static final TField COLUMN_FAMILY_COLUMN_FIELD_DESC = new TField("columnFamily_column", TType.STRING, (short)3);
+    private static final TField START_FIELD_DESC = new TField("start", TType.I32, (short)4);
+    private static final TField COUNT_FIELD_DESC = new TField("count", TType.I32, (short)5);
 
     public String tablename;
-    public static final int TABLENAME = -1;
+    public static final int TABLENAME = 1;
     public String key;
-    public static final int KEY = -2;
+    public static final int KEY = 2;
     public String columnFamily_column;
-    public static final int COLUMNFAMILY_COLUMN = -3;
+    public static final int COLUMNFAMILY_COLUMN = 3;
     public int start;
-    public static final int START = -4;
+    public static final int START = 4;
     public int count;
-    public static final int COUNT = -5;
+    public static final int COUNT = 5;
 
     private final Isset __isset = new Isset();
     private static final class Isset implements java.io.Serializable {
-      public boolean tablename = false;
-      public boolean key = false;
-      public boolean columnFamily_column = false;
       public boolean start = false;
       public boolean count = false;
     }
@@ -1255,11 +1324,8 @@
     {
       this();
       this.tablename = tablename;
-      this.__isset.tablename = (tablename != null);
       this.key = key;
-      this.__isset.key = (key != null);
       this.columnFamily_column = columnFamily_column;
-      this.__isset.columnFamily_column = (columnFamily_column != null);
       this.start = start;
       this.__isset.start = true;
       this.count = count;
@@ -1270,16 +1336,13 @@
      * Performs a deep copy on <i>other</i>.
      */
     public get_slice_args(get_slice_args other) {
-      __isset.tablename = other.__isset.tablename;
-      if (other.tablename != null) {
+      if (other.isSetTablename()) {
         this.tablename = other.tablename;
       }
-      __isset.key = other.__isset.key;
-      if (other.key != null) {
+      if (other.isSetKey()) {
         this.key = other.key;
       }
-      __isset.columnFamily_column = other.__isset.columnFamily_column;
-      if (other.columnFamily_column != null) {
+      if (other.isSetColumnFamily_column()) {
         this.columnFamily_column = other.columnFamily_column;
       }
       __isset.start = other.__isset.start;
@@ -1299,20 +1362,21 @@
 
     public void setTablename(String tablename) {
       this.tablename = tablename;
-      this.__isset.tablename = (tablename != null);
     }
 
     public void unsetTablename() {
-      this.__isset.tablename = false;
+      this.tablename = null;
     }
 
     // Returns true if field tablename is set (has been asigned a value) and false otherwise
     public boolean isSetTablename() {
-      return this.__isset.tablename;
+      return this.tablename != null;
     }
 
     public void setTablenameIsSet(boolean value) {
-      this.__isset.tablename = value;
+      if (!value) {
+        this.tablename = null;
+      }
     }
 
     public String getKey() {
@@ -1321,20 +1385,21 @@
 
     public void setKey(String key) {
       this.key = key;
-      this.__isset.key = (key != null);
     }
 
     public void unsetKey() {
-      this.__isset.key = false;
+      this.key = null;
     }
 
     // Returns true if field key is set (has been asigned a value) and false otherwise
     public boolean isSetKey() {
-      return this.__isset.key;
+      return this.key != null;
     }
 
     public void setKeyIsSet(boolean value) {
-      this.__isset.key = value;
+      if (!value) {
+        this.key = null;
+      }
     }
 
     public String getColumnFamily_column() {
@@ -1343,20 +1408,21 @@
 
     public void setColumnFamily_column(String columnFamily_column) {
       this.columnFamily_column = columnFamily_column;
-      this.__isset.columnFamily_column = (columnFamily_column != null);
     }
 
     public void unsetColumnFamily_column() {
-      this.__isset.columnFamily_column = false;
+      this.columnFamily_column = null;
     }
 
     // Returns true if field columnFamily_column is set (has been asigned a value) and false otherwise
     public boolean isSetColumnFamily_column() {
-      return this.__isset.columnFamily_column;
+      return this.columnFamily_column != null;
     }
 
     public void setColumnFamily_columnIsSet(boolean value) {
-      this.__isset.columnFamily_column = value;
+      if (!value) {
+        this.columnFamily_column = null;
+      }
     }
 
     public int getStart() {
@@ -1406,23 +1472,43 @@
     public void setFieldValue(int fieldID, Object value) {
       switch (fieldID) {
       case TABLENAME:
-        setTablename((String)value);
+        if (value == null) {
+          unsetTablename();
+        } else {
+          setTablename((String)value);
+        }
         break;
 
       case KEY:
-        setKey((String)value);
+        if (value == null) {
+          unsetKey();
+        } else {
+          setKey((String)value);
+        }
         break;
 
       case COLUMNFAMILY_COLUMN:
-        setColumnFamily_column((String)value);
+        if (value == null) {
+          unsetColumnFamily_column();
+        } else {
+          setColumnFamily_column((String)value);
+        }
         break;
 
       case START:
-        setStart((Integer)value);
+        if (value == null) {
+          unsetStart();
+        } else {
+          setStart((Integer)value);
+        }
         break;
 
       case COUNT:
-        setCount((Integer)value);
+        if (value == null) {
+          unsetCount();
+        } else {
+          setCount((Integer)value);
+        }
         break;
 
       default:
@@ -1456,15 +1542,15 @@
     public boolean isSet(int fieldID) {
       switch (fieldID) {
       case TABLENAME:
-        return this.__isset.tablename;
+        return isSetTablename();
       case KEY:
-        return this.__isset.key;
+        return isSetKey();
       case COLUMNFAMILY_COLUMN:
-        return this.__isset.columnFamily_column;
+        return isSetColumnFamily_column();
       case START:
-        return this.__isset.start;
+        return isSetStart();
       case COUNT:
-        return this.__isset.count;
+        return isSetCount();
       default:
         throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
       }
@@ -1483,8 +1569,8 @@
       if (that == null)
         return false;
 
-      boolean this_present_tablename = true && (this.tablename != null);
-      boolean that_present_tablename = true && (that.tablename != null);
+      boolean this_present_tablename = true && this.isSetTablename();
+      boolean that_present_tablename = true && that.isSetTablename();
       if (this_present_tablename || that_present_tablename) {
         if (!(this_present_tablename && that_present_tablename))
           return false;
@@ -1492,8 +1578,8 @@
           return false;
       }
 
-      boolean this_present_key = true && (this.key != null);
-      boolean that_present_key = true && (that.key != null);
+      boolean this_present_key = true && this.isSetKey();
+      boolean that_present_key = true && that.isSetKey();
       if (this_present_key || that_present_key) {
         if (!(this_present_key && that_present_key))
           return false;
@@ -1501,8 +1587,8 @@
           return false;
       }
 
-      boolean this_present_columnFamily_column = true && (this.columnFamily_column != null);
-      boolean that_present_columnFamily_column = true && (that.columnFamily_column != null);
+      boolean this_present_columnFamily_column = true && this.isSetColumnFamily_column();
+      boolean that_present_columnFamily_column = true && that.isSetColumnFamily_column();
       if (this_present_columnFamily_column || that_present_columnFamily_column) {
         if (!(this_present_columnFamily_column && that_present_columnFamily_column))
           return false;
@@ -1550,7 +1636,6 @@
           case TABLENAME:
             if (field.type == TType.STRING) {
               this.tablename = iprot.readString();
-              this.__isset.tablename = true;
             } else { 
               TProtocolUtil.skip(iprot, field.type);
             }
@@ -1558,7 +1643,6 @@
           case KEY:
             if (field.type == TType.STRING) {
               this.key = iprot.readString();
-              this.__isset.key = true;
             } else { 
               TProtocolUtil.skip(iprot, field.type);
             }
@@ -1566,7 +1650,6 @@
           case COLUMNFAMILY_COLUMN:
             if (field.type == TType.STRING) {
               this.columnFamily_column = iprot.readString();
-              this.__isset.columnFamily_column = true;
             } else { 
               TProtocolUtil.skip(iprot, field.type);
             }
@@ -1634,17 +1717,28 @@
       StringBuilder sb = new StringBuilder("get_slice_args(");
       boolean first = true;
 
-      if (!first) sb.append(", ");
       sb.append("tablename:");
-      sb.append(this.tablename);
+      if (this.tablename == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.tablename);
+      }
       first = false;
       if (!first) sb.append(", ");
       sb.append("key:");
-      sb.append(this.key);
+      if (this.key == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.key);
+      }
       first = false;
       if (!first) sb.append(", ");
       sb.append("columnFamily_column:");
-      sb.append(this.columnFamily_column);
+      if (this.columnFamily_column == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.columnFamily_column);
+      }
       first = false;
       if (!first) sb.append(", ");
       sb.append("start:");
@@ -1670,7 +1764,6 @@
     private static final TField SUCCESS_FIELD_DESC = new TField("success", TType.LIST, (short)0);
     private static final TField IRE_FIELD_DESC = new TField("ire", TType.STRUCT, (short)1);
     private static final TField NFE_FIELD_DESC = new TField("nfe", TType.STRUCT, (short)2);
-    private static final TField CE_FIELD_DESC = new TField("ce", TType.STRUCT, (short)3);
 
     public List<column_t> success;
     public static final int SUCCESS = 0;
@@ -1678,15 +1771,9 @@
     public static final int IRE = 1;
     public NotFoundException nfe;
     public static final int NFE = 2;
-    public CassandraException ce;
-    public static final int CE = 3;
 
     private final Isset __isset = new Isset();
     private static final class Isset implements java.io.Serializable {
-      public boolean success = false;
-      public boolean ire = false;
-      public boolean nfe = false;
-      public boolean ce = false;
     }
 
     public static final Map<Integer, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new HashMap<Integer, FieldMetaData>() {{
@@ -1697,8 +1784,6 @@
           new FieldValueMetaData(TType.STRUCT)));
       put(NFE, new FieldMetaData("nfe", TFieldRequirementType.DEFAULT, 
           new FieldValueMetaData(TType.STRUCT)));
-      put(CE, new FieldMetaData("ce", TFieldRequirementType.DEFAULT, 
-          new FieldValueMetaData(TType.STRUCT)));
     }});
 
     static {
@@ -1711,44 +1796,31 @@
     public get_slice_result(
       List<column_t> success,
       InvalidRequestException ire,
-      NotFoundException nfe,
-      CassandraException ce)
+      NotFoundException nfe)
     {
       this();
       this.success = success;
-      this.__isset.success = (success != null);
       this.ire = ire;
-      this.__isset.ire = (ire != null);
       this.nfe = nfe;
-      this.__isset.nfe = (nfe != null);
-      this.ce = ce;
-      this.__isset.ce = (ce != null);
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
     public get_slice_result(get_slice_result other) {
-      __isset.success = other.__isset.success;
-      if (other.success != null) {
+      if (other.isSetSuccess()) {
         List<column_t> __this__success = new ArrayList<column_t>();
         for (column_t other_element : other.success) {
           __this__success.add(new column_t(other_element));
         }
         this.success = __this__success;
       }
-      __isset.ire = other.__isset.ire;
-      if (other.ire != null) {
+      if (other.isSetIre()) {
         this.ire = new InvalidRequestException(other.ire);
       }
-      __isset.nfe = other.__isset.nfe;
-      if (other.nfe != null) {
+      if (other.isSetNfe()) {
         this.nfe = new NotFoundException(other.nfe);
       }
-      __isset.ce = other.__isset.ce;
-      if (other.ce != null) {
-        this.ce = new CassandraException(other.ce);
-      }
     }
 
     @Override
@@ -1769,7 +1841,6 @@
         this.success = new ArrayList<column_t>();
       }
       this.success.add(elem);
-      this.__isset.success = true;
     }
 
     public List<column_t> getSuccess() {
@@ -1778,21 +1849,21 @@
 
     public void setSuccess(List<column_t> success) {
       this.success = success;
-      this.__isset.success = (success != null);
     }
 
     public void unsetSuccess() {
       this.success = null;
-      this.__isset.success = false;
     }
 
     // Returns true if field success is set (has been asigned a value) and false otherwise
     public boolean isSetSuccess() {
-      return this.__isset.success;
+      return this.success != null;
     }
 
     public void setSuccessIsSet(boolean value) {
-      this.__isset.success = value;
+      if (!value) {
+        this.success = null;
+      }
     }
 
     public InvalidRequestException getIre() {
@@ -1801,21 +1872,21 @@
 
     public void setIre(InvalidRequestException ire) {
       this.ire = ire;
-      this.__isset.ire = (ire != null);
     }
 
     public void unsetIre() {
       this.ire = null;
-      this.__isset.ire = false;
     }
 
     // Returns true if field ire is set (has been asigned a value) and false otherwise
     public boolean isSetIre() {
-      return this.__isset.ire;
+      return this.ire != null;
     }
 
     public void setIreIsSet(boolean value) {
-      this.__isset.ire = value;
+      if (!value) {
+        this.ire = null;
+      }
     }
 
     public NotFoundException getNfe() {
@@ -1824,62 +1895,47 @@
 
     public void setNfe(NotFoundException nfe) {
       this.nfe = nfe;
-      this.__isset.nfe = (nfe != null);
     }
 
     public void unsetNfe() {
       this.nfe = null;
-      this.__isset.nfe = false;
     }
 
     // Returns true if field nfe is set (has been asigned a value) and false otherwise
     public boolean isSetNfe() {
-      return this.__isset.nfe;
+      return this.nfe != null;
     }
 
     public void setNfeIsSet(boolean value) {
-      this.__isset.nfe = value;
-    }
-
-    public CassandraException getCe() {
-      return this.ce;
-    }
-
-    public void setCe(CassandraException ce) {
-      this.ce = ce;
-      this.__isset.ce = (ce != null);
-    }
-
-    public void unsetCe() {
-      this.ce = null;
-      this.__isset.ce = false;
-    }
-
-    // Returns true if field ce is set (has been asigned a value) and false otherwise
-    public boolean isSetCe() {
-      return this.__isset.ce;
-    }
-
-    public void setCeIsSet(boolean value) {
-      this.__isset.ce = value;
+      if (!value) {
+        this.nfe = null;
+      }
     }
 
     public void setFieldValue(int fieldID, Object value) {
       switch (fieldID) {
       case SUCCESS:
-        setSuccess((List<column_t>)value);
+        if (value == null) {
+          unsetSuccess();
+        } else {
+          setSuccess((List<column_t>)value);
+        }
         break;
 
       case IRE:
-        setIre((InvalidRequestException)value);
+        if (value == null) {
+          unsetIre();
+        } else {
+          setIre((InvalidRequestException)value);
+        }
         break;
 
       case NFE:
-        setNfe((NotFoundException)value);
-        break;
-
-      case CE:
-        setCe((CassandraException)value);
+        if (value == null) {
+          unsetNfe();
+        } else {
+          setNfe((NotFoundException)value);
+        }
         break;
 
       default:
@@ -1898,9 +1954,6 @@
       case NFE:
         return getNfe();
 
-      case CE:
-        return getCe();
-
       default:
         throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
       }
@@ -1910,13 +1963,11 @@
     public boolean isSet(int fieldID) {
       switch (fieldID) {
       case SUCCESS:
-        return this.__isset.success;
+        return isSetSuccess();
       case IRE:
-        return this.__isset.ire;
+        return isSetIre();
       case NFE:
-        return this.__isset.nfe;
-      case CE:
-        return this.__isset.ce;
+        return isSetNfe();
       default:
         throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
       }
@@ -1935,8 +1986,8 @@
       if (that == null)
         return false;
 
-      boolean this_present_success = true && (this.success != null);
-      boolean that_present_success = true && (that.success != null);
+      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;
@@ -1944,8 +1995,8 @@
           return false;
       }
 
-      boolean this_present_ire = true && (this.ire != null);
-      boolean that_present_ire = true && (that.ire != null);
+      boolean this_present_ire = true && this.isSetIre();
+      boolean that_present_ire = true && that.isSetIre();
       if (this_present_ire || that_present_ire) {
         if (!(this_present_ire && that_present_ire))
           return false;
@@ -1953,8 +2004,8 @@
           return false;
       }
 
-      boolean this_present_nfe = true && (this.nfe != null);
-      boolean that_present_nfe = true && (that.nfe != null);
+      boolean this_present_nfe = true && this.isSetNfe();
+      boolean that_present_nfe = true && that.isSetNfe();
       if (this_present_nfe || that_present_nfe) {
         if (!(this_present_nfe && that_present_nfe))
           return false;
@@ -1962,15 +2013,6 @@
           return false;
       }
 
-      boolean this_present_ce = true && (this.ce != null);
-      boolean that_present_ce = true && (that.ce != null);
-      if (this_present_ce || that_present_ce) {
-        if (!(this_present_ce && that_present_ce))
-          return false;
-        if (!this.ce.equals(that.ce))
-          return false;
-      }
-
       return true;
     }
 
@@ -2004,7 +2046,6 @@
                 }
                 iprot.readListEnd();
               }
-              this.__isset.success = true;
             } else { 
               TProtocolUtil.skip(iprot, field.type);
             }
@@ -2013,7 +2054,6 @@
             if (field.type == TType.STRUCT) {
               this.ire = new InvalidRequestException();
               this.ire.read(iprot);
-              this.__isset.ire = true;
             } else { 
               TProtocolUtil.skip(iprot, field.type);
             }
@@ -2022,16 +2062,6 @@
             if (field.type == TType.STRUCT) {
               this.nfe = new NotFoundException();
               this.nfe.read(iprot);
-              this.__isset.nfe = true;
-            } else { 
-              TProtocolUtil.skip(iprot, field.type);
-            }
-            break;
-          case CE:
-            if (field.type == TType.STRUCT) {
-              this.ce = new CassandraException();
-              this.ce.read(iprot);
-              this.__isset.ce = true;
             } else { 
               TProtocolUtil.skip(iprot, field.type);
             }
@@ -2052,36 +2082,24 @@
     public void write(TProtocol oprot) throws TException {
       oprot.writeStructBegin(STRUCT_DESC);
 
-      if (this.__isset.success) {
-        if (this.success != null) {
-          oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
-          {
-            oprot.writeListBegin(new TList(TType.STRUCT, this.success.size()));
-            for (column_t _iter34 : this.success)            {
-              _iter34.write(oprot);
-            }
-            oprot.writeListEnd();
+      if (this.isSetSuccess()) {
+        oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+        {
+          oprot.writeListBegin(new TList(TType.STRUCT, this.success.size()));
+          for (column_t _iter34 : this.success)          {
+            _iter34.write(oprot);
           }
-          oprot.writeFieldEnd();
-        }
-      } else if (this.__isset.ire) {
-        if (this.ire != null) {
-          oprot.writeFieldBegin(IRE_FIELD_DESC);
-          this.ire.write(oprot);
-          oprot.writeFieldEnd();
-        }
-      } else if (this.__isset.nfe) {
-        if (this.nfe != null) {
-          oprot.writeFieldBegin(NFE_FIELD_DESC);
-          this.nfe.write(oprot);
-          oprot.writeFieldEnd();
-        }
-      } else if (this.__isset.ce) {
-        if (this.ce != null) {
-          oprot.writeFieldBegin(CE_FIELD_DESC);
-          this.ce.write(oprot);
-          oprot.writeFieldEnd();
+          oprot.writeListEnd();
         }
+        oprot.writeFieldEnd();
+      } else if (this.isSetIre()) {
+        oprot.writeFieldBegin(IRE_FIELD_DESC);
+        this.ire.write(oprot);
+        oprot.writeFieldEnd();
+      } else if (this.isSetNfe()) {
+        oprot.writeFieldBegin(NFE_FIELD_DESC);
+        this.nfe.write(oprot);
+        oprot.writeFieldEnd();
       }
       oprot.writeFieldStop();
       oprot.writeStructEnd();
@@ -2092,21 +2110,28 @@
       StringBuilder sb = new StringBuilder("get_slice_result(");
       boolean first = true;
 
-      if (!first) sb.append(", ");
       sb.append("success:");
-      sb.append(this.success);
+      if (this.success == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.success);
+      }
       first = false;
       if (!first) sb.append(", ");
       sb.append("ire:");
-      sb.append(this.ire);
+      if (this.ire == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.ire);
+      }
       first = false;
       if (!first) sb.append(", ");
       sb.append("nfe:");
-      sb.append(this.nfe);
-      first = false;
-      if (!first) sb.append(", ");
-      sb.append("ce:");
-      sb.append(this.ce);
+      if (this.nfe == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.nfe);
+      }
       first = false;
       sb.append(")");
       return sb.toString();
@@ -2121,26 +2146,22 @@
 
   public static class get_slice_by_names_args implements TBase, java.io.Serializable, Cloneable   {
     private static final TStruct STRUCT_DESC = new TStruct("get_slice_by_names_args");
-    private static final TField TABLENAME_FIELD_DESC = new TField("tablename", TType.STRING, (short)-1);
-    private static final TField KEY_FIELD_DESC = new TField("key", TType.STRING, (short)-2);
-    private static final TField COLUMN_FAMILY_FIELD_DESC = new TField("columnFamily", TType.STRING, (short)-3);
-    private static final TField COLUMN_NAMES_FIELD_DESC = new TField("columnNames", TType.LIST, (short)-4);
+    private static final TField TABLENAME_FIELD_DESC = new TField("tablename", TType.STRING, (short)1);
+    private static final TField KEY_FIELD_DESC = new TField("key", TType.STRING, (short)2);
+    private static final TField COLUMN_FAMILY_FIELD_DESC = new TField("columnFamily", TType.STRING, (short)3);
+    private static final TField COLUMN_NAMES_FIELD_DESC = new TField("columnNames", TType.LIST, (short)4);
 
     public String tablename;
-    public static final int TABLENAME = -1;
+    public static final int TABLENAME = 1;
     public String key;
-    public static final int KEY = -2;
+    public static final int KEY = 2;
     public String columnFamily;
-    public static final int COLUMNFAMILY = -3;
+    public static final int COLUMNFAMILY = 3;
     public List<String> columnNames;
-    public static final int COLUMNNAMES = -4;
+    public static final int COLUMNNAMES = 4;
 
     private final Isset __isset = new Isset();
     private static final class Isset implements java.io.Serializable {
-      public boolean tablename = false;
-      public boolean key = false;
-      public boolean columnFamily = false;
-      public boolean columnNames = false;
     }
 
     public static final Map<Integer, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new HashMap<Integer, FieldMetaData>() {{
@@ -2170,33 +2191,25 @@
     {
       this();
       this.tablename = tablename;
-      this.__isset.tablename = (tablename != null);
       this.key = key;
-      this.__isset.key = (key != null);
       this.columnFamily = columnFamily;
-      this.__isset.columnFamily = (columnFamily != null);
       this.columnNames = columnNames;
-      this.__isset.columnNames = (columnNames != null);
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
     public get_slice_by_names_args(get_slice_by_names_args other) {
-      __isset.tablename = other.__isset.tablename;
-      if (other.tablename != null) {
+      if (other.isSetTablename()) {
         this.tablename = other.tablename;
       }
-      __isset.key = other.__isset.key;
-      if (other.key != null) {
+      if (other.isSetKey()) {
         this.key = other.key;
       }
-      __isset.columnFamily = other.__isset.columnFamily;
-      if (other.columnFamily != null) {
+      if (other.isSetColumnFamily()) {
         this.columnFamily = other.columnFamily;
       }
-      __isset.columnNames = other.__isset.columnNames;
-      if (other.columnNames != null) {
+      if (other.isSetColumnNames()) {
         List<String> __this__columnNames = new ArrayList<String>();
         for (String other_element : other.columnNames) {
           __this__columnNames.add(other_element);
@@ -2216,20 +2229,21 @@
 
     public void setTablename(String tablename) {
       this.tablename = tablename;
-      this.__isset.tablename = (tablename != null);
     }
 
     public void unsetTablename() {
-      this.__isset.tablename = false;
+      this.tablename = null;
     }
 
     // Returns true if field tablename is set (has been asigned a value) and false otherwise
     public boolean isSetTablename() {
-      return this.__isset.tablename;
+      return this.tablename != null;
     }
 
     public void setTablenameIsSet(boolean value) {
-      this.__isset.tablename = value;
+      if (!value) {
+        this.tablename = null;
+      }
     }
 
     public String getKey() {
@@ -2238,20 +2252,21 @@
 
     public void setKey(String key) {
       this.key = key;
-      this.__isset.key = (key != null);
     }
 
     public void unsetKey() {
-      this.__isset.key = false;
+      this.key = null;
     }
 
     // Returns true if field key is set (has been asigned a value) and false otherwise
     public boolean isSetKey() {
-      return this.__isset.key;
+      return this.key != null;
     }
 
     public void setKeyIsSet(boolean value) {
-      this.__isset.key = value;
+      if (!value) {
+        this.key = null;
+      }
     }
 
     public String getColumnFamily() {
@@ -2260,20 +2275,21 @@
 
     public void setColumnFamily(String columnFamily) {
       this.columnFamily = columnFamily;
-      this.__isset.columnFamily = (columnFamily != null);
     }
 
     public void unsetColumnFamily() {
-      this.__isset.columnFamily = false;
+      this.columnFamily = null;
     }
 
     // Returns true if field columnFamily is set (has been asigned a value) and false otherwise
     public boolean isSetColumnFamily() {
-      return this.__isset.columnFamily;
+      return this.columnFamily != null;
     }
 
     public void setColumnFamilyIsSet(boolean value) {
-      this.__isset.columnFamily = value;
+      if (!value) {
+        this.columnFamily = null;
+      }
     }
 
     public int getColumnNamesSize() {
@@ -2289,7 +2305,6 @@
         this.columnNames = new ArrayList<String>();
       }
       this.columnNames.add(elem);
-      this.__isset.columnNames = true;
     }
 
     public List<String> getColumnNames() {
@@ -2298,39 +2313,55 @@
 
     public void setColumnNames(List<String> columnNames) {
       this.columnNames = columnNames;
-      this.__isset.columnNames = (columnNames != null);
     }
 
     public void unsetColumnNames() {
       this.columnNames = null;
-      this.__isset.columnNames = false;
     }
 
     // Returns true if field columnNames is set (has been asigned a value) and false otherwise
     public boolean isSetColumnNames() {
-      return this.__isset.columnNames;
+      return this.columnNames != null;
     }
 
     public void setColumnNamesIsSet(boolean value) {
-      this.__isset.columnNames = value;
+      if (!value) {
+        this.columnNames = null;
+      }
     }
 
     public void setFieldValue(int fieldID, Object value) {
       switch (fieldID) {
       case TABLENAME:
-        setTablename((String)value);
+        if (value == null) {
+          unsetTablename();
+        } else {
+          setTablename((String)value);
+        }
         break;
 
       case KEY:
-        setKey((String)value);
+        if (value == null) {
+          unsetKey();
+        } else {
+          setKey((String)value);
+        }
         break;
 
       case COLUMNFAMILY:
-        setColumnFamily((String)value);
+        if (value == null) {
+          unsetColumnFamily();
+        } else {
+          setColumnFamily((String)value);
+        }
         break;
 
       case COLUMNNAMES:
-        setColumnNames((List<String>)value);
+        if (value == null) {
+          unsetColumnNames();
+        } else {
+          setColumnNames((List<String>)value);
+        }
         break;
 
       default:
@@ -2361,13 +2392,13 @@
     public boolean isSet(int fieldID) {
       switch (fieldID) {
       case TABLENAME:
-        return this.__isset.tablename;
+        return isSetTablename();
       case KEY:
-        return this.__isset.key;
+        return isSetKey();
       case COLUMNFAMILY:
-        return this.__isset.columnFamily;
+        return isSetColumnFamily();
       case COLUMNNAMES:
-        return this.__isset.columnNames;
+        return isSetColumnNames();
       default:
         throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
       }
@@ -2386,8 +2417,8 @@
       if (that == null)
         return false;
 
-      boolean this_present_tablename = true && (this.tablename != null);
-      boolean that_present_tablename = true && (that.tablename != null);
+      boolean this_present_tablename = true && this.isSetTablename();
+      boolean that_present_tablename = true && that.isSetTablename();
       if (this_present_tablename || that_present_tablename) {
         if (!(this_present_tablename && that_present_tablename))
           return false;
@@ -2395,8 +2426,8 @@
           return false;
       }
 
-      boolean this_present_key = true && (this.key != null);
-      boolean that_present_key = true && (that.key != null);
+      boolean this_present_key = true && this.isSetKey();
+      boolean that_present_key = true && that.isSetKey();
       if (this_present_key || that_present_key) {
         if (!(this_present_key && that_present_key))
           return false;
@@ -2404,8 +2435,8 @@
           return false;
       }
 
-      boolean this_present_columnFamily = true && (this.columnFamily != null);
-      boolean that_present_columnFamily = true && (that.columnFamily != null);
+      boolean this_present_columnFamily = true && this.isSetColumnFamily();
+      boolean that_present_columnFamily = true && that.isSetColumnFamily();
       if (this_present_columnFamily || that_present_columnFamily) {
         if (!(this_present_columnFamily && that_present_columnFamily))
           return false;
@@ -2413,8 +2444,8 @@
           return false;
       }
 
-      boolean this_present_columnNames = true && (this.columnNames != null);
-      boolean that_present_columnNames = true && (that.columnNames != null);
+      boolean this_present_columnNames = true && this.isSetColumnNames();
+      boolean that_present_columnNames = true && that.isSetColumnNames();
       if (this_present_columnNames || that_present_columnNames) {
         if (!(this_present_columnNames && that_present_columnNames))
           return false;
@@ -2444,7 +2475,6 @@
           case TABLENAME:
             if (field.type == TType.STRING) {
               this.tablename = iprot.readString();
-              this.__isset.tablename = true;
             } else { 
               TProtocolUtil.skip(iprot, field.type);
             }
@@ -2452,7 +2482,6 @@
           case KEY:
             if (field.type == TType.STRING) {
               this.key = iprot.readString();
-              this.__isset.key = true;
             } else { 
               TProtocolUtil.skip(iprot, field.type);
             }
@@ -2460,7 +2489,6 @@
           case COLUMNFAMILY:
             if (field.type == TType.STRING) {
               this.columnFamily = iprot.readString();
-              this.__isset.columnFamily = true;
             } else { 
               TProtocolUtil.skip(iprot, field.type);
             }
@@ -2478,7 +2506,6 @@
                 }
                 iprot.readListEnd();
               }
-              this.__isset.columnNames = true;
             } else { 
               TProtocolUtil.skip(iprot, field.type);
             }
@@ -2535,21 +2562,36 @@
       StringBuilder sb = new StringBuilder("get_slice_by_names_args(");
       boolean first = true;
 
-      if (!first) sb.append(", ");
       sb.append("tablename:");
-      sb.append(this.tablename);
+      if (this.tablename == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.tablename);
+      }
       first = false;
       if (!first) sb.append(", ");
       sb.append("key:");
-      sb.append(this.key);
+      if (this.key == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.key);
+      }
       first = false;
       if (!first) sb.append(", ");
       sb.append("columnFamily:");
-      sb.append(this.columnFamily);
+      if (this.columnFamily == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.columnFamily);
+      }
       first = false;
       if (!first) sb.append(", ");
       sb.append("columnNames:");
-      sb.append(this.columnNames);
+      if (this.columnNames == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.columnNames);
+      }
       first = false;
       sb.append(")");
       return sb.toString();
@@ -2567,7 +2609,6 @@
     private static final TField SUCCESS_FIELD_DESC = new TField("success", TType.LIST, (short)0);
     private static final TField IRE_FIELD_DESC = new TField("ire", TType.STRUCT, (short)1);
     private static final TField NFE_FIELD_DESC = new TField("nfe", TType.STRUCT, (short)2);
-    private static final TField CE_FIELD_DESC = new TField("ce", TType.STRUCT, (short)3);
 
     public List<column_t> success;
     public static final int SUCCESS = 0;
@@ -2575,15 +2616,9 @@
     public static final int IRE = 1;
     public NotFoundException nfe;
     public static final int NFE = 2;
-    public CassandraException ce;
-    public static final int CE = 3;
 
     private final Isset __isset = new Isset();
     private static final class Isset implements java.io.Serializable {
-      public boolean success = false;
-      public boolean ire = false;
-      public boolean nfe = false;
-      public boolean ce = false;
     }
 
     public static final Map<Integer, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new HashMap<Integer, FieldMetaData>() {{
@@ -2594,8 +2629,6 @@
           new FieldValueMetaData(TType.STRUCT)));
       put(NFE, new FieldMetaData("nfe", TFieldRequirementType.DEFAULT, 
           new FieldValueMetaData(TType.STRUCT)));
-      put(CE, new FieldMetaData("ce", TFieldRequirementType.DEFAULT, 
-          new FieldValueMetaData(TType.STRUCT)));
     }});
 
     static {
@@ -2608,44 +2641,31 @@
     public get_slice_by_names_result(
       List<column_t> success,
       InvalidRequestException ire,
-      NotFoundException nfe,
-      CassandraException ce)
+      NotFoundException nfe)
     {
       this();
       this.success = success;
-      this.__isset.success = (success != null);
       this.ire = ire;
-      this.__isset.ire = (ire != null);
       this.nfe = nfe;
-      this.__isset.nfe = (nfe != null);
-      this.ce = ce;
-      this.__isset.ce = (ce != null);
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
     public get_slice_by_names_result(get_slice_by_names_result other) {
-      __isset.success = other.__isset.success;
-      if (other.success != null) {
+      if (other.isSetSuccess()) {
         List<column_t> __this__success = new ArrayList<column_t>();
         for (column_t other_element : other.success) {
           __this__success.add(new column_t(other_element));
         }
         this.success = __this__success;
       }
-      __isset.ire = other.__isset.ire;
-      if (other.ire != null) {
+      if (other.isSetIre()) {
         this.ire = new InvalidRequestException(other.ire);
       }
-      __isset.nfe = other.__isset.nfe;
-      if (other.nfe != null) {
+      if (other.isSetNfe()) {
         this.nfe = new NotFoundException(other.nfe);
       }
-      __isset.ce = other.__isset.ce;
-      if (other.ce != null) {
-        this.ce = new CassandraException(other.ce);
-      }
     }
 
     @Override
@@ -2666,7 +2686,6 @@
         this.success = new ArrayList<column_t>();
       }
       this.success.add(elem);
-      this.__isset.success = true;
     }
 
     public List<column_t> getSuccess() {
@@ -2675,21 +2694,21 @@
 
     public void setSuccess(List<column_t> success) {
       this.success = success;
-      this.__isset.success = (success != null);
     }
 
     public void unsetSuccess() {
       this.success = null;
-      this.__isset.success = false;
     }
 
     // Returns true if field success is set (has been asigned a value) and false otherwise
     public boolean isSetSuccess() {
-      return this.__isset.success;
+      return this.success != null;
     }
 
     public void setSuccessIsSet(boolean value) {
-      this.__isset.success = value;
+      if (!value) {
+        this.success = null;
+      }
     }
 
     public InvalidRequestException getIre() {
@@ -2698,21 +2717,21 @@
 
     public void setIre(InvalidRequestException ire) {
       this.ire = ire;
-      this.__isset.ire = (ire != null);
     }
 
     public void unsetIre() {
       this.ire = null;
-      this.__isset.ire = false;
     }
 
     // Returns true if field ire is set (has been asigned a value) and false otherwise
     public boolean isSetIre() {
-      return this.__isset.ire;
+      return this.ire != null;
     }
 
     public void setIreIsSet(boolean value) {
-      this.__isset.ire = value;
+      if (!value) {
+        this.ire = null;
+      }
     }
 
     public NotFoundException getNfe() {
@@ -2721,62 +2740,47 @@
 
     public void setNfe(NotFoundException nfe) {
       this.nfe = nfe;
-      this.__isset.nfe = (nfe != null);
     }
 
     public void unsetNfe() {
       this.nfe = null;
-      this.__isset.nfe = false;
     }
 
     // Returns true if field nfe is set (has been asigned a value) and false otherwise
     public boolean isSetNfe() {
-      return this.__isset.nfe;
+      return this.nfe != null;
     }
 
     public void setNfeIsSet(boolean value) {
-      this.__isset.nfe = value;
-    }
-
-    public CassandraException getCe() {
-      return this.ce;
-    }
-
-    public void setCe(CassandraException ce) {
-      this.ce = ce;
-      this.__isset.ce = (ce != null);
-    }
-
-    public void unsetCe() {
-      this.ce = null;
-      this.__isset.ce = false;
-    }
-
-    // Returns true if field ce is set (has been asigned a value) and false otherwise
-    public boolean isSetCe() {
-      return this.__isset.ce;
-    }
-
-    public void setCeIsSet(boolean value) {
-      this.__isset.ce = value;
+      if (!value) {
+        this.nfe = null;
+      }
     }
 
     public void setFieldValue(int fieldID, Object value) {
       switch (fieldID) {
       case SUCCESS:
-        setSuccess((List<column_t>)value);
+        if (value == null) {
+          unsetSuccess();
+        } else {
+          setSuccess((List<column_t>)value);
+        }
         break;
 
       case IRE:
-        setIre((InvalidRequestException)value);
+        if (value == null) {
+          unsetIre();
+        } else {
+          setIre((InvalidRequestException)value);
+        }
         break;
 
       case NFE:
-        setNfe((NotFoundException)value);
-        break;
-
-      case CE:
-        setCe((CassandraException)value);
+        if (value == null) {
+          unsetNfe();
+        } else {
+          setNfe((NotFoundException)value);
+        }
         break;
 
       default:
@@ -2795,9 +2799,6 @@
       case NFE:
         return getNfe();
 
-      case CE:
-        return getCe();
-
       default:
         throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
       }
@@ -2807,13 +2808,11 @@
     public boolean isSet(int fieldID) {
       switch (fieldID) {
       case SUCCESS:
-        return this.__isset.success;
+        return isSetSuccess();
       case IRE:
-        return this.__isset.ire;
+        return isSetIre();
       case NFE:
-        return this.__isset.nfe;
-      case CE:
-        return this.__isset.ce;
+        return isSetNfe();
       default:
         throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
       }
@@ -2832,8 +2831,8 @@
       if (that == null)
         return false;
 
-      boolean this_present_success = true && (this.success != null);
-      boolean that_present_success = true && (that.success != null);
+      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;
@@ -2841,8 +2840,8 @@
           return false;
       }
 
-      boolean this_present_ire = true && (this.ire != null);
-      boolean that_present_ire = true && (that.ire != null);
+      boolean this_present_ire = true && this.isSetIre();
+      boolean that_present_ire = true && that.isSetIre();
       if (this_present_ire || that_present_ire) {
         if (!(this_present_ire && that_present_ire))
           return false;
@@ -2850,8 +2849,8 @@
           return false;
       }
 
-      boolean this_present_nfe = true && (this.nfe != null);
-      boolean that_present_nfe = true && (that.nfe != null);
+      boolean this_present_nfe = true && this.isSetNfe();
+      boolean that_present_nfe = true && that.isSetNfe();
       if (this_present_nfe || that_present_nfe) {
         if (!(this_present_nfe && that_present_nfe))
           return false;
@@ -2859,15 +2858,6 @@
           return false;
       }
 
-      boolean this_present_ce = true && (this.ce != null);
-      boolean that_present_ce = true && (that.ce != null);
-      if (this_present_ce || that_present_ce) {
-        if (!(this_present_ce && that_present_ce))
-          return false;
-        if (!this.ce.equals(that.ce))
-          return false;
-      }
-
       return true;
     }
 
@@ -2901,7 +2891,6 @@
                 }
                 iprot.readListEnd();
               }
-              this.__isset.success = true;
             } else { 
               TProtocolUtil.skip(iprot, field.type);
             }
@@ -2910,7 +2899,6 @@
             if (field.type == TType.STRUCT) {
               this.ire = new InvalidRequestException();
               this.ire.read(iprot);
-              this.__isset.ire = true;
             } else { 
               TProtocolUtil.skip(iprot, field.type);
             }
@@ -2919,16 +2907,6 @@
             if (field.type == TType.STRUCT) {
               this.nfe = new NotFoundException();
               this.nfe.read(iprot);
-              this.__isset.nfe = true;
-            } else { 
-              TProtocolUtil.skip(iprot, field.type);
-            }
-            break;
-          case CE:
-            if (field.type == TType.STRUCT) {
-              this.ce = new CassandraException();
-              this.ce.read(iprot);
-              this.__isset.ce = true;
             } else { 
               TProtocolUtil.skip(iprot, field.type);
             }
@@ -2949,36 +2927,24 @@
     public void write(TProtocol oprot) throws TException {
       oprot.writeStructBegin(STRUCT_DESC);
 
-      if (this.__isset.success) {
-        if (this.success != null) {
-          oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
-          {
-            oprot.writeListBegin(new TList(TType.STRUCT, this.success.size()));
-            for (column_t _iter42 : this.success)            {
-              _iter42.write(oprot);
-            }
-            oprot.writeListEnd();
+      if (this.isSetSuccess()) {
+        oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+        {
+          oprot.writeListBegin(new TList(TType.STRUCT, this.success.size()));
+          for (column_t _iter42 : this.success)          {
+            _iter42.write(oprot);
           }
-          oprot.writeFieldEnd();
-        }
-      } else if (this.__isset.ire) {
-        if (this.ire != null) {
-          oprot.writeFieldBegin(IRE_FIELD_DESC);
-          this.ire.write(oprot);
-          oprot.writeFieldEnd();
-        }
-      } else if (this.__isset.nfe) {
-        if (this.nfe != null) {
-          oprot.writeFieldBegin(NFE_FIELD_DESC);
-          this.nfe.write(oprot);
-          oprot.writeFieldEnd();
-        }
-      } else if (this.__isset.ce) {
-        if (this.ce != null) {
-          oprot.writeFieldBegin(CE_FIELD_DESC);
-          this.ce.write(oprot);
-          oprot.writeFieldEnd();
+          oprot.writeListEnd();
         }
+        oprot.writeFieldEnd();
+      } else if (this.isSetIre()) {
+        oprot.writeFieldBegin(IRE_FIELD_DESC);
+        this.ire.write(oprot);
+        oprot.writeFieldEnd();
+      } else if (this.isSetNfe()) {
+        oprot.writeFieldBegin(NFE_FIELD_DESC);
+        this.nfe.write(oprot);
+        oprot.writeFieldEnd();
       }
       oprot.writeFieldStop();
       oprot.writeStructEnd();
@@ -2989,21 +2955,28 @@
       StringBuilder sb = new StringBuilder("get_slice_by_names_result(");
       boolean first = true;
 
-      if (!first) sb.append(", ");
       sb.append("success:");
-      sb.append(this.success);
+      if (this.success == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.success);
+      }
       first = false;
       if (!first) sb.append(", ");
       sb.append("ire:");
-      sb.append(this.ire);
+      if (this.ire == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.ire);
+      }
       first = false;
       if (!first) sb.append(", ");
       sb.append("nfe:");
-      sb.append(this.nfe);
-      first = false;
-      if (!first) sb.append(", ");
-      sb.append("ce:");
-      sb.append(this.ce);
+      if (this.nfe == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.nfe);
+      }
       first = false;
       sb.append(")");
       return sb.toString();
@@ -3018,22 +2991,19 @@
 
   public static class get_column_args implements TBase, java.io.Serializable, Cloneable   {
     private static final TStruct STRUCT_DESC = new TStruct("get_column_args");
-    private static final TField TABLENAME_FIELD_DESC = new TField("tablename", TType.STRING, (short)-1);
-    private static final TField KEY_FIELD_DESC = new TField("key", TType.STRING, (short)-2);
-    private static final TField COLUMN_FAMILY_COLUMN_FIELD_DESC = new TField("columnFamily_column", TType.STRING, (short)-3);
+    private static final TField TABLENAME_FIELD_DESC = new TField("tablename", TType.STRING, (short)1);
+    private static final TField KEY_FIELD_DESC = new TField("key", TType.STRING, (short)2);
+    private static final TField COLUMN_FAMILY_COLUMN_FIELD_DESC = new TField("columnFamily_column", TType.STRING, (short)3);
 
     public String tablename;
-    public static final int TABLENAME = -1;
+    public static final int TABLENAME = 1;
     public String key;
-    public static final int KEY = -2;
+    public static final int KEY = 2;
     public String columnFamily_column;
-    public static final int COLUMNFAMILY_COLUMN = -3;
+    public static final int COLUMNFAMILY_COLUMN = 3;
 
     private final Isset __isset = new Isset();
     private static final class Isset implements java.io.Serializable {
-      public boolean tablename = false;
-      public boolean key = false;
-      public boolean columnFamily_column = false;
     }
 
     public static final Map<Integer, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new HashMap<Integer, FieldMetaData>() {{
@@ -3059,27 +3029,21 @@
     {
       this();
       this.tablename = tablename;
-      this.__isset.tablename = (tablename != null);
       this.key = key;
-      this.__isset.key = (key != null);
       this.columnFamily_column = columnFamily_column;
-      this.__isset.columnFamily_column = (columnFamily_column != null);
     }
 
     /**
      * Performs a deep copy on <i>other</i>.
      */
     public get_column_args(get_column_args other) {
-      __isset.tablename = other.__isset.tablename;
-      if (other.tablename != null) {
+      if (other.isSetTablename()) {
         this.tablename = other.tablename;
       }
-      __isset.key = other.__isset.key;
-      if (other.key != null) {
+      if (other.isSetKey()) {
         this.key = other.key;
       }
-      __isset.columnFamily_column = other.__isset.columnFamily_column;
-      if (other.columnFamily_column != null) {
+      if (other.isSetColumnFamily_column()) {
         this.columnFamily_column = other.columnFamily_column;
       }
     }
@@ -3095,20 +3059,21 @@
 
     public void setTablename(String tablename) {
       this.tablename = tablename;
-      this.__isset.tablename = (tablename != null);
     }
 
     public void unsetTablename() {
-      this.__isset.tablename = false;
+      this.tablename = null;
     }
 
     // Returns true if field tablename is set (has been asigned a value) and false otherwise
     public boolean isSetTablename() {
-      return this.__isset.tablename;
+      return this.tablename != null;
     }
 
     public void setTablenameIsSet(boolean value) {
-      this.__isset.tablename = value;
+      if (!value) {
+        this.tablename = null;
+      }
     }
 
     public String getKey() {
@@ -3117,20 +3082,21 @@
 
     public void setKey(String key) {
       this.key = key;
-      this.__isset.key = (key != null);
     }
 
     public void unsetKey() {
-      this.__isset.key = false;
+      this.key = null;
     }
 
     // Returns true if field key is set (has been asigned a value) and false otherwise
     public boolean isSetKey() {
-      return this.__isset.key;
+      return this.key != null;
     }
 
     public void setKeyIsSet(boolean value) {
-      this.__isset.key = value;
+      if (!value) {
+        this.key = null;
+      }
     }
 
     public String getColumnFamily_column() {
@@ -3139,34 +3105,47 @@
 
     public void setColumnFamily_column(String columnFamily_column) {
       this.columnFamily_column = columnFamily_column;
-      this.__isset.columnFamily_column = (columnFamily_column != null);
     }
 
     public void unsetColumnFamily_column() {
-      this.__isset.columnFamily_column = false;
+      this.columnFamily_column = null;
     }
 
     // Returns true if field columnFamily_column is set (has been asigned a value) and false otherwise
     public boolean isSetColumnFamily_column() {
-      return this.__isset.columnFamily_column;
+      return this.columnFamily_column != null;
     }
 
     public void setColumnFamily_columnIsSet(boolean value) {
-      this.__isset.columnFamily_column = value;
+      if (!value) {
+        this.columnFamily_column = null;
+      }
     }
 
     public void setFieldValue(int fieldID, Object value) {
       switch (fieldID) {
       case TABLENAME:
-        setTablename((String)value);
+        if (value == null) {
+          unsetTablename();
+        } else {
+          setTablename((String)value);
+        }
         break;
 
       case KEY:
-        setKey((String)value);
+        if (value == null) {
+          unsetKey();
+        } else {
+          setKey((String)value);
+        }
         break;
 
       case COLUMNFAMILY_COLUMN:
-        setColumnFamily_column((String)value);
+        if (value == null) {
+          unsetColumnFamily_column();
+        } else {
+          setColumnFamily_column((String)value);
+        }
         break;
 
       default:
@@ -3194,11 +3173,11 @@
     public boolean isSet(int fieldID) {
       switch (fieldID) {
       case TABLENAME:
-        return this.__isset.tablename;
+        return isSetTablename();
       case KEY:

[... 7170 lines stripped ...]


Mime
View raw message