cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pma...@apache.org
Subject svn commit: r749218 [26/34] - in /incubator/cassandra: branches/ dist/ nightly/ site/ tags/ trunk/ trunk/lib/ trunk/src/ trunk/src/org/ trunk/src/org/apache/ trunk/src/org/apache/cassandra/ trunk/src/org/apache/cassandra/analytics/ trunk/src/org/apache...
Date Mon, 02 Mar 2009 07:57:31 GMT
Added: 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=749218&view=auto
==============================================================================
--- incubator/cassandra/trunk/src/org/apache/cassandra/service/Cassandra.java (added)
+++ incubator/cassandra/trunk/src/org/apache/cassandra/service/Cassandra.java Mon Mar  2 07:57:22 2009
@@ -0,0 +1,5866 @@
+/**
+ * Autogenerated by Thrift
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ */
+package org.apache.cassandra.service;
+
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.Set;
+import java.util.HashSet;
+import com.facebook.thrift.*;
+
+import com.facebook.thrift.protocol.*;
+import com.facebook.thrift.transport.*;
+
+public class Cassandra {
+
+  public interface Iface extends com.facebook.fb303.FacebookService.Iface {
+
+    public List<column_t> get_slice(String tablename, String key, String columnFamily_column, int start, int count) throws CassandraException, TException;
+
+    public List<column_t> get_slice_by_names(String tablename, String key, String columnFamily, List<String> columnNames) throws CassandraException, TException;
+
+    public column_t get_column(String tablename, String key, String columnFamily_column) throws CassandraException, TException;
+
+    public int get_column_count(String tablename, String key, String columnFamily_column) throws CassandraException, TException;
+
+    public void insert(String tablename, String key, String columnFamily_column, String cellData, long timestamp) throws TException;
+
+    public void batch_insert(batch_mutation_t batchMutation) throws TException;
+
+    public boolean batch_insert_blocking(batch_mutation_t batchMutation) throws CassandraException, TException;
+
+    public void remove(String tablename, String key, String columnFamily_column) throws TException;
+
+    public List<column_t> get_columns_since(String tablename, String key, String columnFamily_column, long timeStamp) throws CassandraException, TException;
+
+    public List<superColumn_t> get_slice_super(String tablename, String key, String columnFamily_superColumnName, int start, int count) throws CassandraException, TException;
+
+    public List<superColumn_t> get_slice_super_by_names(String tablename, String key, String columnFamily, List<String> superColumnNames) throws CassandraException, TException;
+
+    public superColumn_t get_superColumn(String tablename, String key, String columnFamily) throws CassandraException, TException;
+
+    public void batch_insert_superColumn(batch_mutation_super_t batchMutationSuper) throws TException;
+
+    public boolean batch_insert_superColumn_blocking(batch_mutation_super_t batchMutationSuper) throws CassandraException, TException;
+
+    public void touch(String key, boolean fData) throws TException;
+
+    public String getStringProperty(String propertyName) throws TException;
+
+    public List<String> getStringListProperty(String propertyName) throws TException;
+
+    public String describeTable(String tableName) throws TException;
+
+    public CqlResult_t executeQuery(String query) throws TException;
+
+  }
+
+  public static class Client extends com.facebook.fb303.FacebookService.Client implements Iface {
+    public Client(TProtocol prot)
+    {
+      this(prot, prot);
+    }
+
+    public Client(TProtocol iprot, TProtocol oprot)
+    {
+      super(iprot, oprot);
+    }
+
+    public List<column_t> get_slice(String tablename, String key, String columnFamily_column, int start, int count) throws CassandraException, TException
+    {
+      send_get_slice(tablename, key, columnFamily_column, start, count);
+      return recv_get_slice();
+    }
+
+    public void send_get_slice(String tablename, String key, String columnFamily_column, int start, int count) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_slice", TMessageType.CALL, seqid_));
+      get_slice_args args = new get_slice_args();
+      args.tablename = tablename;
+      args.key = key;
+      args.columnFamily_column = columnFamily_column;
+      args.start = start;
+      args.count = count;
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<column_t> recv_get_slice() throws CassandraException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      get_slice_result result = new get_slice_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.__isset.success) {
+        return result.success;
+      }
+      if (result.__isset.e) {
+        throw result.e;
+      }
+      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 CassandraException, TException
+    {
+      send_get_slice_by_names(tablename, key, columnFamily, columnNames);
+      return recv_get_slice_by_names();
+    }
+
+    public void send_get_slice_by_names(String tablename, String key, String columnFamily, List<String> columnNames) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_slice_by_names", TMessageType.CALL, seqid_));
+      get_slice_by_names_args args = new get_slice_by_names_args();
+      args.tablename = tablename;
+      args.key = key;
+      args.columnFamily = columnFamily;
+      args.columnNames = columnNames;
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<column_t> recv_get_slice_by_names() throws CassandraException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      get_slice_by_names_result result = new get_slice_by_names_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.__isset.success) {
+        return result.success;
+      }
+      if (result.__isset.e) {
+        throw result.e;
+      }
+      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 CassandraException, TException
+    {
+      send_get_column(tablename, key, columnFamily_column);
+      return recv_get_column();
+    }
+
+    public void send_get_column(String tablename, String key, String columnFamily_column) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_column", TMessageType.CALL, seqid_));
+      get_column_args args = new get_column_args();
+      args.tablename = tablename;
+      args.key = key;
+      args.columnFamily_column = columnFamily_column;
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public column_t recv_get_column() throws CassandraException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      get_column_result result = new get_column_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.__isset.success) {
+        return result.success;
+      }
+      if (result.__isset.e) {
+        throw result.e;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_column failed: unknown result");
+    }
+
+    public int get_column_count(String tablename, String key, String columnFamily_column) throws CassandraException, TException
+    {
+      send_get_column_count(tablename, key, columnFamily_column);
+      return recv_get_column_count();
+    }
+
+    public void send_get_column_count(String tablename, String key, String columnFamily_column) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_column_count", TMessageType.CALL, seqid_));
+      get_column_count_args args = new get_column_count_args();
+      args.tablename = tablename;
+      args.key = key;
+      args.columnFamily_column = columnFamily_column;
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public int recv_get_column_count() throws CassandraException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      get_column_count_result result = new get_column_count_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.__isset.success) {
+        return result.success;
+      }
+      if (result.__isset.e) {
+        throw result.e;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_column_count failed: unknown result");
+    }
+
+    public void insert(String tablename, String key, String columnFamily_column, String cellData, long timestamp) throws TException
+    {
+      send_insert(tablename, key, columnFamily_column, cellData, timestamp);
+    }
+
+    public void send_insert(String tablename, String key, String columnFamily_column, String cellData, long timestamp) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("insert", TMessageType.CALL, seqid_));
+      insert_args args = new insert_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 void batch_insert(batch_mutation_t batchMutation) throws TException
+    {
+      send_batch_insert(batchMutation);
+    }
+
+    public void send_batch_insert(batch_mutation_t batchMutation) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("batch_insert", TMessageType.CALL, seqid_));
+      batch_insert_args args = new batch_insert_args();
+      args.batchMutation = batchMutation;
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public boolean batch_insert_blocking(batch_mutation_t batchMutation) throws CassandraException, TException
+    {
+      send_batch_insert_blocking(batchMutation);
+      return recv_batch_insert_blocking();
+    }
+
+    public void send_batch_insert_blocking(batch_mutation_t batchMutation) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("batch_insert_blocking", TMessageType.CALL, seqid_));
+      batch_insert_blocking_args args = new batch_insert_blocking_args();
+      args.batchMutation = batchMutation;
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public boolean recv_batch_insert_blocking() throws CassandraException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      batch_insert_blocking_result result = new batch_insert_blocking_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.__isset.success) {
+        return result.success;
+      }
+      if (result.__isset.e) {
+        throw result.e;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "batch_insert_blocking failed: unknown result");
+    }
+
+    public void remove(String tablename, String key, String columnFamily_column) throws TException
+    {
+      send_remove(tablename, key, columnFamily_column);
+    }
+
+    public void send_remove(String tablename, String key, String columnFamily_column) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("remove", TMessageType.CALL, seqid_));
+      remove_args args = new remove_args();
+      args.tablename = tablename;
+      args.key = key;
+      args.columnFamily_column = columnFamily_column;
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<column_t> get_columns_since(String tablename, String key, String columnFamily_column, long timeStamp) throws CassandraException, TException
+    {
+      send_get_columns_since(tablename, key, columnFamily_column, timeStamp);
+      return recv_get_columns_since();
+    }
+
+    public void send_get_columns_since(String tablename, String key, String columnFamily_column, long timeStamp) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_columns_since", TMessageType.CALL, seqid_));
+      get_columns_since_args args = new get_columns_since_args();
+      args.tablename = tablename;
+      args.key = key;
+      args.columnFamily_column = columnFamily_column;
+      args.timeStamp = timeStamp;
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<column_t> recv_get_columns_since() throws CassandraException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      get_columns_since_result result = new get_columns_since_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.__isset.success) {
+        return result.success;
+      }
+      if (result.__isset.e) {
+        throw result.e;
+      }
+      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 CassandraException, TException
+    {
+      send_get_slice_super(tablename, key, columnFamily_superColumnName, start, count);
+      return recv_get_slice_super();
+    }
+
+    public void send_get_slice_super(String tablename, String key, String columnFamily_superColumnName, int start, int count) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_slice_super", TMessageType.CALL, seqid_));
+      get_slice_super_args args = new get_slice_super_args();
+      args.tablename = tablename;
+      args.key = key;
+      args.columnFamily_superColumnName = columnFamily_superColumnName;
+      args.start = start;
+      args.count = count;
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<superColumn_t> recv_get_slice_super() throws CassandraException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      get_slice_super_result result = new get_slice_super_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.__isset.success) {
+        return result.success;
+      }
+      if (result.__isset.e) {
+        throw result.e;
+      }
+      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 CassandraException, TException
+    {
+      send_get_slice_super_by_names(tablename, key, columnFamily, superColumnNames);
+      return recv_get_slice_super_by_names();
+    }
+
+    public void send_get_slice_super_by_names(String tablename, String key, String columnFamily, List<String> superColumnNames) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_slice_super_by_names", TMessageType.CALL, seqid_));
+      get_slice_super_by_names_args args = new get_slice_super_by_names_args();
+      args.tablename = tablename;
+      args.key = key;
+      args.columnFamily = columnFamily;
+      args.superColumnNames = superColumnNames;
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<superColumn_t> recv_get_slice_super_by_names() throws CassandraException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      get_slice_super_by_names_result result = new get_slice_super_by_names_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.__isset.success) {
+        return result.success;
+      }
+      if (result.__isset.e) {
+        throw result.e;
+      }
+      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 CassandraException, TException
+    {
+      send_get_superColumn(tablename, key, columnFamily);
+      return recv_get_superColumn();
+    }
+
+    public void send_get_superColumn(String tablename, String key, String columnFamily) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("get_superColumn", TMessageType.CALL, seqid_));
+      get_superColumn_args args = new get_superColumn_args();
+      args.tablename = tablename;
+      args.key = key;
+      args.columnFamily = columnFamily;
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public superColumn_t recv_get_superColumn() throws CassandraException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      get_superColumn_result result = new get_superColumn_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.__isset.success) {
+        return result.success;
+      }
+      if (result.__isset.e) {
+        throw result.e;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_superColumn failed: unknown result");
+    }
+
+    public void batch_insert_superColumn(batch_mutation_super_t batchMutationSuper) throws TException
+    {
+      send_batch_insert_superColumn(batchMutationSuper);
+    }
+
+    public void send_batch_insert_superColumn(batch_mutation_super_t batchMutationSuper) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("batch_insert_superColumn", TMessageType.CALL, seqid_));
+      batch_insert_superColumn_args args = new batch_insert_superColumn_args();
+      args.batchMutationSuper = batchMutationSuper;
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public boolean batch_insert_superColumn_blocking(batch_mutation_super_t batchMutationSuper) throws CassandraException, TException
+    {
+      send_batch_insert_superColumn_blocking(batchMutationSuper);
+      return recv_batch_insert_superColumn_blocking();
+    }
+
+    public void send_batch_insert_superColumn_blocking(batch_mutation_super_t batchMutationSuper) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("batch_insert_superColumn_blocking", TMessageType.CALL, seqid_));
+      batch_insert_superColumn_blocking_args args = new batch_insert_superColumn_blocking_args();
+      args.batchMutationSuper = batchMutationSuper;
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public boolean recv_batch_insert_superColumn_blocking() throws CassandraException, TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      batch_insert_superColumn_blocking_result result = new batch_insert_superColumn_blocking_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.__isset.success) {
+        return result.success;
+      }
+      if (result.__isset.e) {
+        throw result.e;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "batch_insert_superColumn_blocking failed: unknown result");
+    }
+
+    public void touch(String key, boolean fData) throws TException
+    {
+      send_touch(key, fData);
+    }
+
+    public void send_touch(String key, boolean fData) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("touch", TMessageType.CALL, seqid_));
+      touch_args args = new touch_args();
+      args.key = key;
+      args.fData = fData;
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public String getStringProperty(String propertyName) throws TException
+    {
+      send_getStringProperty(propertyName);
+      return recv_getStringProperty();
+    }
+
+    public void send_getStringProperty(String propertyName) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("getStringProperty", TMessageType.CALL, seqid_));
+      getStringProperty_args args = new getStringProperty_args();
+      args.propertyName = propertyName;
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public String recv_getStringProperty() throws TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      getStringProperty_result result = new getStringProperty_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.__isset.success) {
+        return result.success;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "getStringProperty failed: unknown result");
+    }
+
+    public List<String> getStringListProperty(String propertyName) throws TException
+    {
+      send_getStringListProperty(propertyName);
+      return recv_getStringListProperty();
+    }
+
+    public void send_getStringListProperty(String propertyName) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("getStringListProperty", TMessageType.CALL, seqid_));
+      getStringListProperty_args args = new getStringListProperty_args();
+      args.propertyName = propertyName;
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public List<String> recv_getStringListProperty() throws TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      getStringListProperty_result result = new getStringListProperty_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.__isset.success) {
+        return result.success;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "getStringListProperty failed: unknown result");
+    }
+
+    public String describeTable(String tableName) throws TException
+    {
+      send_describeTable(tableName);
+      return recv_describeTable();
+    }
+
+    public void send_describeTable(String tableName) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("describeTable", TMessageType.CALL, seqid_));
+      describeTable_args args = new describeTable_args();
+      args.tableName = tableName;
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public String recv_describeTable() throws TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      describeTable_result result = new describeTable_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.__isset.success) {
+        return result.success;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "describeTable failed: unknown result");
+    }
+
+    public CqlResult_t executeQuery(String query) throws TException
+    {
+      send_executeQuery(query);
+      return recv_executeQuery();
+    }
+
+    public void send_executeQuery(String query) throws TException
+    {
+      oprot_.writeMessageBegin(new TMessage("executeQuery", TMessageType.CALL, seqid_));
+      executeQuery_args args = new executeQuery_args();
+      args.query = query;
+      args.write(oprot_);
+      oprot_.writeMessageEnd();
+      oprot_.getTransport().flush();
+    }
+
+    public CqlResult_t recv_executeQuery() throws TException
+    {
+      TMessage msg = iprot_.readMessageBegin();
+      if (msg.type == TMessageType.EXCEPTION) {
+        TApplicationException x = TApplicationException.read(iprot_);
+        iprot_.readMessageEnd();
+        throw x;
+      }
+      executeQuery_result result = new executeQuery_result();
+      result.read(iprot_);
+      iprot_.readMessageEnd();
+      if (result.__isset.success) {
+        return result.success;
+      }
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "executeQuery failed: unknown result");
+    }
+
+  }
+  public static class Processor extends com.facebook.fb303.FacebookService.Processor implements TProcessor {
+    public Processor(Iface iface)
+    {
+      super(iface);
+      iface_ = iface;
+      processMap_.put("get_slice", new get_slice());
+      processMap_.put("get_slice_by_names", new get_slice_by_names());
+      processMap_.put("get_column", new get_column());
+      processMap_.put("get_column_count", new get_column_count());
+      processMap_.put("insert", new insert());
+      processMap_.put("batch_insert", new batch_insert());
+      processMap_.put("batch_insert_blocking", new batch_insert_blocking());
+      processMap_.put("remove", new remove());
+      processMap_.put("get_columns_since", new get_columns_since());
+      processMap_.put("get_slice_super", new get_slice_super());
+      processMap_.put("get_slice_super_by_names", new get_slice_super_by_names());
+      processMap_.put("get_superColumn", new get_superColumn());
+      processMap_.put("batch_insert_superColumn", new batch_insert_superColumn());
+      processMap_.put("batch_insert_superColumn_blocking", new batch_insert_superColumn_blocking());
+      processMap_.put("touch", new touch());
+      processMap_.put("getStringProperty", new getStringProperty());
+      processMap_.put("getStringListProperty", new getStringListProperty());
+      processMap_.put("describeTable", new describeTable());
+      processMap_.put("executeQuery", new executeQuery());
+    }
+
+    private Iface iface_;
+
+    public boolean process(TProtocol iprot, TProtocol oprot) throws TException
+    {
+      TMessage msg = iprot.readMessageBegin();
+      ProcessFunction fn = processMap_.get(msg.name);
+      if (fn == null) {
+        TProtocolUtil.skip(iprot, TType.STRUCT);
+        iprot.readMessageEnd();
+        TApplicationException x = new TApplicationException(TApplicationException.UNKNOWN_METHOD, "Invalid method name: '"+msg.name+"'");
+        oprot.writeMessageBegin(new TMessage(msg.name, TMessageType.EXCEPTION, msg.seqid));
+        x.write(oprot);
+        oprot.writeMessageEnd();
+        oprot.getTransport().flush();
+        return true;
+      }
+      fn.process(msg.seqid, iprot, oprot);
+      return true;
+    }
+
+    private class get_slice implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        get_slice_args args = new get_slice_args();
+        args.read(iprot);
+        iprot.readMessageEnd();
+        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 (CassandraException e) {
+          result.e = e;
+          result.__isset.e = true;
+        }
+        oprot.writeMessageBegin(new TMessage("get_slice", TMessageType.REPLY, seqid));
+        result.write(oprot);
+        oprot.writeMessageEnd();
+        oprot.getTransport().flush();
+      }
+
+    }
+
+    private class get_slice_by_names implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        get_slice_by_names_args args = new get_slice_by_names_args();
+        args.read(iprot);
+        iprot.readMessageEnd();
+        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 (CassandraException e) {
+          result.e = e;
+          result.__isset.e = true;
+        }
+        oprot.writeMessageBegin(new TMessage("get_slice_by_names", TMessageType.REPLY, seqid));
+        result.write(oprot);
+        oprot.writeMessageEnd();
+        oprot.getTransport().flush();
+      }
+
+    }
+
+    private class get_column implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        get_column_args args = new get_column_args();
+        args.read(iprot);
+        iprot.readMessageEnd();
+        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 (CassandraException e) {
+          result.e = e;
+          result.__isset.e = true;
+        }
+        oprot.writeMessageBegin(new TMessage("get_column", TMessageType.REPLY, seqid));
+        result.write(oprot);
+        oprot.writeMessageEnd();
+        oprot.getTransport().flush();
+      }
+
+    }
+
+    private class get_column_count implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        get_column_count_args args = new get_column_count_args();
+        args.read(iprot);
+        iprot.readMessageEnd();
+        get_column_count_result result = new get_column_count_result();
+        try {
+          result.success = iface_.get_column_count(args.tablename, args.key, args.columnFamily_column);
+          result.__isset.success = true;
+        } catch (CassandraException e) {
+          result.e = e;
+          result.__isset.e = true;
+        }
+        oprot.writeMessageBegin(new TMessage("get_column_count", TMessageType.REPLY, seqid));
+        result.write(oprot);
+        oprot.writeMessageEnd();
+        oprot.getTransport().flush();
+      }
+
+    }
+
+    private class insert implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        insert_args args = new insert_args();
+        args.read(iprot);
+        iprot.readMessageEnd();
+        iface_.insert(args.tablename, args.key, args.columnFamily_column, args.cellData, args.timestamp);
+        return;
+      }
+    }
+
+    private class batch_insert implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        batch_insert_args args = new batch_insert_args();
+        args.read(iprot);
+        iprot.readMessageEnd();
+        iface_.batch_insert(args.batchMutation);
+        return;
+      }
+    }
+
+    private class batch_insert_blocking implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        batch_insert_blocking_args args = new batch_insert_blocking_args();
+        args.read(iprot);
+        iprot.readMessageEnd();
+        batch_insert_blocking_result result = new batch_insert_blocking_result();
+        try {
+          result.success = iface_.batch_insert_blocking(args.batchMutation);
+          result.__isset.success = true;
+        } catch (CassandraException e) {
+          result.e = e;
+          result.__isset.e = true;
+        }
+        oprot.writeMessageBegin(new TMessage("batch_insert_blocking", TMessageType.REPLY, seqid));
+        result.write(oprot);
+        oprot.writeMessageEnd();
+        oprot.getTransport().flush();
+      }
+
+    }
+
+    private class remove implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        remove_args args = new remove_args();
+        args.read(iprot);
+        iprot.readMessageEnd();
+        iface_.remove(args.tablename, args.key, args.columnFamily_column);
+        return;
+      }
+    }
+
+    private class get_columns_since implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        get_columns_since_args args = new get_columns_since_args();
+        args.read(iprot);
+        iprot.readMessageEnd();
+        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 (CassandraException e) {
+          result.e = e;
+          result.__isset.e = true;
+        }
+        oprot.writeMessageBegin(new TMessage("get_columns_since", TMessageType.REPLY, seqid));
+        result.write(oprot);
+        oprot.writeMessageEnd();
+        oprot.getTransport().flush();
+      }
+
+    }
+
+    private class get_slice_super implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        get_slice_super_args args = new get_slice_super_args();
+        args.read(iprot);
+        iprot.readMessageEnd();
+        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 (CassandraException e) {
+          result.e = e;
+          result.__isset.e = true;
+        }
+        oprot.writeMessageBegin(new TMessage("get_slice_super", TMessageType.REPLY, seqid));
+        result.write(oprot);
+        oprot.writeMessageEnd();
+        oprot.getTransport().flush();
+      }
+
+    }
+
+    private class get_slice_super_by_names implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        get_slice_super_by_names_args args = new get_slice_super_by_names_args();
+        args.read(iprot);
+        iprot.readMessageEnd();
+        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 (CassandraException e) {
+          result.e = e;
+          result.__isset.e = true;
+        }
+        oprot.writeMessageBegin(new TMessage("get_slice_super_by_names", TMessageType.REPLY, seqid));
+        result.write(oprot);
+        oprot.writeMessageEnd();
+        oprot.getTransport().flush();
+      }
+
+    }
+
+    private class get_superColumn implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        get_superColumn_args args = new get_superColumn_args();
+        args.read(iprot);
+        iprot.readMessageEnd();
+        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 (CassandraException e) {
+          result.e = e;
+          result.__isset.e = true;
+        }
+        oprot.writeMessageBegin(new TMessage("get_superColumn", TMessageType.REPLY, seqid));
+        result.write(oprot);
+        oprot.writeMessageEnd();
+        oprot.getTransport().flush();
+      }
+
+    }
+
+    private class batch_insert_superColumn implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        batch_insert_superColumn_args args = new batch_insert_superColumn_args();
+        args.read(iprot);
+        iprot.readMessageEnd();
+        iface_.batch_insert_superColumn(args.batchMutationSuper);
+        return;
+      }
+    }
+
+    private class batch_insert_superColumn_blocking implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        batch_insert_superColumn_blocking_args args = new batch_insert_superColumn_blocking_args();
+        args.read(iprot);
+        iprot.readMessageEnd();
+        batch_insert_superColumn_blocking_result result = new batch_insert_superColumn_blocking_result();
+        try {
+          result.success = iface_.batch_insert_superColumn_blocking(args.batchMutationSuper);
+          result.__isset.success = true;
+        } catch (CassandraException e) {
+          result.e = e;
+          result.__isset.e = true;
+        }
+        oprot.writeMessageBegin(new TMessage("batch_insert_superColumn_blocking", TMessageType.REPLY, seqid));
+        result.write(oprot);
+        oprot.writeMessageEnd();
+        oprot.getTransport().flush();
+      }
+
+    }
+
+    private class touch implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        touch_args args = new touch_args();
+        args.read(iprot);
+        iprot.readMessageEnd();
+        iface_.touch(args.key, args.fData);
+        return;
+      }
+    }
+
+    private class getStringProperty implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        getStringProperty_args args = new getStringProperty_args();
+        args.read(iprot);
+        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();
+        oprot.getTransport().flush();
+      }
+
+    }
+
+    private class getStringListProperty implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        getStringListProperty_args args = new getStringListProperty_args();
+        args.read(iprot);
+        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();
+        oprot.getTransport().flush();
+      }
+
+    }
+
+    private class describeTable implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        describeTable_args args = new describeTable_args();
+        args.read(iprot);
+        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();
+        oprot.getTransport().flush();
+      }
+
+    }
+
+    private class executeQuery implements ProcessFunction {
+      public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
+        executeQuery_args args = new executeQuery_args();
+        args.read(iprot);
+        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();
+        oprot.getTransport().flush();
+      }
+
+    }
+
+  }
+
+  public static class get_slice_args implements TBase, java.io.Serializable   {
+    public String tablename;
+    public String key;
+    public String columnFamily_column;
+    public int start;
+    public int count;
+
+    public final Isset __isset = new Isset();
+    public 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;
+    }
+
+    public get_slice_args() {
+      this.start = -1;
+
+      this.count = -1;
+
+    }
+
+    public get_slice_args(
+      String tablename,
+      String key,
+      String columnFamily_column,
+      int start,
+      int count)
+    {
+      this();
+      this.tablename = tablename;
+      this.__isset.tablename = true;
+      this.key = key;
+      this.__isset.key = true;
+      this.columnFamily_column = columnFamily_column;
+      this.__isset.columnFamily_column = true;
+      this.start = start;
+      this.__isset.start = true;
+      this.count = count;
+      this.__isset.count = true;
+    }
+
+    public boolean equals(Object that) {
+      if (that == null)
+        return false;
+      if (that instanceof get_slice_args)
+        return this.equals((get_slice_args)that);
+      return false;
+    }
+
+    public boolean equals(get_slice_args that) {
+      if (that == null)
+        return false;
+
+      boolean this_present_tablename = true && (this.tablename != null);
+      boolean that_present_tablename = true && (that.tablename != null);
+      if (this_present_tablename || that_present_tablename) {
+        if (!(this_present_tablename && that_present_tablename))
+          return false;
+        if (!this.tablename.equals(that.tablename))
+          return false;
+      }
+
+      boolean this_present_key = true && (this.key != null);
+      boolean that_present_key = true && (that.key != null);
+      if (this_present_key || that_present_key) {
+        if (!(this_present_key && that_present_key))
+          return false;
+        if (!this.key.equals(that.key))
+          return false;
+      }
+
+      boolean this_present_columnFamily_column = true && (this.columnFamily_column != null);
+      boolean that_present_columnFamily_column = true && (that.columnFamily_column != null);
+      if (this_present_columnFamily_column || that_present_columnFamily_column) {
+        if (!(this_present_columnFamily_column && that_present_columnFamily_column))
+          return false;
+        if (!this.columnFamily_column.equals(that.columnFamily_column))
+          return false;
+      }
+
+      boolean this_present_start = true;
+      boolean that_present_start = true;
+      if (this_present_start || that_present_start) {
+        if (!(this_present_start && that_present_start))
+          return false;
+        if (this.start != that.start)
+          return false;
+      }
+
+      boolean this_present_count = true;
+      boolean that_present_count = true;
+      if (this_present_count || that_present_count) {
+        if (!(this_present_count && that_present_count))
+          return false;
+        if (this.count != that.count)
+          return false;
+      }
+
+      return true;
+    }
+
+    public int hashCode() {
+      return 0;
+    }
+
+    public void read(TProtocol iprot) throws TException {
+      TField field;
+      iprot.readStructBegin();
+      while (true)
+      {
+        field = iprot.readFieldBegin();
+        if (field.type == TType.STOP) { 
+          break;
+        }
+        switch (field.id)
+        {
+          case -1:
+            if (field.type == TType.STRING) {
+              this.tablename = iprot.readString();
+              this.__isset.tablename = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case -2:
+            if (field.type == TType.STRING) {
+              this.key = iprot.readString();
+              this.__isset.key = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case -3:
+            if (field.type == TType.STRING) {
+              this.columnFamily_column = iprot.readString();
+              this.__isset.columnFamily_column = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case -4:
+            if (field.type == TType.I32) {
+              this.start = iprot.readI32();
+              this.__isset.start = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case -5:
+            if (field.type == TType.I32) {
+              this.count = iprot.readI32();
+              this.__isset.count = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          default:
+            TProtocolUtil.skip(iprot, field.type);
+            break;
+        }
+        iprot.readFieldEnd();
+      }
+      iprot.readStructEnd();
+    }
+
+    public void write(TProtocol oprot) throws TException {
+      TStruct struct = new TStruct("get_slice_args");
+      oprot.writeStructBegin(struct);
+      TField field = new TField();
+      if (this.tablename != null) {
+        field.name = "tablename";
+        field.type = TType.STRING;
+        field.id = -1;
+        oprot.writeFieldBegin(field);
+        oprot.writeString(this.tablename);
+        oprot.writeFieldEnd();
+      }
+      if (this.key != null) {
+        field.name = "key";
+        field.type = TType.STRING;
+        field.id = -2;
+        oprot.writeFieldBegin(field);
+        oprot.writeString(this.key);
+        oprot.writeFieldEnd();
+      }
+      if (this.columnFamily_column != null) {
+        field.name = "columnFamily_column";
+        field.type = TType.STRING;
+        field.id = -3;
+        oprot.writeFieldBegin(field);
+        oprot.writeString(this.columnFamily_column);
+        oprot.writeFieldEnd();
+      }
+      field.name = "start";
+      field.type = TType.I32;
+      field.id = -4;
+      oprot.writeFieldBegin(field);
+      oprot.writeI32(this.start);
+      oprot.writeFieldEnd();
+      field.name = "count";
+      field.type = TType.I32;
+      field.id = -5;
+      oprot.writeFieldBegin(field);
+      oprot.writeI32(this.count);
+      oprot.writeFieldEnd();
+      oprot.writeFieldStop();
+      oprot.writeStructEnd();
+    }
+
+    public String toString() {
+      StringBuilder sb = new StringBuilder("get_slice_args(");
+      sb.append("tablename:");
+      sb.append(this.tablename);
+      sb.append(",key:");
+      sb.append(this.key);
+      sb.append(",columnFamily_column:");
+      sb.append(this.columnFamily_column);
+      sb.append(",start:");
+      sb.append(this.start);
+      sb.append(",count:");
+      sb.append(this.count);
+      sb.append(")");
+      return sb.toString();
+    }
+
+  }
+
+  public static class get_slice_result implements TBase, java.io.Serializable   {
+    public List<column_t> success;
+    public CassandraException e;
+
+    public final Isset __isset = new Isset();
+    public static final class Isset implements java.io.Serializable {
+      public boolean success = false;
+      public boolean e = false;
+    }
+
+    public get_slice_result() {
+    }
+
+    public get_slice_result(
+      List<column_t> success,
+      CassandraException e)
+    {
+      this();
+      this.success = success;
+      this.__isset.success = true;
+      this.e = e;
+      this.__isset.e = true;
+    }
+
+    public boolean equals(Object that) {
+      if (that == null)
+        return false;
+      if (that instanceof get_slice_result)
+        return this.equals((get_slice_result)that);
+      return false;
+    }
+
+    public boolean equals(get_slice_result that) {
+      if (that == null)
+        return false;
+
+      boolean this_present_success = true && (this.success != null);
+      boolean that_present_success = true && (that.success != null);
+      if (this_present_success || that_present_success) {
+        if (!(this_present_success && that_present_success))
+          return false;
+        if (!this.success.equals(that.success))
+          return false;
+      }
+
+      boolean this_present_e = true && (this.e != null);
+      boolean that_present_e = true && (that.e != null);
+      if (this_present_e || that_present_e) {
+        if (!(this_present_e && that_present_e))
+          return false;
+        if (!this.e.equals(that.e))
+          return false;
+      }
+
+      return true;
+    }
+
+    public int hashCode() {
+      return 0;
+    }
+
+    public void read(TProtocol iprot) throws TException {
+      TField field;
+      iprot.readStructBegin();
+      while (true)
+      {
+        field = iprot.readFieldBegin();
+        if (field.type == TType.STOP) { 
+          break;
+        }
+        switch (field.id)
+        {
+          case 0:
+            if (field.type == TType.LIST) {
+              {
+                TList _list49 = iprot.readListBegin();
+                this.success = new ArrayList<column_t>(_list49.size);
+                for (int _i50 = 0; _i50 < _list49.size; ++_i50)
+                {
+                  column_t _elem51 = new column_t();
+                  _elem51 = new column_t();
+                  _elem51.read(iprot);
+                  this.success.add(_elem51);
+                }
+                iprot.readListEnd();
+              }
+              this.__isset.success = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case 1:
+            if (field.type == TType.STRUCT) {
+              this.e = new CassandraException();
+              this.e.read(iprot);
+              this.__isset.e = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          default:
+            TProtocolUtil.skip(iprot, field.type);
+            break;
+        }
+        iprot.readFieldEnd();
+      }
+      iprot.readStructEnd();
+    }
+
+    public void write(TProtocol oprot) throws TException {
+      TStruct struct = new TStruct("get_slice_result");
+      oprot.writeStructBegin(struct);
+      TField field = new TField();
+
+      if (this.__isset.success) {
+        if (this.success != null) {
+          field.name = "success";
+          field.type = TType.LIST;
+          field.id = 0;
+          oprot.writeFieldBegin(field);
+          {
+            oprot.writeListBegin(new TList(TType.STRUCT, this.success.size()));
+            for (column_t _iter52 : this.success)            {
+              _iter52.write(oprot);
+            }
+            oprot.writeListEnd();
+          }
+          oprot.writeFieldEnd();
+        }
+      } else if (this.__isset.e) {
+        if (this.e != null) {
+          field.name = "e";
+          field.type = TType.STRUCT;
+          field.id = 1;
+          oprot.writeFieldBegin(field);
+          this.e.write(oprot);
+          oprot.writeFieldEnd();
+        }
+      }
+      oprot.writeFieldStop();
+      oprot.writeStructEnd();
+    }
+
+    public String toString() {
+      StringBuilder sb = new StringBuilder("get_slice_result(");
+      sb.append("success:");
+      sb.append(this.success);
+      sb.append(",e:");
+      sb.append(this.e);
+      sb.append(")");
+      return sb.toString();
+    }
+
+  }
+
+  public static class get_slice_by_names_args implements TBase, java.io.Serializable   {
+    public String tablename;
+    public String key;
+    public String columnFamily;
+    public List<String> columnNames;
+
+    public final Isset __isset = new Isset();
+    public 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 get_slice_by_names_args() {
+    }
+
+    public get_slice_by_names_args(
+      String tablename,
+      String key,
+      String columnFamily,
+      List<String> columnNames)
+    {
+      this();
+      this.tablename = tablename;
+      this.__isset.tablename = true;
+      this.key = key;
+      this.__isset.key = true;
+      this.columnFamily = columnFamily;
+      this.__isset.columnFamily = true;
+      this.columnNames = columnNames;
+      this.__isset.columnNames = true;
+    }
+
+    public boolean equals(Object that) {
+      if (that == null)
+        return false;
+      if (that instanceof get_slice_by_names_args)
+        return this.equals((get_slice_by_names_args)that);
+      return false;
+    }
+
+    public boolean equals(get_slice_by_names_args that) {
+      if (that == null)
+        return false;
+
+      boolean this_present_tablename = true && (this.tablename != null);
+      boolean that_present_tablename = true && (that.tablename != null);
+      if (this_present_tablename || that_present_tablename) {
+        if (!(this_present_tablename && that_present_tablename))
+          return false;
+        if (!this.tablename.equals(that.tablename))
+          return false;
+      }
+
+      boolean this_present_key = true && (this.key != null);
+      boolean that_present_key = true && (that.key != null);
+      if (this_present_key || that_present_key) {
+        if (!(this_present_key && that_present_key))
+          return false;
+        if (!this.key.equals(that.key))
+          return false;
+      }
+
+      boolean this_present_columnFamily = true && (this.columnFamily != null);
+      boolean that_present_columnFamily = true && (that.columnFamily != null);
+      if (this_present_columnFamily || that_present_columnFamily) {
+        if (!(this_present_columnFamily && that_present_columnFamily))
+          return false;
+        if (!this.columnFamily.equals(that.columnFamily))
+          return false;
+      }
+
+      boolean this_present_columnNames = true && (this.columnNames != null);
+      boolean that_present_columnNames = true && (that.columnNames != null);
+      if (this_present_columnNames || that_present_columnNames) {
+        if (!(this_present_columnNames && that_present_columnNames))
+          return false;
+        if (!this.columnNames.equals(that.columnNames))
+          return false;
+      }
+
+      return true;
+    }
+
+    public int hashCode() {
+      return 0;
+    }
+
+    public void read(TProtocol iprot) throws TException {
+      TField field;
+      iprot.readStructBegin();
+      while (true)
+      {
+        field = iprot.readFieldBegin();
+        if (field.type == TType.STOP) { 
+          break;
+        }
+        switch (field.id)
+        {
+          case -1:
+            if (field.type == TType.STRING) {
+              this.tablename = iprot.readString();
+              this.__isset.tablename = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case -2:
+            if (field.type == TType.STRING) {
+              this.key = iprot.readString();
+              this.__isset.key = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case -3:
+            if (field.type == TType.STRING) {
+              this.columnFamily = iprot.readString();
+              this.__isset.columnFamily = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case -4:
+            if (field.type == TType.LIST) {
+              {
+                TList _list53 = iprot.readListBegin();
+                this.columnNames = new ArrayList<String>(_list53.size);
+                for (int _i54 = 0; _i54 < _list53.size; ++_i54)
+                {
+                  String _elem55 = null;
+                  _elem55 = iprot.readString();
+                  this.columnNames.add(_elem55);
+                }
+                iprot.readListEnd();
+              }
+              this.__isset.columnNames = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          default:
+            TProtocolUtil.skip(iprot, field.type);
+            break;
+        }
+        iprot.readFieldEnd();
+      }
+      iprot.readStructEnd();
+    }
+
+    public void write(TProtocol oprot) throws TException {
+      TStruct struct = new TStruct("get_slice_by_names_args");
+      oprot.writeStructBegin(struct);
+      TField field = new TField();
+      if (this.tablename != null) {
+        field.name = "tablename";
+        field.type = TType.STRING;
+        field.id = -1;
+        oprot.writeFieldBegin(field);
+        oprot.writeString(this.tablename);
+        oprot.writeFieldEnd();
+      }
+      if (this.key != null) {
+        field.name = "key";
+        field.type = TType.STRING;
+        field.id = -2;
+        oprot.writeFieldBegin(field);
+        oprot.writeString(this.key);
+        oprot.writeFieldEnd();
+      }
+      if (this.columnFamily != null) {
+        field.name = "columnFamily";
+        field.type = TType.STRING;
+        field.id = -3;
+        oprot.writeFieldBegin(field);
+        oprot.writeString(this.columnFamily);
+        oprot.writeFieldEnd();
+      }
+      if (this.columnNames != null) {
+        field.name = "columnNames";
+        field.type = TType.LIST;
+        field.id = -4;
+        oprot.writeFieldBegin(field);
+        {
+          oprot.writeListBegin(new TList(TType.STRING, this.columnNames.size()));
+          for (String _iter56 : this.columnNames)          {
+            oprot.writeString(_iter56);
+          }
+          oprot.writeListEnd();
+        }
+        oprot.writeFieldEnd();
+      }
+      oprot.writeFieldStop();
+      oprot.writeStructEnd();
+    }
+
+    public String toString() {
+      StringBuilder sb = new StringBuilder("get_slice_by_names_args(");
+      sb.append("tablename:");
+      sb.append(this.tablename);
+      sb.append(",key:");
+      sb.append(this.key);
+      sb.append(",columnFamily:");
+      sb.append(this.columnFamily);
+      sb.append(",columnNames:");
+      sb.append(this.columnNames);
+      sb.append(")");
+      return sb.toString();
+    }
+
+  }
+
+  public static class get_slice_by_names_result implements TBase, java.io.Serializable   {
+    public List<column_t> success;
+    public CassandraException e;
+
+    public final Isset __isset = new Isset();
+    public static final class Isset implements java.io.Serializable {
+      public boolean success = false;
+      public boolean e = false;
+    }
+
+    public get_slice_by_names_result() {
+    }
+
+    public get_slice_by_names_result(
+      List<column_t> success,
+      CassandraException e)
+    {
+      this();
+      this.success = success;
+      this.__isset.success = true;
+      this.e = e;
+      this.__isset.e = true;
+    }
+
+    public boolean equals(Object that) {
+      if (that == null)
+        return false;
+      if (that instanceof get_slice_by_names_result)
+        return this.equals((get_slice_by_names_result)that);
+      return false;
+    }
+
+    public boolean equals(get_slice_by_names_result that) {
+      if (that == null)
+        return false;
+
+      boolean this_present_success = true && (this.success != null);
+      boolean that_present_success = true && (that.success != null);
+      if (this_present_success || that_present_success) {
+        if (!(this_present_success && that_present_success))
+          return false;
+        if (!this.success.equals(that.success))
+          return false;
+      }
+
+      boolean this_present_e = true && (this.e != null);
+      boolean that_present_e = true && (that.e != null);
+      if (this_present_e || that_present_e) {
+        if (!(this_present_e && that_present_e))
+          return false;
+        if (!this.e.equals(that.e))
+          return false;
+      }
+
+      return true;
+    }
+
+    public int hashCode() {
+      return 0;
+    }
+
+    public void read(TProtocol iprot) throws TException {
+      TField field;
+      iprot.readStructBegin();
+      while (true)
+      {
+        field = iprot.readFieldBegin();
+        if (field.type == TType.STOP) { 
+          break;
+        }
+        switch (field.id)
+        {
+          case 0:
+            if (field.type == TType.LIST) {
+              {
+                TList _list57 = iprot.readListBegin();
+                this.success = new ArrayList<column_t>(_list57.size);
+                for (int _i58 = 0; _i58 < _list57.size; ++_i58)
+                {
+                  column_t _elem59 = new column_t();
+                  _elem59 = new column_t();
+                  _elem59.read(iprot);
+                  this.success.add(_elem59);
+                }
+                iprot.readListEnd();
+              }
+              this.__isset.success = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case 1:
+            if (field.type == TType.STRUCT) {
+              this.e = new CassandraException();
+              this.e.read(iprot);
+              this.__isset.e = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          default:
+            TProtocolUtil.skip(iprot, field.type);
+            break;
+        }
+        iprot.readFieldEnd();
+      }
+      iprot.readStructEnd();
+    }
+
+    public void write(TProtocol oprot) throws TException {
+      TStruct struct = new TStruct("get_slice_by_names_result");
+      oprot.writeStructBegin(struct);
+      TField field = new TField();
+
+      if (this.__isset.success) {
+        if (this.success != null) {
+          field.name = "success";
+          field.type = TType.LIST;
+          field.id = 0;
+          oprot.writeFieldBegin(field);
+          {
+            oprot.writeListBegin(new TList(TType.STRUCT, this.success.size()));
+            for (column_t _iter60 : this.success)            {
+              _iter60.write(oprot);
+            }
+            oprot.writeListEnd();
+          }
+          oprot.writeFieldEnd();
+        }
+      } else if (this.__isset.e) {
+        if (this.e != null) {
+          field.name = "e";
+          field.type = TType.STRUCT;
+          field.id = 1;
+          oprot.writeFieldBegin(field);
+          this.e.write(oprot);
+          oprot.writeFieldEnd();
+        }
+      }
+      oprot.writeFieldStop();
+      oprot.writeStructEnd();
+    }
+
+    public String toString() {
+      StringBuilder sb = new StringBuilder("get_slice_by_names_result(");
+      sb.append("success:");
+      sb.append(this.success);
+      sb.append(",e:");
+      sb.append(this.e);
+      sb.append(")");
+      return sb.toString();
+    }
+
+  }
+
+  public static class get_column_args implements TBase, java.io.Serializable   {
+    public String tablename;
+    public String key;
+    public String columnFamily_column;
+
+    public final Isset __isset = new Isset();
+    public static final class Isset implements java.io.Serializable {
+      public boolean tablename = false;
+      public boolean key = false;
+      public boolean columnFamily_column = false;
+    }
+
+    public get_column_args() {
+    }
+
+    public get_column_args(
+      String tablename,
+      String key,
+      String columnFamily_column)
+    {
+      this();
+      this.tablename = tablename;
+      this.__isset.tablename = true;
+      this.key = key;
+      this.__isset.key = true;
+      this.columnFamily_column = columnFamily_column;
+      this.__isset.columnFamily_column = true;
+    }
+
+    public boolean equals(Object that) {
+      if (that == null)
+        return false;
+      if (that instanceof get_column_args)
+        return this.equals((get_column_args)that);
+      return false;
+    }
+
+    public boolean equals(get_column_args that) {
+      if (that == null)
+        return false;
+
+      boolean this_present_tablename = true && (this.tablename != null);
+      boolean that_present_tablename = true && (that.tablename != null);
+      if (this_present_tablename || that_present_tablename) {
+        if (!(this_present_tablename && that_present_tablename))
+          return false;
+        if (!this.tablename.equals(that.tablename))
+          return false;
+      }
+
+      boolean this_present_key = true && (this.key != null);
+      boolean that_present_key = true && (that.key != null);
+      if (this_present_key || that_present_key) {
+        if (!(this_present_key && that_present_key))
+          return false;
+        if (!this.key.equals(that.key))
+          return false;
+      }
+
+      boolean this_present_columnFamily_column = true && (this.columnFamily_column != null);
+      boolean that_present_columnFamily_column = true && (that.columnFamily_column != null);
+      if (this_present_columnFamily_column || that_present_columnFamily_column) {
+        if (!(this_present_columnFamily_column && that_present_columnFamily_column))
+          return false;
+        if (!this.columnFamily_column.equals(that.columnFamily_column))
+          return false;
+      }
+
+      return true;
+    }
+
+    public int hashCode() {
+      return 0;
+    }
+
+    public void read(TProtocol iprot) throws TException {
+      TField field;
+      iprot.readStructBegin();
+      while (true)
+      {
+        field = iprot.readFieldBegin();
+        if (field.type == TType.STOP) { 
+          break;
+        }
+        switch (field.id)
+        {
+          case -1:
+            if (field.type == TType.STRING) {
+              this.tablename = iprot.readString();
+              this.__isset.tablename = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case -2:
+            if (field.type == TType.STRING) {
+              this.key = iprot.readString();
+              this.__isset.key = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case -3:
+            if (field.type == TType.STRING) {
+              this.columnFamily_column = iprot.readString();
+              this.__isset.columnFamily_column = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          default:
+            TProtocolUtil.skip(iprot, field.type);
+            break;
+        }
+        iprot.readFieldEnd();
+      }
+      iprot.readStructEnd();
+    }
+
+    public void write(TProtocol oprot) throws TException {
+      TStruct struct = new TStruct("get_column_args");
+      oprot.writeStructBegin(struct);
+      TField field = new TField();
+      if (this.tablename != null) {
+        field.name = "tablename";
+        field.type = TType.STRING;
+        field.id = -1;
+        oprot.writeFieldBegin(field);
+        oprot.writeString(this.tablename);
+        oprot.writeFieldEnd();
+      }
+      if (this.key != null) {
+        field.name = "key";
+        field.type = TType.STRING;
+        field.id = -2;
+        oprot.writeFieldBegin(field);
+        oprot.writeString(this.key);
+        oprot.writeFieldEnd();
+      }
+      if (this.columnFamily_column != null) {
+        field.name = "columnFamily_column";
+        field.type = TType.STRING;
+        field.id = -3;
+        oprot.writeFieldBegin(field);
+        oprot.writeString(this.columnFamily_column);
+        oprot.writeFieldEnd();
+      }
+      oprot.writeFieldStop();
+      oprot.writeStructEnd();
+    }
+
+    public String toString() {
+      StringBuilder sb = new StringBuilder("get_column_args(");
+      sb.append("tablename:");
+      sb.append(this.tablename);
+      sb.append(",key:");
+      sb.append(this.key);
+      sb.append(",columnFamily_column:");
+      sb.append(this.columnFamily_column);
+      sb.append(")");
+      return sb.toString();
+    }
+
+  }
+
+  public static class get_column_result implements TBase, java.io.Serializable   {
+    public column_t success;
+    public CassandraException e;
+
+    public final Isset __isset = new Isset();
+    public static final class Isset implements java.io.Serializable {
+      public boolean success = false;
+      public boolean e = false;
+    }
+
+    public get_column_result() {
+    }
+
+    public get_column_result(
+      column_t success,
+      CassandraException e)
+    {
+      this();
+      this.success = success;
+      this.__isset.success = true;
+      this.e = e;
+      this.__isset.e = true;
+    }
+
+    public boolean equals(Object that) {
+      if (that == null)
+        return false;
+      if (that instanceof get_column_result)
+        return this.equals((get_column_result)that);
+      return false;
+    }
+
+    public boolean equals(get_column_result that) {
+      if (that == null)
+        return false;
+
+      boolean this_present_success = true && (this.success != null);
+      boolean that_present_success = true && (that.success != null);
+      if (this_present_success || that_present_success) {
+        if (!(this_present_success && that_present_success))
+          return false;
+        if (!this.success.equals(that.success))
+          return false;
+      }
+
+      boolean this_present_e = true && (this.e != null);
+      boolean that_present_e = true && (that.e != null);
+      if (this_present_e || that_present_e) {
+        if (!(this_present_e && that_present_e))
+          return false;
+        if (!this.e.equals(that.e))
+          return false;
+      }
+
+      return true;
+    }
+
+    public int hashCode() {
+      return 0;
+    }
+
+    public void read(TProtocol iprot) throws TException {
+      TField field;
+      iprot.readStructBegin();
+      while (true)
+      {
+        field = iprot.readFieldBegin();
+        if (field.type == TType.STOP) { 
+          break;
+        }
+        switch (field.id)
+        {
+          case 0:
+            if (field.type == TType.STRUCT) {
+              this.success = new column_t();
+              this.success.read(iprot);
+              this.__isset.success = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case 1:
+            if (field.type == TType.STRUCT) {
+              this.e = new CassandraException();
+              this.e.read(iprot);
+              this.__isset.e = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          default:
+            TProtocolUtil.skip(iprot, field.type);
+            break;
+        }
+        iprot.readFieldEnd();
+      }
+      iprot.readStructEnd();
+    }
+
+    public void write(TProtocol oprot) throws TException {
+      TStruct struct = new TStruct("get_column_result");
+      oprot.writeStructBegin(struct);
+      TField field = new TField();
+
+      if (this.__isset.success) {
+        if (this.success != null) {
+          field.name = "success";
+          field.type = TType.STRUCT;
+          field.id = 0;
+          oprot.writeFieldBegin(field);
+          this.success.write(oprot);
+          oprot.writeFieldEnd();
+        }
+      } else if (this.__isset.e) {
+        if (this.e != null) {
+          field.name = "e";
+          field.type = TType.STRUCT;
+          field.id = 1;
+          oprot.writeFieldBegin(field);
+          this.e.write(oprot);
+          oprot.writeFieldEnd();
+        }
+      }
+      oprot.writeFieldStop();
+      oprot.writeStructEnd();
+    }
+
+    public String toString() {
+      StringBuilder sb = new StringBuilder("get_column_result(");
+      sb.append("success:");
+      sb.append(this.success);
+      sb.append(",e:");
+      sb.append(this.e);
+      sb.append(")");
+      return sb.toString();
+    }
+
+  }
+
+  public static class get_column_count_args implements TBase, java.io.Serializable   {
+    public String tablename;
+    public String key;
+    public String columnFamily_column;
+
+    public final Isset __isset = new Isset();
+    public static final class Isset implements java.io.Serializable {
+      public boolean tablename = false;
+      public boolean key = false;
+      public boolean columnFamily_column = false;
+    }
+
+    public get_column_count_args() {
+    }
+
+    public get_column_count_args(
+      String tablename,
+      String key,
+      String columnFamily_column)
+    {
+      this();
+      this.tablename = tablename;
+      this.__isset.tablename = true;
+      this.key = key;
+      this.__isset.key = true;
+      this.columnFamily_column = columnFamily_column;
+      this.__isset.columnFamily_column = true;
+    }
+
+    public boolean equals(Object that) {
+      if (that == null)
+        return false;
+      if (that instanceof get_column_count_args)
+        return this.equals((get_column_count_args)that);
+      return false;
+    }
+
+    public boolean equals(get_column_count_args that) {
+      if (that == null)
+        return false;
+
+      boolean this_present_tablename = true && (this.tablename != null);
+      boolean that_present_tablename = true && (that.tablename != null);
+      if (this_present_tablename || that_present_tablename) {
+        if (!(this_present_tablename && that_present_tablename))
+          return false;
+        if (!this.tablename.equals(that.tablename))
+          return false;
+      }
+
+      boolean this_present_key = true && (this.key != null);
+      boolean that_present_key = true && (that.key != null);
+      if (this_present_key || that_present_key) {
+        if (!(this_present_key && that_present_key))
+          return false;
+        if (!this.key.equals(that.key))
+          return false;
+      }
+
+      boolean this_present_columnFamily_column = true && (this.columnFamily_column != null);
+      boolean that_present_columnFamily_column = true && (that.columnFamily_column != null);
+      if (this_present_columnFamily_column || that_present_columnFamily_column) {
+        if (!(this_present_columnFamily_column && that_present_columnFamily_column))
+          return false;
+        if (!this.columnFamily_column.equals(that.columnFamily_column))
+          return false;
+      }
+
+      return true;
+    }
+
+    public int hashCode() {
+      return 0;
+    }
+
+    public void read(TProtocol iprot) throws TException {
+      TField field;
+      iprot.readStructBegin();
+      while (true)
+      {
+        field = iprot.readFieldBegin();
+        if (field.type == TType.STOP) { 
+          break;
+        }
+        switch (field.id)
+        {
+          case -1:
+            if (field.type == TType.STRING) {
+              this.tablename = iprot.readString();
+              this.__isset.tablename = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case -2:
+            if (field.type == TType.STRING) {
+              this.key = iprot.readString();
+              this.__isset.key = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case -3:
+            if (field.type == TType.STRING) {
+              this.columnFamily_column = iprot.readString();
+              this.__isset.columnFamily_column = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          default:
+            TProtocolUtil.skip(iprot, field.type);
+            break;
+        }
+        iprot.readFieldEnd();
+      }
+      iprot.readStructEnd();
+    }
+
+    public void write(TProtocol oprot) throws TException {
+      TStruct struct = new TStruct("get_column_count_args");
+      oprot.writeStructBegin(struct);
+      TField field = new TField();
+      if (this.tablename != null) {
+        field.name = "tablename";
+        field.type = TType.STRING;
+        field.id = -1;
+        oprot.writeFieldBegin(field);
+        oprot.writeString(this.tablename);
+        oprot.writeFieldEnd();
+      }
+      if (this.key != null) {
+        field.name = "key";
+        field.type = TType.STRING;
+        field.id = -2;
+        oprot.writeFieldBegin(field);
+        oprot.writeString(this.key);
+        oprot.writeFieldEnd();
+      }
+      if (this.columnFamily_column != null) {
+        field.name = "columnFamily_column";
+        field.type = TType.STRING;
+        field.id = -3;
+        oprot.writeFieldBegin(field);
+        oprot.writeString(this.columnFamily_column);
+        oprot.writeFieldEnd();
+      }
+      oprot.writeFieldStop();
+      oprot.writeStructEnd();
+    }
+
+    public String toString() {
+      StringBuilder sb = new StringBuilder("get_column_count_args(");
+      sb.append("tablename:");
+      sb.append(this.tablename);
+      sb.append(",key:");
+      sb.append(this.key);
+      sb.append(",columnFamily_column:");
+      sb.append(this.columnFamily_column);
+      sb.append(")");
+      return sb.toString();
+    }
+
+  }
+
+  public static class get_column_count_result implements TBase, java.io.Serializable   {
+    public int success;
+    public CassandraException e;
+
+    public final Isset __isset = new Isset();
+    public static final class Isset implements java.io.Serializable {
+      public boolean success = false;
+      public boolean e = false;
+    }
+
+    public get_column_count_result() {
+    }
+
+    public get_column_count_result(
+      int success,
+      CassandraException e)
+    {
+      this();
+      this.success = success;
+      this.__isset.success = true;
+      this.e = e;
+      this.__isset.e = true;
+    }
+
+    public boolean equals(Object that) {
+      if (that == null)
+        return false;
+      if (that instanceof get_column_count_result)
+        return this.equals((get_column_count_result)that);
+      return false;
+    }
+
+    public boolean equals(get_column_count_result that) {
+      if (that == null)
+        return false;
+
+      boolean this_present_success = true;
+      boolean that_present_success = true;
+      if (this_present_success || that_present_success) {
+        if (!(this_present_success && that_present_success))
+          return false;
+        if (this.success != that.success)
+          return false;
+      }
+
+      boolean this_present_e = true && (this.e != null);
+      boolean that_present_e = true && (that.e != null);
+      if (this_present_e || that_present_e) {
+        if (!(this_present_e && that_present_e))
+          return false;
+        if (!this.e.equals(that.e))
+          return false;
+      }
+
+      return true;
+    }
+
+    public int hashCode() {
+      return 0;
+    }
+
+    public void read(TProtocol iprot) throws TException {
+      TField field;
+      iprot.readStructBegin();
+      while (true)
+      {
+        field = iprot.readFieldBegin();
+        if (field.type == TType.STOP) { 
+          break;
+        }
+        switch (field.id)
+        {
+          case 0:
+            if (field.type == TType.I32) {
+              this.success = iprot.readI32();
+              this.__isset.success = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case 1:
+            if (field.type == TType.STRUCT) {
+              this.e = new CassandraException();
+              this.e.read(iprot);
+              this.__isset.e = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          default:
+            TProtocolUtil.skip(iprot, field.type);
+            break;
+        }
+        iprot.readFieldEnd();
+      }
+      iprot.readStructEnd();
+    }
+
+    public void write(TProtocol oprot) throws TException {
+      TStruct struct = new TStruct("get_column_count_result");
+      oprot.writeStructBegin(struct);
+      TField field = new TField();
+
+      if (this.__isset.success) {
+        field.name = "success";
+        field.type = TType.I32;
+        field.id = 0;
+        oprot.writeFieldBegin(field);
+        oprot.writeI32(this.success);
+        oprot.writeFieldEnd();
+      } else if (this.__isset.e) {
+        if (this.e != null) {
+          field.name = "e";
+          field.type = TType.STRUCT;
+          field.id = 1;
+          oprot.writeFieldBegin(field);
+          this.e.write(oprot);
+          oprot.writeFieldEnd();
+        }
+      }
+      oprot.writeFieldStop();
+      oprot.writeStructEnd();
+    }
+
+    public String toString() {
+      StringBuilder sb = new StringBuilder("get_column_count_result(");
+      sb.append("success:");
+      sb.append(this.success);
+      sb.append(",e:");
+      sb.append(this.e);
+      sb.append(")");
+      return sb.toString();
+    }
+
+  }
+
+  public static class insert_args implements TBase, java.io.Serializable   {
+    public String tablename;
+    public String key;
+    public String columnFamily_column;
+    public String cellData;
+    public long timestamp;
+
+    public final Isset __isset = new Isset();
+    public static final class Isset implements java.io.Serializable {
+      public boolean tablename = false;
+      public boolean key = false;
+      public boolean columnFamily_column = false;
+      public boolean cellData = false;
+      public boolean timestamp = false;
+    }
+
+    public insert_args() {
+    }
+
+    public insert_args(
+      String tablename,
+      String key,
+      String columnFamily_column,
+      String cellData,
+      long timestamp)
+    {
+      this();
+      this.tablename = tablename;
+      this.__isset.tablename = true;
+      this.key = key;
+      this.__isset.key = true;
+      this.columnFamily_column = columnFamily_column;
+      this.__isset.columnFamily_column = true;
+      this.cellData = cellData;
+      this.__isset.cellData = true;
+      this.timestamp = timestamp;
+      this.__isset.timestamp = true;
+    }
+
+    public boolean equals(Object that) {
+      if (that == null)
+        return false;
+      if (that instanceof insert_args)
+        return this.equals((insert_args)that);
+      return false;
+    }
+
+    public boolean equals(insert_args that) {
+      if (that == null)
+        return false;
+
+      boolean this_present_tablename = true && (this.tablename != null);
+      boolean that_present_tablename = true && (that.tablename != null);
+      if (this_present_tablename || that_present_tablename) {
+        if (!(this_present_tablename && that_present_tablename))
+          return false;
+        if (!this.tablename.equals(that.tablename))
+          return false;
+      }
+
+      boolean this_present_key = true && (this.key != null);
+      boolean that_present_key = true && (that.key != null);
+      if (this_present_key || that_present_key) {
+        if (!(this_present_key && that_present_key))
+          return false;
+        if (!this.key.equals(that.key))
+          return false;
+      }
+
+      boolean this_present_columnFamily_column = true && (this.columnFamily_column != null);
+      boolean that_present_columnFamily_column = true && (that.columnFamily_column != null);
+      if (this_present_columnFamily_column || that_present_columnFamily_column) {
+        if (!(this_present_columnFamily_column && that_present_columnFamily_column))
+          return false;
+        if (!this.columnFamily_column.equals(that.columnFamily_column))
+          return false;
+      }
+
+      boolean this_present_cellData = true && (this.cellData != null);
+      boolean that_present_cellData = true && (that.cellData != null);
+      if (this_present_cellData || that_present_cellData) {
+        if (!(this_present_cellData && that_present_cellData))
+          return false;
+        if (!this.cellData.equals(that.cellData))
+          return false;
+      }
+
+      boolean this_present_timestamp = true;
+      boolean that_present_timestamp = true;
+      if (this_present_timestamp || that_present_timestamp) {
+        if (!(this_present_timestamp && that_present_timestamp))
+          return false;
+        if (this.timestamp != that.timestamp)
+          return false;
+      }
+
+      return true;
+    }
+
+    public int hashCode() {
+      return 0;
+    }
+
+    public void read(TProtocol iprot) throws TException {
+      TField field;
+      iprot.readStructBegin();
+      while (true)
+      {
+        field = iprot.readFieldBegin();
+        if (field.type == TType.STOP) { 
+          break;
+        }
+        switch (field.id)
+        {
+          case -1:
+            if (field.type == TType.STRING) {
+              this.tablename = iprot.readString();
+              this.__isset.tablename = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case -2:
+            if (field.type == TType.STRING) {
+              this.key = iprot.readString();
+              this.__isset.key = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case -3:
+            if (field.type == TType.STRING) {
+              this.columnFamily_column = iprot.readString();
+              this.__isset.columnFamily_column = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case -4:
+            if (field.type == TType.STRING) {
+              this.cellData = iprot.readString();
+              this.__isset.cellData = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case -5:
+            if (field.type == TType.I64) {
+              this.timestamp = iprot.readI64();
+              this.__isset.timestamp = true;
+            } else { 
+              TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          default:
+            TProtocolUtil.skip(iprot, field.type);
+            break;
+        }
+        iprot.readFieldEnd();
+      }
+      iprot.readStructEnd();
+    }
+
+    public void write(TProtocol oprot) throws TException {
+      TStruct struct = new TStruct("insert_args");
+      oprot.writeStructBegin(struct);
+      TField field = new TField();
+      if (this.tablename != null) {
+        field.name = "tablename";
+        field.type = TType.STRING;
+        field.id = -1;
+        oprot.writeFieldBegin(field);
+        oprot.writeString(this.tablename);
+        oprot.writeFieldEnd();
+      }
+      if (this.key != null) {
+        field.name = "key";
+        field.type = TType.STRING;
+        field.id = -2;
+        oprot.writeFieldBegin(field);
+        oprot.writeString(this.key);
+        oprot.writeFieldEnd();
+      }
+      if (this.columnFamily_column != null) {
+        field.name = "columnFamily_column";
+        field.type = TType.STRING;
+        field.id = -3;
+        oprot.writeFieldBegin(field);
+        oprot.writeString(this.columnFamily_column);
+        oprot.writeFieldEnd();
+      }

[... 3257 lines stripped ...]


Mime
View raw message