You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by al...@apache.org on 2009/03/02 07:13:17 UTC
svn commit: r749207 [6/12] - in
/incubator/cassandra/src/org/apache/cassandra: loader/ locator/ net/
net/http/ net/io/ net/sink/ procedures/ service/ test/ tools/
Added: incubator/cassandra/src/org/apache/cassandra/service/Cassandra.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/src/org/apache/cassandra/service/Cassandra.java?rev=749207&view=auto
==============================================================================
--- incubator/cassandra/src/org/apache/cassandra/service/Cassandra.java (added)
+++ incubator/cassandra/src/org/apache/cassandra/service/Cassandra.java Mon Mar 2 06:13:14 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();
+ }
+ if (this.cellData != null) {
[... 3256 lines stripped ...]