You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2010/03/01 17:21:34 UTC
svn commit: r917571 [2/3] - in /incubator/cassandra/branches/cassandra-0.6:
interface/thrift/gen-java/org/apache/cassandra/thrift/ lib/ test/system/
Modified: incubator/cassandra/branches/cassandra-0.6/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/branches/cassandra-0.6/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java?rev=917571&r1=917570&r2=917571&view=diff
==============================================================================
--- incubator/cassandra/branches/cassandra-0.6/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java (original)
+++ incubator/cassandra/branches/cassandra-0.6/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java Mon Mar 1 16:21:33 2010
@@ -77,6 +77,7 @@
* Perform a get for column_path in parallel on the given list<string> keys. The return value maps keys to the
* ColumnOrSuperColumn found. If no value corresponding to a key is present, the key will still be in the map, but both
* the column and super_column references of the ColumnOrSuperColumn object it maps to will be null.
+ * @deprecated; use multiget_slice
*
* @param keyspace
* @param keys
@@ -1119,7 +1120,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
login_args args = new login_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("login", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
login_result result = new login_result();
try {
@@ -1149,7 +1160,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
get_args args = new get_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("get", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
get_result result = new get_result();
try {
@@ -1183,7 +1204,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
get_slice_args args = new get_slice_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("get_slice", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
get_slice_result result = new get_slice_result();
try {
@@ -1215,7 +1246,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
multiget_args args = new multiget_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("multiget", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
multiget_result result = new multiget_result();
try {
@@ -1247,7 +1288,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
multiget_slice_args args = new multiget_slice_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("multiget_slice", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
multiget_slice_result result = new multiget_slice_result();
try {
@@ -1279,7 +1330,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
get_count_args args = new get_count_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("get_count", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
get_count_result result = new get_count_result();
try {
@@ -1312,7 +1373,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
get_range_slice_args args = new get_range_slice_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("get_range_slice", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
get_range_slice_result result = new get_range_slice_result();
try {
@@ -1344,7 +1415,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
get_range_slices_args args = new get_range_slices_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("get_range_slices", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
get_range_slices_result result = new get_range_slices_result();
try {
@@ -1376,7 +1457,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
insert_args args = new insert_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("insert", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
insert_result result = new insert_result();
try {
@@ -1408,7 +1499,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
batch_insert_args args = new batch_insert_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("batch_insert", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
batch_insert_result result = new batch_insert_result();
try {
@@ -1440,7 +1541,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
remove_args args = new remove_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("remove", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
remove_result result = new remove_result();
try {
@@ -1472,7 +1583,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
batch_mutate_args args = new batch_mutate_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("batch_mutate", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
batch_mutate_result result = new batch_mutate_result();
try {
@@ -1504,7 +1625,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
get_string_property_args args = new get_string_property_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("get_string_property", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
get_string_property_result result = new get_string_property_result();
result.success = iface_.get_string_property(args.property);
@@ -1520,7 +1651,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
get_string_list_property_args args = new get_string_list_property_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("get_string_list_property", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
get_string_list_property_result result = new get_string_list_property_result();
result.success = iface_.get_string_list_property(args.property);
@@ -1536,7 +1677,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
describe_keyspaces_args args = new describe_keyspaces_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("describe_keyspaces", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
describe_keyspaces_result result = new describe_keyspaces_result();
result.success = iface_.describe_keyspaces();
@@ -1552,7 +1703,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
describe_cluster_name_args args = new describe_cluster_name_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("describe_cluster_name", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
describe_cluster_name_result result = new describe_cluster_name_result();
result.success = iface_.describe_cluster_name();
@@ -1568,7 +1729,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
describe_version_args args = new describe_version_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("describe_version", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
describe_version_result result = new describe_version_result();
result.success = iface_.describe_version();
@@ -1584,7 +1755,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
describe_ring_args args = new describe_ring_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("describe_ring", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
describe_ring_result result = new describe_ring_result();
result.success = iface_.describe_ring(args.keyspace);
@@ -1600,7 +1781,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
describe_keyspace_args args = new describe_keyspace_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("describe_keyspace", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
describe_keyspace_result result = new describe_keyspace_result();
try {
@@ -1628,7 +1819,17 @@
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
{
describe_splits_args args = new describe_splits_args();
- args.read(iprot);
+ try {
+ args.read(iprot);
+ } catch (TProtocolException e) {
+ iprot.readMessageEnd();
+ TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
+ oprot.writeMessageBegin(new TMessage("describe_splits", TMessageType.EXCEPTION, seqid));
+ x.write(oprot);
+ oprot.writeMessageEnd();
+ oprot.getTransport().flush();
+ return;
+ }
iprot.readMessageEnd();
describe_splits_result result = new describe_splits_result();
result.success = iface_.describe_splits(args.start_token, args.end_token, args.keys_per_split);
@@ -1905,29 +2106,26 @@
if (field.type == TType.STOP) {
break;
}
- _Fields fieldId = _Fields.findByThriftId(field.id);
- if (fieldId == null) {
- TProtocolUtil.skip(iprot, field.type);
- } else {
- switch (fieldId) {
- case KEYSPACE:
- if (field.type == TType.STRING) {
- this.keyspace = iprot.readString();
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case AUTH_REQUEST:
- if (field.type == TType.STRUCT) {
- this.auth_request = new AuthenticationRequest();
- this.auth_request.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- }
- iprot.readFieldEnd();
+ switch (field.id) {
+ case 1: // KEYSPACE
+ if (field.type == TType.STRING) {
+ this.keyspace = iprot.readString();
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 2: // AUTH_REQUEST
+ if (field.type == TType.STRUCT) {
+ this.auth_request = new AuthenticationRequest();
+ this.auth_request.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ default:
+ TProtocolUtil.skip(iprot, field.type);
}
+ iprot.readFieldEnd();
}
iprot.readStructEnd();
@@ -2251,21 +2449,23 @@
int lastComparison = 0;
login_result typedOther = (login_result)other;
- lastComparison = Boolean.valueOf(isSetAuthnx()).compareTo(isSetAuthnx());
+ lastComparison = Boolean.valueOf(isSetAuthnx()).compareTo(typedOther.isSetAuthnx());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(authnx, typedOther.authnx);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetAuthnx()) { lastComparison = TBaseHelper.compareTo(authnx, typedOther.authnx);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetAuthzx()).compareTo(isSetAuthzx());
+ lastComparison = Boolean.valueOf(isSetAuthzx()).compareTo(typedOther.isSetAuthzx());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(authzx, typedOther.authzx);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetAuthzx()) { lastComparison = TBaseHelper.compareTo(authzx, typedOther.authzx);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
return 0;
}
@@ -2279,30 +2479,27 @@
if (field.type == TType.STOP) {
break;
}
- _Fields fieldId = _Fields.findByThriftId(field.id);
- if (fieldId == null) {
- TProtocolUtil.skip(iprot, field.type);
- } else {
- switch (fieldId) {
- case AUTHNX:
- if (field.type == TType.STRUCT) {
- this.authnx = new AuthenticationException();
- this.authnx.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case AUTHZX:
- if (field.type == TType.STRUCT) {
- this.authzx = new AuthorizationException();
- this.authzx.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- }
- iprot.readFieldEnd();
+ switch (field.id) {
+ case 1: // AUTHNX
+ if (field.type == TType.STRUCT) {
+ this.authnx = new AuthenticationException();
+ this.authnx.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 2: // AUTHZX
+ if (field.type == TType.STRUCT) {
+ this.authzx = new AuthorizationException();
+ this.authzx.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ default:
+ TProtocolUtil.skip(iprot, field.type);
}
+ iprot.readFieldEnd();
}
iprot.readStructEnd();
@@ -2748,37 +2945,41 @@
int lastComparison = 0;
get_args typedOther = (get_args)other;
- lastComparison = Boolean.valueOf(isSetKeyspace()).compareTo(isSetKeyspace());
+ lastComparison = Boolean.valueOf(isSetKeyspace()).compareTo(typedOther.isSetKeyspace());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(keyspace, typedOther.keyspace);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetKeyspace()) { lastComparison = TBaseHelper.compareTo(keyspace, typedOther.keyspace);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetKey()).compareTo(isSetKey());
+ lastComparison = Boolean.valueOf(isSetKey()).compareTo(typedOther.isSetKey());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(key, typedOther.key);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetKey()) { lastComparison = TBaseHelper.compareTo(key, typedOther.key);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetColumn_path()).compareTo(isSetColumn_path());
+ lastComparison = Boolean.valueOf(isSetColumn_path()).compareTo(typedOther.isSetColumn_path());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(column_path, typedOther.column_path);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetColumn_path()) { lastComparison = TBaseHelper.compareTo(column_path, typedOther.column_path);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetConsistency_level()).compareTo(isSetConsistency_level());
+ lastComparison = Boolean.valueOf(isSetConsistency_level()).compareTo(typedOther.isSetConsistency_level());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(consistency_level, typedOther.consistency_level);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetConsistency_level()) { lastComparison = TBaseHelper.compareTo(consistency_level, typedOther.consistency_level);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
return 0;
}
@@ -2792,43 +2993,40 @@
if (field.type == TType.STOP) {
break;
}
- _Fields fieldId = _Fields.findByThriftId(field.id);
- if (fieldId == null) {
- TProtocolUtil.skip(iprot, field.type);
- } else {
- switch (fieldId) {
- case KEYSPACE:
- if (field.type == TType.STRING) {
- this.keyspace = iprot.readString();
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case KEY:
- if (field.type == TType.STRING) {
- this.key = iprot.readString();
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case COLUMN_PATH:
- if (field.type == TType.STRUCT) {
- this.column_path = new ColumnPath();
- this.column_path.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case CONSISTENCY_LEVEL:
- if (field.type == TType.I32) {
- this.consistency_level = ConsistencyLevel.findByValue(iprot.readI32());
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- }
- iprot.readFieldEnd();
+ switch (field.id) {
+ case 1: // KEYSPACE
+ if (field.type == TType.STRING) {
+ this.keyspace = iprot.readString();
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 2: // KEY
+ if (field.type == TType.STRING) {
+ this.key = iprot.readString();
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 3: // COLUMN_PATH
+ if (field.type == TType.STRUCT) {
+ this.column_path = new ColumnPath();
+ this.column_path.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 4: // CONSISTENCY_LEVEL
+ if (field.type == TType.I32) {
+ this.consistency_level = ConsistencyLevel.findByValue(iprot.readI32());
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ default:
+ TProtocolUtil.skip(iprot, field.type);
}
+ iprot.readFieldEnd();
}
iprot.readStructEnd();
@@ -3352,45 +3550,50 @@
int lastComparison = 0;
get_result typedOther = (get_result)other;
- lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(isSetSuccess());
+ lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(success, typedOther.success);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetSuccess()) { lastComparison = TBaseHelper.compareTo(success, typedOther.success);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetIre()).compareTo(isSetIre());
+ lastComparison = Boolean.valueOf(isSetIre()).compareTo(typedOther.isSetIre());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(ire, typedOther.ire);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetIre()) { lastComparison = TBaseHelper.compareTo(ire, typedOther.ire);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetNfe()).compareTo(isSetNfe());
+ lastComparison = Boolean.valueOf(isSetNfe()).compareTo(typedOther.isSetNfe());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(nfe, typedOther.nfe);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetNfe()) { lastComparison = TBaseHelper.compareTo(nfe, typedOther.nfe);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetUe()).compareTo(isSetUe());
+ lastComparison = Boolean.valueOf(isSetUe()).compareTo(typedOther.isSetUe());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(ue, typedOther.ue);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetUe()) { lastComparison = TBaseHelper.compareTo(ue, typedOther.ue);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetTe()).compareTo(isSetTe());
+ lastComparison = Boolean.valueOf(isSetTe()).compareTo(typedOther.isSetTe());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(te, typedOther.te);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetTe()) { lastComparison = TBaseHelper.compareTo(te, typedOther.te);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
return 0;
}
@@ -3404,54 +3607,51 @@
if (field.type == TType.STOP) {
break;
}
- _Fields fieldId = _Fields.findByThriftId(field.id);
- if (fieldId == null) {
- TProtocolUtil.skip(iprot, field.type);
- } else {
- switch (fieldId) {
- case SUCCESS:
- if (field.type == TType.STRUCT) {
- this.success = new ColumnOrSuperColumn();
- this.success.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case IRE:
- if (field.type == TType.STRUCT) {
- this.ire = new InvalidRequestException();
- this.ire.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case NFE:
- if (field.type == TType.STRUCT) {
- this.nfe = new NotFoundException();
- this.nfe.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case UE:
- if (field.type == TType.STRUCT) {
- this.ue = new UnavailableException();
- this.ue.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case TE:
- if (field.type == TType.STRUCT) {
- this.te = new TimedOutException();
- this.te.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- }
- iprot.readFieldEnd();
+ switch (field.id) {
+ case 0: // SUCCESS
+ if (field.type == TType.STRUCT) {
+ this.success = new ColumnOrSuperColumn();
+ this.success.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 1: // IRE
+ if (field.type == TType.STRUCT) {
+ this.ire = new InvalidRequestException();
+ this.ire.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 2: // NFE
+ if (field.type == TType.STRUCT) {
+ this.nfe = new NotFoundException();
+ this.nfe.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 3: // UE
+ if (field.type == TType.STRUCT) {
+ this.ue = new UnavailableException();
+ this.ue.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 4: // TE
+ if (field.type == TType.STRUCT) {
+ this.te = new TimedOutException();
+ this.te.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ default:
+ TProtocolUtil.skip(iprot, field.type);
}
+ iprot.readFieldEnd();
}
iprot.readStructEnd();
@@ -3989,45 +4189,50 @@
int lastComparison = 0;
get_slice_args typedOther = (get_slice_args)other;
- lastComparison = Boolean.valueOf(isSetKeyspace()).compareTo(isSetKeyspace());
+ lastComparison = Boolean.valueOf(isSetKeyspace()).compareTo(typedOther.isSetKeyspace());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(keyspace, typedOther.keyspace);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetKeyspace()) { lastComparison = TBaseHelper.compareTo(keyspace, typedOther.keyspace);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetKey()).compareTo(isSetKey());
+ lastComparison = Boolean.valueOf(isSetKey()).compareTo(typedOther.isSetKey());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(key, typedOther.key);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetKey()) { lastComparison = TBaseHelper.compareTo(key, typedOther.key);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetColumn_parent()).compareTo(isSetColumn_parent());
+ lastComparison = Boolean.valueOf(isSetColumn_parent()).compareTo(typedOther.isSetColumn_parent());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(column_parent, typedOther.column_parent);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetColumn_parent()) { lastComparison = TBaseHelper.compareTo(column_parent, typedOther.column_parent);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetPredicate()).compareTo(isSetPredicate());
+ lastComparison = Boolean.valueOf(isSetPredicate()).compareTo(typedOther.isSetPredicate());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(predicate, typedOther.predicate);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetPredicate()) { lastComparison = TBaseHelper.compareTo(predicate, typedOther.predicate);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetConsistency_level()).compareTo(isSetConsistency_level());
+ lastComparison = Boolean.valueOf(isSetConsistency_level()).compareTo(typedOther.isSetConsistency_level());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(consistency_level, typedOther.consistency_level);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetConsistency_level()) { lastComparison = TBaseHelper.compareTo(consistency_level, typedOther.consistency_level);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
return 0;
}
@@ -4041,51 +4246,48 @@
if (field.type == TType.STOP) {
break;
}
- _Fields fieldId = _Fields.findByThriftId(field.id);
- if (fieldId == null) {
- TProtocolUtil.skip(iprot, field.type);
- } else {
- switch (fieldId) {
- case KEYSPACE:
- if (field.type == TType.STRING) {
- this.keyspace = iprot.readString();
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case KEY:
- if (field.type == TType.STRING) {
- this.key = iprot.readString();
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case COLUMN_PARENT:
- if (field.type == TType.STRUCT) {
- this.column_parent = new ColumnParent();
- this.column_parent.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case PREDICATE:
- if (field.type == TType.STRUCT) {
- this.predicate = new SlicePredicate();
- this.predicate.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case CONSISTENCY_LEVEL:
- if (field.type == TType.I32) {
- this.consistency_level = ConsistencyLevel.findByValue(iprot.readI32());
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- }
- iprot.readFieldEnd();
+ switch (field.id) {
+ case 1: // KEYSPACE
+ if (field.type == TType.STRING) {
+ this.keyspace = iprot.readString();
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 2: // KEY
+ if (field.type == TType.STRING) {
+ this.key = iprot.readString();
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 3: // COLUMN_PARENT
+ if (field.type == TType.STRUCT) {
+ this.column_parent = new ColumnParent();
+ this.column_parent.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 4: // PREDICATE
+ if (field.type == TType.STRUCT) {
+ this.predicate = new SlicePredicate();
+ this.predicate.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 5: // CONSISTENCY_LEVEL
+ if (field.type == TType.I32) {
+ this.consistency_level = ConsistencyLevel.findByValue(iprot.readI32());
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ default:
+ TProtocolUtil.skip(iprot, field.type);
}
+ iprot.readFieldEnd();
}
iprot.readStructEnd();
@@ -4589,37 +4791,41 @@
int lastComparison = 0;
get_slice_result typedOther = (get_slice_result)other;
- lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(isSetSuccess());
+ lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(success, typedOther.success);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetSuccess()) { lastComparison = TBaseHelper.compareTo(success, typedOther.success);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetIre()).compareTo(isSetIre());
+ lastComparison = Boolean.valueOf(isSetIre()).compareTo(typedOther.isSetIre());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(ire, typedOther.ire);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetIre()) { lastComparison = TBaseHelper.compareTo(ire, typedOther.ire);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetUe()).compareTo(isSetUe());
+ lastComparison = Boolean.valueOf(isSetUe()).compareTo(typedOther.isSetUe());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(ue, typedOther.ue);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetUe()) { lastComparison = TBaseHelper.compareTo(ue, typedOther.ue);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetTe()).compareTo(isSetTe());
+ lastComparison = Boolean.valueOf(isSetTe()).compareTo(typedOther.isSetTe());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(te, typedOther.te);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetTe()) { lastComparison = TBaseHelper.compareTo(te, typedOther.te);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
return 0;
}
@@ -4633,56 +4839,53 @@
if (field.type == TType.STOP) {
break;
}
- _Fields fieldId = _Fields.findByThriftId(field.id);
- if (fieldId == null) {
- TProtocolUtil.skip(iprot, field.type);
- } else {
- switch (fieldId) {
- case SUCCESS:
- if (field.type == TType.LIST) {
+ switch (field.id) {
+ case 0: // SUCCESS
+ if (field.type == TType.LIST) {
+ {
+ TList _list21 = iprot.readListBegin();
+ this.success = new ArrayList<ColumnOrSuperColumn>(_list21.size);
+ for (int _i22 = 0; _i22 < _list21.size; ++_i22)
{
- TList _list21 = iprot.readListBegin();
- this.success = new ArrayList<ColumnOrSuperColumn>(_list21.size);
- for (int _i22 = 0; _i22 < _list21.size; ++_i22)
- {
- ColumnOrSuperColumn _elem23;
- _elem23 = new ColumnOrSuperColumn();
- _elem23.read(iprot);
- this.success.add(_elem23);
- }
- iprot.readListEnd();
+ ColumnOrSuperColumn _elem23;
+ _elem23 = new ColumnOrSuperColumn();
+ _elem23.read(iprot);
+ this.success.add(_elem23);
}
- } else {
- TProtocolUtil.skip(iprot, field.type);
+ iprot.readListEnd();
}
- break;
- case IRE:
- if (field.type == TType.STRUCT) {
- this.ire = new InvalidRequestException();
- this.ire.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case UE:
- if (field.type == TType.STRUCT) {
- this.ue = new UnavailableException();
- this.ue.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case TE:
- if (field.type == TType.STRUCT) {
- this.te = new TimedOutException();
- this.te.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- }
- iprot.readFieldEnd();
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 1: // IRE
+ if (field.type == TType.STRUCT) {
+ this.ire = new InvalidRequestException();
+ this.ire.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 2: // UE
+ if (field.type == TType.STRUCT) {
+ this.ue = new UnavailableException();
+ this.ue.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 3: // TE
+ if (field.type == TType.STRUCT) {
+ this.te = new TimedOutException();
+ this.te.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ default:
+ TProtocolUtil.skip(iprot, field.type);
}
+ iprot.readFieldEnd();
}
iprot.readStructEnd();
@@ -5179,37 +5382,41 @@
int lastComparison = 0;
multiget_args typedOther = (multiget_args)other;
- lastComparison = Boolean.valueOf(isSetKeyspace()).compareTo(isSetKeyspace());
+ lastComparison = Boolean.valueOf(isSetKeyspace()).compareTo(typedOther.isSetKeyspace());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(keyspace, typedOther.keyspace);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetKeyspace()) { lastComparison = TBaseHelper.compareTo(keyspace, typedOther.keyspace);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetKeys()).compareTo(isSetKeys());
+ lastComparison = Boolean.valueOf(isSetKeys()).compareTo(typedOther.isSetKeys());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(keys, typedOther.keys);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetKeys()) { lastComparison = TBaseHelper.compareTo(keys, typedOther.keys);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetColumn_path()).compareTo(isSetColumn_path());
+ lastComparison = Boolean.valueOf(isSetColumn_path()).compareTo(typedOther.isSetColumn_path());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(column_path, typedOther.column_path);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetColumn_path()) { lastComparison = TBaseHelper.compareTo(column_path, typedOther.column_path);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetConsistency_level()).compareTo(isSetConsistency_level());
+ lastComparison = Boolean.valueOf(isSetConsistency_level()).compareTo(typedOther.isSetConsistency_level());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(consistency_level, typedOther.consistency_level);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetConsistency_level()) { lastComparison = TBaseHelper.compareTo(consistency_level, typedOther.consistency_level);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
return 0;
}
@@ -5223,53 +5430,50 @@
if (field.type == TType.STOP) {
break;
}
- _Fields fieldId = _Fields.findByThriftId(field.id);
- if (fieldId == null) {
- TProtocolUtil.skip(iprot, field.type);
- } else {
- switch (fieldId) {
- case KEYSPACE:
- if (field.type == TType.STRING) {
- this.keyspace = iprot.readString();
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case KEYS:
- if (field.type == TType.LIST) {
+ switch (field.id) {
+ case 1: // KEYSPACE
+ if (field.type == TType.STRING) {
+ this.keyspace = iprot.readString();
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 2: // KEYS
+ if (field.type == TType.LIST) {
+ {
+ TList _list25 = iprot.readListBegin();
+ this.keys = new ArrayList<String>(_list25.size);
+ for (int _i26 = 0; _i26 < _list25.size; ++_i26)
{
- TList _list25 = iprot.readListBegin();
- this.keys = new ArrayList<String>(_list25.size);
- for (int _i26 = 0; _i26 < _list25.size; ++_i26)
- {
- String _elem27;
- _elem27 = iprot.readString();
- this.keys.add(_elem27);
- }
- iprot.readListEnd();
+ String _elem27;
+ _elem27 = iprot.readString();
+ this.keys.add(_elem27);
}
- } else {
- TProtocolUtil.skip(iprot, field.type);
+ iprot.readListEnd();
}
- break;
- case COLUMN_PATH:
- if (field.type == TType.STRUCT) {
- this.column_path = new ColumnPath();
- this.column_path.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case CONSISTENCY_LEVEL:
- if (field.type == TType.I32) {
- this.consistency_level = ConsistencyLevel.findByValue(iprot.readI32());
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- }
- iprot.readFieldEnd();
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 3: // COLUMN_PATH
+ if (field.type == TType.STRUCT) {
+ this.column_path = new ColumnPath();
+ this.column_path.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 4: // CONSISTENCY_LEVEL
+ if (field.type == TType.I32) {
+ this.consistency_level = ConsistencyLevel.findByValue(iprot.readI32());
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ default:
+ TProtocolUtil.skip(iprot, field.type);
}
+ iprot.readFieldEnd();
}
iprot.readStructEnd();
@@ -5770,58 +5974,55 @@
if (field.type == TType.STOP) {
break;
}
- _Fields fieldId = _Fields.findByThriftId(field.id);
- if (fieldId == null) {
- TProtocolUtil.skip(iprot, field.type);
- } else {
- switch (fieldId) {
- case SUCCESS:
- if (field.type == TType.MAP) {
+ switch (field.id) {
+ case 0: // SUCCESS
+ if (field.type == TType.MAP) {
+ {
+ TMap _map29 = iprot.readMapBegin();
+ this.success = new HashMap<String,ColumnOrSuperColumn>(2*_map29.size);
+ for (int _i30 = 0; _i30 < _map29.size; ++_i30)
{
- TMap _map29 = iprot.readMapBegin();
- this.success = new HashMap<String,ColumnOrSuperColumn>(2*_map29.size);
- for (int _i30 = 0; _i30 < _map29.size; ++_i30)
- {
- String _key31;
- ColumnOrSuperColumn _val32;
- _key31 = iprot.readString();
- _val32 = new ColumnOrSuperColumn();
- _val32.read(iprot);
- this.success.put(_key31, _val32);
- }
- iprot.readMapEnd();
+ String _key31;
+ ColumnOrSuperColumn _val32;
+ _key31 = iprot.readString();
+ _val32 = new ColumnOrSuperColumn();
+ _val32.read(iprot);
+ this.success.put(_key31, _val32);
}
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case IRE:
- if (field.type == TType.STRUCT) {
- this.ire = new InvalidRequestException();
- this.ire.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
+ iprot.readMapEnd();
}
- break;
- case UE:
- if (field.type == TType.STRUCT) {
- this.ue = new UnavailableException();
- this.ue.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case TE:
- if (field.type == TType.STRUCT) {
- this.te = new TimedOutException();
- this.te.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- }
- iprot.readFieldEnd();
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 1: // IRE
+ if (field.type == TType.STRUCT) {
+ this.ire = new InvalidRequestException();
+ this.ire.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 2: // UE
+ if (field.type == TType.STRUCT) {
+ this.ue = new UnavailableException();
+ this.ue.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 3: // TE
+ if (field.type == TType.STRUCT) {
+ this.te = new TimedOutException();
+ this.te.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ default:
+ TProtocolUtil.skip(iprot, field.type);
}
+ iprot.readFieldEnd();
}
iprot.readStructEnd();
@@ -6375,45 +6576,50 @@
int lastComparison = 0;
multiget_slice_args typedOther = (multiget_slice_args)other;
- lastComparison = Boolean.valueOf(isSetKeyspace()).compareTo(isSetKeyspace());
+ lastComparison = Boolean.valueOf(isSetKeyspace()).compareTo(typedOther.isSetKeyspace());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(keyspace, typedOther.keyspace);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetKeyspace()) { lastComparison = TBaseHelper.compareTo(keyspace, typedOther.keyspace);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetKeys()).compareTo(isSetKeys());
+ lastComparison = Boolean.valueOf(isSetKeys()).compareTo(typedOther.isSetKeys());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(keys, typedOther.keys);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetKeys()) { lastComparison = TBaseHelper.compareTo(keys, typedOther.keys);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetColumn_parent()).compareTo(isSetColumn_parent());
+ lastComparison = Boolean.valueOf(isSetColumn_parent()).compareTo(typedOther.isSetColumn_parent());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(column_parent, typedOther.column_parent);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetColumn_parent()) { lastComparison = TBaseHelper.compareTo(column_parent, typedOther.column_parent);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetPredicate()).compareTo(isSetPredicate());
+ lastComparison = Boolean.valueOf(isSetPredicate()).compareTo(typedOther.isSetPredicate());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(predicate, typedOther.predicate);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetPredicate()) { lastComparison = TBaseHelper.compareTo(predicate, typedOther.predicate);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetConsistency_level()).compareTo(isSetConsistency_level());
+ lastComparison = Boolean.valueOf(isSetConsistency_level()).compareTo(typedOther.isSetConsistency_level());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(consistency_level, typedOther.consistency_level);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetConsistency_level()) { lastComparison = TBaseHelper.compareTo(consistency_level, typedOther.consistency_level);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
return 0;
}
@@ -6427,61 +6633,58 @@
if (field.type == TType.STOP) {
break;
}
- _Fields fieldId = _Fields.findByThriftId(field.id);
- if (fieldId == null) {
- TProtocolUtil.skip(iprot, field.type);
- } else {
- switch (fieldId) {
- case KEYSPACE:
- if (field.type == TType.STRING) {
- this.keyspace = iprot.readString();
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case KEYS:
- if (field.type == TType.LIST) {
+ switch (field.id) {
+ case 1: // KEYSPACE
+ if (field.type == TType.STRING) {
+ this.keyspace = iprot.readString();
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 2: // KEYS
+ if (field.type == TType.LIST) {
+ {
+ TList _list34 = iprot.readListBegin();
+ this.keys = new ArrayList<String>(_list34.size);
+ for (int _i35 = 0; _i35 < _list34.size; ++_i35)
{
- TList _list34 = iprot.readListBegin();
- this.keys = new ArrayList<String>(_list34.size);
- for (int _i35 = 0; _i35 < _list34.size; ++_i35)
- {
- String _elem36;
- _elem36 = iprot.readString();
- this.keys.add(_elem36);
- }
- iprot.readListEnd();
+ String _elem36;
+ _elem36 = iprot.readString();
+ this.keys.add(_elem36);
}
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case COLUMN_PARENT:
- if (field.type == TType.STRUCT) {
- this.column_parent = new ColumnParent();
- this.column_parent.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case PREDICATE:
- if (field.type == TType.STRUCT) {
- this.predicate = new SlicePredicate();
- this.predicate.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
+ iprot.readListEnd();
}
- break;
- case CONSISTENCY_LEVEL:
- if (field.type == TType.I32) {
- this.consistency_level = ConsistencyLevel.findByValue(iprot.readI32());
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- }
- iprot.readFieldEnd();
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 3: // COLUMN_PARENT
+ if (field.type == TType.STRUCT) {
+ this.column_parent = new ColumnParent();
+ this.column_parent.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 4: // PREDICATE
+ if (field.type == TType.STRUCT) {
+ this.predicate = new SlicePredicate();
+ this.predicate.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 5: // CONSISTENCY_LEVEL
+ if (field.type == TType.I32) {
+ this.consistency_level = ConsistencyLevel.findByValue(iprot.readI32());
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ default:
+ TProtocolUtil.skip(iprot, field.type);
}
+ iprot.readFieldEnd();
}
iprot.readStructEnd();
@@ -7002,68 +7205,65 @@
if (field.type == TType.STOP) {
break;
}
- _Fields fieldId = _Fields.findByThriftId(field.id);
- if (fieldId == null) {
- TProtocolUtil.skip(iprot, field.type);
- } else {
- switch (fieldId) {
- case SUCCESS:
- if (field.type == TType.MAP) {
+ switch (field.id) {
+ case 0: // SUCCESS
+ if (field.type == TType.MAP) {
+ {
+ TMap _map38 = iprot.readMapBegin();
+ this.success = new HashMap<String,List<ColumnOrSuperColumn>>(2*_map38.size);
+ for (int _i39 = 0; _i39 < _map38.size; ++_i39)
{
- TMap _map38 = iprot.readMapBegin();
- this.success = new HashMap<String,List<ColumnOrSuperColumn>>(2*_map38.size);
- for (int _i39 = 0; _i39 < _map38.size; ++_i39)
+ String _key40;
+ List<ColumnOrSuperColumn> _val41;
+ _key40 = iprot.readString();
{
- String _key40;
- List<ColumnOrSuperColumn> _val41;
- _key40 = iprot.readString();
+ TList _list42 = iprot.readListBegin();
+ _val41 = new ArrayList<ColumnOrSuperColumn>(_list42.size);
+ for (int _i43 = 0; _i43 < _list42.size; ++_i43)
{
- TList _list42 = iprot.readListBegin();
- _val41 = new ArrayList<ColumnOrSuperColumn>(_list42.size);
- for (int _i43 = 0; _i43 < _list42.size; ++_i43)
- {
- ColumnOrSuperColumn _elem44;
- _elem44 = new ColumnOrSuperColumn();
- _elem44.read(iprot);
- _val41.add(_elem44);
- }
- iprot.readListEnd();
+ ColumnOrSuperColumn _elem44;
+ _elem44 = new ColumnOrSuperColumn();
+ _elem44.read(iprot);
+ _val41.add(_elem44);
}
- this.success.put(_key40, _val41);
+ iprot.readListEnd();
}
- iprot.readMapEnd();
+ this.success.put(_key40, _val41);
}
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case IRE:
- if (field.type == TType.STRUCT) {
- this.ire = new InvalidRequestException();
- this.ire.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case UE:
- if (field.type == TType.STRUCT) {
- this.ue = new UnavailableException();
- this.ue.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
+ iprot.readMapEnd();
}
- break;
- case TE:
- if (field.type == TType.STRUCT) {
- this.te = new TimedOutException();
- this.te.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- }
- iprot.readFieldEnd();
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 1: // IRE
+ if (field.type == TType.STRUCT) {
+ this.ire = new InvalidRequestException();
+ this.ire.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 2: // UE
+ if (field.type == TType.STRUCT) {
+ this.ue = new UnavailableException();
+ this.ue.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 3: // TE
+ if (field.type == TType.STRUCT) {
+ this.te = new TimedOutException();
+ this.te.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ default:
+ TProtocolUtil.skip(iprot, field.type);
}
+ iprot.readFieldEnd();
}
iprot.readStructEnd();
@@ -7548,37 +7748,41 @@
int lastComparison = 0;
get_count_args typedOther = (get_count_args)other;
- lastComparison = Boolean.valueOf(isSetKeyspace()).compareTo(isSetKeyspace());
+ lastComparison = Boolean.valueOf(isSetKeyspace()).compareTo(typedOther.isSetKeyspace());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(keyspace, typedOther.keyspace);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetKeyspace()) { lastComparison = TBaseHelper.compareTo(keyspace, typedOther.keyspace);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetKey()).compareTo(isSetKey());
+ lastComparison = Boolean.valueOf(isSetKey()).compareTo(typedOther.isSetKey());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(key, typedOther.key);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetKey()) { lastComparison = TBaseHelper.compareTo(key, typedOther.key);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetColumn_parent()).compareTo(isSetColumn_parent());
+ lastComparison = Boolean.valueOf(isSetColumn_parent()).compareTo(typedOther.isSetColumn_parent());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(column_parent, typedOther.column_parent);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetColumn_parent()) { lastComparison = TBaseHelper.compareTo(column_parent, typedOther.column_parent);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetConsistency_level()).compareTo(isSetConsistency_level());
+ lastComparison = Boolean.valueOf(isSetConsistency_level()).compareTo(typedOther.isSetConsistency_level());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(consistency_level, typedOther.consistency_level);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetConsistency_level()) { lastComparison = TBaseHelper.compareTo(consistency_level, typedOther.consistency_level);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
return 0;
}
@@ -7592,43 +7796,40 @@
if (field.type == TType.STOP) {
break;
}
- _Fields fieldId = _Fields.findByThriftId(field.id);
- if (fieldId == null) {
- TProtocolUtil.skip(iprot, field.type);
- } else {
- switch (fieldId) {
- case KEYSPACE:
- if (field.type == TType.STRING) {
- this.keyspace = iprot.readString();
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case KEY:
- if (field.type == TType.STRING) {
- this.key = iprot.readString();
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case COLUMN_PARENT:
- if (field.type == TType.STRUCT) {
- this.column_parent = new ColumnParent();
- this.column_parent.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case CONSISTENCY_LEVEL:
- if (field.type == TType.I32) {
- this.consistency_level = ConsistencyLevel.findByValue(iprot.readI32());
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- }
- iprot.readFieldEnd();
+ switch (field.id) {
+ case 1: // KEYSPACE
+ if (field.type == TType.STRING) {
+ this.keyspace = iprot.readString();
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 2: // KEY
+ if (field.type == TType.STRING) {
+ this.key = iprot.readString();
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 3: // COLUMN_PARENT
+ if (field.type == TType.STRUCT) {
+ this.column_parent = new ColumnParent();
+ this.column_parent.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 4: // CONSISTENCY_LEVEL
+ if (field.type == TType.I32) {
+ this.consistency_level = ConsistencyLevel.findByValue(iprot.readI32());
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ default:
+ TProtocolUtil.skip(iprot, field.type);
}
+ iprot.readFieldEnd();
}
iprot.readStructEnd();
@@ -8098,37 +8299,41 @@
int lastComparison = 0;
get_count_result typedOther = (get_count_result)other;
- lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(isSetSuccess());
+ lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(success, typedOther.success);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetSuccess()) { lastComparison = TBaseHelper.compareTo(success, typedOther.success);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetIre()).compareTo(isSetIre());
+ lastComparison = Boolean.valueOf(isSetIre()).compareTo(typedOther.isSetIre());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(ire, typedOther.ire);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetIre()) { lastComparison = TBaseHelper.compareTo(ire, typedOther.ire);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetUe()).compareTo(isSetUe());
+ lastComparison = Boolean.valueOf(isSetUe()).compareTo(typedOther.isSetUe());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(ue, typedOther.ue);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetUe()) { lastComparison = TBaseHelper.compareTo(ue, typedOther.ue);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetTe()).compareTo(isSetTe());
+ lastComparison = Boolean.valueOf(isSetTe()).compareTo(typedOther.isSetTe());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(te, typedOther.te);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetTe()) { lastComparison = TBaseHelper.compareTo(te, typedOther.te);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
return 0;
}
@@ -8142,46 +8347,43 @@
if (field.type == TType.STOP) {
break;
}
- _Fields fieldId = _Fields.findByThriftId(field.id);
- if (fieldId == null) {
- TProtocolUtil.skip(iprot, field.type);
- } else {
- switch (fieldId) {
- case SUCCESS:
- if (field.type == TType.I32) {
- this.success = iprot.readI32();
- setSuccessIsSet(true);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case IRE:
- if (field.type == TType.STRUCT) {
- this.ire = new InvalidRequestException();
- this.ire.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case UE:
- if (field.type == TType.STRUCT) {
- this.ue = new UnavailableException();
- this.ue.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case TE:
- if (field.type == TType.STRUCT) {
- this.te = new TimedOutException();
- this.te.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- }
- iprot.readFieldEnd();
+ switch (field.id) {
+ case 0: // SUCCESS
+ if (field.type == TType.I32) {
+ this.success = iprot.readI32();
+ setSuccessIsSet(true);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 1: // IRE
+ if (field.type == TType.STRUCT) {
+ this.ire = new InvalidRequestException();
+ this.ire.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 2: // UE
+ if (field.type == TType.STRUCT) {
+ this.ue = new UnavailableException();
+ this.ue.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 3: // TE
+ if (field.type == TType.STRUCT) {
+ this.te = new TimedOutException();
+ this.te.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ default:
+ TProtocolUtil.skip(iprot, field.type);
}
+ iprot.readFieldEnd();
}
iprot.readStructEnd();
@@ -8823,61 +9025,68 @@
int lastComparison = 0;
get_range_slice_args typedOther = (get_range_slice_args)other;
- lastComparison = Boolean.valueOf(isSetKeyspace()).compareTo(isSetKeyspace());
+ lastComparison = Boolean.valueOf(isSetKeyspace()).compareTo(typedOther.isSetKeyspace());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(keyspace, typedOther.keyspace);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetKeyspace()) { lastComparison = TBaseHelper.compareTo(keyspace, typedOther.keyspace);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetColumn_parent()).compareTo(isSetColumn_parent());
+ lastComparison = Boolean.valueOf(isSetColumn_parent()).compareTo(typedOther.isSetColumn_parent());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(column_parent, typedOther.column_parent);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetColumn_parent()) { lastComparison = TBaseHelper.compareTo(column_parent, typedOther.column_parent);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetPredicate()).compareTo(isSetPredicate());
+ lastComparison = Boolean.valueOf(isSetPredicate()).compareTo(typedOther.isSetPredicate());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(predicate, typedOther.predicate);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetPredicate()) { lastComparison = TBaseHelper.compareTo(predicate, typedOther.predicate);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetStart_key()).compareTo(isSetStart_key());
+ lastComparison = Boolean.valueOf(isSetStart_key()).compareTo(typedOther.isSetStart_key());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(start_key, typedOther.start_key);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetStart_key()) { lastComparison = TBaseHelper.compareTo(start_key, typedOther.start_key);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetFinish_key()).compareTo(isSetFinish_key());
+ lastComparison = Boolean.valueOf(isSetFinish_key()).compareTo(typedOther.isSetFinish_key());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(finish_key, typedOther.finish_key);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetFinish_key()) { lastComparison = TBaseHelper.compareTo(finish_key, typedOther.finish_key);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetRow_count()).compareTo(isSetRow_count());
+ lastComparison = Boolean.valueOf(isSetRow_count()).compareTo(typedOther.isSetRow_count());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(row_count, typedOther.row_count);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetRow_count()) { lastComparison = TBaseHelper.compareTo(row_count, typedOther.row_count);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetConsistency_level()).compareTo(isSetConsistency_level());
+ lastComparison = Boolean.valueOf(isSetConsistency_level()).compareTo(typedOther.isSetConsistency_level());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(consistency_level, typedOther.consistency_level);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetConsistency_level()) { lastComparison = TBaseHelper.compareTo(consistency_level, typedOther.consistency_level);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
return 0;
}
@@ -8891,66 +9100,63 @@
if (field.type == TType.STOP) {
break;
}
- _Fields fieldId = _Fields.findByThriftId(field.id);
- if (fieldId == null) {
- TProtocolUtil.skip(iprot, field.type);
- } else {
- switch (fieldId) {
- case KEYSPACE:
- if (field.type == TType.STRING) {
- this.keyspace = iprot.readString();
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case COLUMN_PARENT:
- if (field.type == TType.STRUCT) {
- this.column_parent = new ColumnParent();
- this.column_parent.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case PREDICATE:
- if (field.type == TType.STRUCT) {
- this.predicate = new SlicePredicate();
- this.predicate.read(iprot);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case START_KEY:
- if (field.type == TType.STRING) {
- this.start_key = iprot.readString();
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case FINISH_KEY:
- if (field.type == TType.STRING) {
- this.finish_key = iprot.readString();
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case ROW_COUNT:
- if (field.type == TType.I32) {
- this.row_count = iprot.readI32();
- setRow_countIsSet(true);
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- case CONSISTENCY_LEVEL:
- if (field.type == TType.I32) {
- this.consistency_level = ConsistencyLevel.findByValue(iprot.readI32());
- } else {
- TProtocolUtil.skip(iprot, field.type);
- }
- break;
- }
- iprot.readFieldEnd();
+ switch (field.id) {
+ case 1: // KEYSPACE
+ if (field.type == TType.STRING) {
+ this.keyspace = iprot.readString();
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 2: // COLUMN_PARENT
+ if (field.type == TType.STRUCT) {
+ this.column_parent = new ColumnParent();
+ this.column_parent.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 3: // PREDICATE
+ if (field.type == TType.STRUCT) {
+ this.predicate = new SlicePredicate();
+ this.predicate.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 4: // START_KEY
+ if (field.type == TType.STRING) {
+ this.start_key = iprot.readString();
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 5: // FINISH_KEY
+ if (field.type == TType.STRING) {
+ this.finish_key = iprot.readString();
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 6: // ROW_COUNT
+ if (field.type == TType.I32) {
+ this.row_count = iprot.readI32();
+ setRow_countIsSet(true);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ case 7: // CONSISTENCY_LEVEL
+ if (field.type == TType.I32) {
+ this.consistency_level = ConsistencyLevel.findByValue(iprot.readI32());
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
+ default:
+ TProtocolUtil.skip(iprot, field.type);
}
+ iprot.readFieldEnd();
}
iprot.readStructEnd();
@@ -9481,37 +9687,41 @@
int lastComparison = 0;
get_range_slice_result typedOther = (get_range_slice_result)other;
- lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(isSetSuccess());
+ lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(typedOther.isSetSuccess());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(success, typedOther.success);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetSuccess()) { lastComparison = TBaseHelper.compareTo(success, typedOther.success);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetIre()).compareTo(isSetIre());
+ lastComparison = Boolean.valueOf(isSetIre()).compareTo(typedOther.isSetIre());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(ire, typedOther.ire);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetIre()) { lastComparison = TBaseHelper.compareTo(ire, typedOther.ire);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetUe()).compareTo(isSetUe());
+ lastComparison = Boolean.valueOf(isSetUe()).compareTo(typedOther.isSetUe());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(ue, typedOther.ue);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetUe()) { lastComparison = TBaseHelper.compareTo(ue, typedOther.ue);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
- lastComparison = Boolean.valueOf(isSetTe()).compareTo(isSetTe());
+ lastComparison = Boolean.valueOf(isSetTe()).compareTo(typedOther.isSetTe());
if (lastComparison != 0) {
return lastComparison;
}
- lastComparison = TBaseHelper.compareTo(te, typedOther.te);
- if (lastComparison != 0) {
- return lastComparison;
+ if (isSetTe()) { lastComparison = TBaseHelper.compareTo(te, typedOther.te);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
}
return 0;
}
@@ -9525,56 +9735,53 @@
if (field.type == TType.STOP) {
break;
}
- _Fields fieldId = _Fields.findByThriftId(field.id);
- if (fieldId == null) {
- TProtocolUtil.skip(iprot, field.type);
- } else {
- switch (fieldId) {
- case SUCCESS:
- if (field.type == TType.LIST) {
+ switch (field.id) {
+ case 0: // SUCCESS
+ if (field.type == TType.LIST) {
+ {
+ TList _list47 = iprot.readListBegin();
+ this.success = new ArrayList<KeySlice>(_list47.size);
+ for (int _i48 = 0; _i48 < _list47.size; ++_i48)
{
- TList _list47 = iprot.readListBegin();
- this.success = new ArrayList<KeySlice>(_list47.size);
- for (int _i48 = 0; _i48 < _list47.size; ++_i48)
- {
- KeySlice _elem49;
- _elem49 = new KeySlice();
- _elem49.read(iprot);
[... 2318 lines stripped ...]