Modified: cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java URL: http://svn.apache.org/viewvc/cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java?rev=1026200&r1=1026199&r2=1026200&view=diff ============================================================================== --- cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java (original) +++ cassandra/trunk/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java Fri Oct 22 03:23:26 2010 @@ -37,6 +37,7 @@ import java.util.HashSet; import java.util.EnumSet; import java.util.Collections; import java.util.BitSet; +import java.nio.ByteBuffer; import java.util.Arrays; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -63,7 +64,7 @@ public class Cassandra { * @param column_path * @param consistency_level */ - public ColumnOrSuperColumn get(byte[] key, ColumnPath column_path, ConsistencyLevel consistency_level) throws InvalidRequestException, NotFoundException, UnavailableException, TimedOutException, TException; + public ColumnOrSuperColumn get(ByteBuffer key, ColumnPath column_path, ConsistencyLevel consistency_level) throws InvalidRequestException, NotFoundException, UnavailableException, TimedOutException, TException; /** * Get the group of columns contained by column_parent (either a ColumnFamily name or a ColumnFamily/SuperColumn name @@ -74,7 +75,7 @@ public class Cassandra { * @param predicate * @param consistency_level */ - public List get_slice(byte[] key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException; + public List get_slice(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException; /** * returns the number of columns matching predicate for a particular key, @@ -85,7 +86,7 @@ public class Cassandra { * @param predicate * @param consistency_level */ - public int get_count(byte[] key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException; + public int get_count(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException; /** * Performs a get_slice for column_parent and predicate for the given keys in parallel. @@ -95,7 +96,7 @@ public class Cassandra { * @param predicate * @param consistency_level */ - public Map> multiget_slice(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException; + public Map> multiget_slice(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException; /** * Perform a get_count in parallel on the given list keys. The return value maps keys to the count found. @@ -105,7 +106,7 @@ public class Cassandra { * @param predicate * @param consistency_level */ - public Map multiget_count(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException; + public Map multiget_count(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException; /** * returns a subset of columns for a contiguous range of keys. @@ -135,7 +136,7 @@ public class Cassandra { * @param column * @param consistency_level */ - public void insert(byte[] key, ColumnParent column_parent, Column column, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException; + public void insert(ByteBuffer key, ColumnParent column_parent, Column column, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException; /** * Remove data from the row specified by key at the granularity specified by column_path, and the given timestamp. Note @@ -147,7 +148,7 @@ public class Cassandra { * @param timestamp * @param consistency_level */ - public void remove(byte[] key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException; + public void remove(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException; /** * Mutate many columns or super columns for many row keys. See also: Mutation. @@ -158,7 +159,7 @@ public class Cassandra { * @param mutation_map * @param consistency_level */ - public void batch_mutate(Map>> mutation_map, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException; + public void batch_mutate(Map>> mutation_map, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException; /** * Truncate will mark and entire column family as deleted. @@ -289,25 +290,25 @@ public class Cassandra { public void set_keyspace(String keyspace, AsyncMethodCallback resultHandler) throws TException; - public void get(byte[] key, ColumnPath column_path, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException; + public void get(ByteBuffer key, ColumnPath column_path, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException; - public void get_slice(byte[] key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException; + public void get_slice(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException; - public void get_count(byte[] key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException; + public void get_count(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException; - public void multiget_slice(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException; + public void multiget_slice(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException; - public void multiget_count(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException; + public void multiget_count(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException; public void get_range_slices(ColumnParent column_parent, SlicePredicate predicate, KeyRange range, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException; public void get_indexed_slices(ColumnParent column_parent, IndexClause index_clause, SlicePredicate column_predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException; - public void insert(byte[] key, ColumnParent column_parent, Column column, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException; + public void insert(ByteBuffer key, ColumnParent column_parent, Column column, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException; - public void remove(byte[] key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException; + public void remove(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException; - public void batch_mutate(Map>> mutation_map, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException; + public void batch_mutate(Map>> mutation_map, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException; public void truncate(String cfname, AsyncMethodCallback resultHandler) throws TException; @@ -455,13 +456,13 @@ public class Cassandra { return; } - public ColumnOrSuperColumn get(byte[] key, ColumnPath column_path, ConsistencyLevel consistency_level) throws InvalidRequestException, NotFoundException, UnavailableException, TimedOutException, TException + public ColumnOrSuperColumn get(ByteBuffer key, ColumnPath column_path, ConsistencyLevel consistency_level) throws InvalidRequestException, NotFoundException, UnavailableException, TimedOutException, TException { send_get(key, column_path, consistency_level); return recv_get(); } - public void send_get(byte[] key, ColumnPath column_path, ConsistencyLevel consistency_level) throws TException + public void send_get(ByteBuffer key, ColumnPath column_path, ConsistencyLevel consistency_level) throws TException { oprot_.writeMessageBegin(new TMessage("get", TMessageType.CALL, ++seqid_)); get_args args = new get_args(); @@ -505,13 +506,13 @@ public class Cassandra { throw new TApplicationException(TApplicationException.MISSING_RESULT, "get failed: unknown result"); } - public List get_slice(byte[] key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException + public List get_slice(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException { send_get_slice(key, column_parent, predicate, consistency_level); return recv_get_slice(); } - public void send_get_slice(byte[] key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws TException + public void send_get_slice(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws TException { oprot_.writeMessageBegin(new TMessage("get_slice", TMessageType.CALL, ++seqid_)); get_slice_args args = new get_slice_args(); @@ -553,13 +554,13 @@ public class Cassandra { throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_slice failed: unknown result"); } - public int get_count(byte[] key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException + public int get_count(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException { send_get_count(key, column_parent, predicate, consistency_level); return recv_get_count(); } - public void send_get_count(byte[] key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws TException + public void send_get_count(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws TException { oprot_.writeMessageBegin(new TMessage("get_count", TMessageType.CALL, ++seqid_)); get_count_args args = new get_count_args(); @@ -601,13 +602,13 @@ public class Cassandra { throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_count failed: unknown result"); } - public Map> multiget_slice(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException + public Map> multiget_slice(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException { send_multiget_slice(keys, column_parent, predicate, consistency_level); return recv_multiget_slice(); } - public void send_multiget_slice(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws TException + public void send_multiget_slice(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws TException { oprot_.writeMessageBegin(new TMessage("multiget_slice", TMessageType.CALL, ++seqid_)); multiget_slice_args args = new multiget_slice_args(); @@ -620,7 +621,7 @@ public class Cassandra { oprot_.getTransport().flush(); } - public Map> recv_multiget_slice() throws InvalidRequestException, UnavailableException, TimedOutException, TException + public Map> recv_multiget_slice() throws InvalidRequestException, UnavailableException, TimedOutException, TException { TMessage msg = iprot_.readMessageBegin(); if (msg.type == TMessageType.EXCEPTION) { @@ -649,13 +650,13 @@ public class Cassandra { throw new TApplicationException(TApplicationException.MISSING_RESULT, "multiget_slice failed: unknown result"); } - public Map multiget_count(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException + public Map multiget_count(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException { send_multiget_count(keys, column_parent, predicate, consistency_level); return recv_multiget_count(); } - public void send_multiget_count(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws TException + public void send_multiget_count(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws TException { oprot_.writeMessageBegin(new TMessage("multiget_count", TMessageType.CALL, ++seqid_)); multiget_count_args args = new multiget_count_args(); @@ -668,7 +669,7 @@ public class Cassandra { oprot_.getTransport().flush(); } - public Map recv_multiget_count() throws InvalidRequestException, UnavailableException, TimedOutException, TException + public Map recv_multiget_count() throws InvalidRequestException, UnavailableException, TimedOutException, TException { TMessage msg = iprot_.readMessageBegin(); if (msg.type == TMessageType.EXCEPTION) { @@ -793,13 +794,13 @@ public class Cassandra { throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_indexed_slices failed: unknown result"); } - public void insert(byte[] key, ColumnParent column_parent, Column column, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException + public void insert(ByteBuffer key, ColumnParent column_parent, Column column, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException { send_insert(key, column_parent, column, consistency_level); recv_insert(); } - public void send_insert(byte[] key, ColumnParent column_parent, Column column, ConsistencyLevel consistency_level) throws TException + public void send_insert(ByteBuffer key, ColumnParent column_parent, Column column, ConsistencyLevel consistency_level) throws TException { oprot_.writeMessageBegin(new TMessage("insert", TMessageType.CALL, ++seqid_)); insert_args args = new insert_args(); @@ -838,13 +839,13 @@ public class Cassandra { return; } - public void remove(byte[] key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException + public void remove(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException { send_remove(key, column_path, timestamp, consistency_level); recv_remove(); } - public void send_remove(byte[] key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level) throws TException + public void send_remove(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level) throws TException { oprot_.writeMessageBegin(new TMessage("remove", TMessageType.CALL, ++seqid_)); remove_args args = new remove_args(); @@ -883,13 +884,13 @@ public class Cassandra { return; } - public void batch_mutate(Map>> mutation_map, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException + public void batch_mutate(Map>> mutation_map, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException { send_batch_mutate(mutation_map, consistency_level); recv_batch_mutate(); } - public void send_batch_mutate(Map>> mutation_map, ConsistencyLevel consistency_level) throws TException + public void send_batch_mutate(Map>> mutation_map, ConsistencyLevel consistency_level) throws TException { oprot_.writeMessageBegin(new TMessage("batch_mutate", TMessageType.CALL, ++seqid_)); batch_mutate_args args = new batch_mutate_args(); @@ -1615,17 +1616,17 @@ public class Cassandra { } } - public void get(byte[] key, ColumnPath column_path, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException { + public void get(ByteBuffer key, ColumnPath column_path, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException { checkReady(); get_call method_call = new get_call(key, column_path, consistency_level, resultHandler, this, protocolFactory, transport); manager.call(method_call); } public static class get_call extends TAsyncMethodCall { - private byte[] key; + private ByteBuffer key; private ColumnPath column_path; private ConsistencyLevel consistency_level; - public get_call(byte[] key, ColumnPath column_path, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException { + public get_call(ByteBuffer key, ColumnPath column_path, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); this.key = key; this.column_path = column_path; @@ -1652,18 +1653,18 @@ public class Cassandra { } } - public void get_slice(byte[] key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException { + public void get_slice(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException { checkReady(); get_slice_call method_call = new get_slice_call(key, column_parent, predicate, consistency_level, resultHandler, this, protocolFactory, transport); manager.call(method_call); } public static class get_slice_call extends TAsyncMethodCall { - private byte[] key; + private ByteBuffer key; private ColumnParent column_parent; private SlicePredicate predicate; private ConsistencyLevel consistency_level; - public get_slice_call(byte[] key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException { + public get_slice_call(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); this.key = key; this.column_parent = column_parent; @@ -1692,18 +1693,18 @@ public class Cassandra { } } - public void get_count(byte[] key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException { + public void get_count(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException { checkReady(); get_count_call method_call = new get_count_call(key, column_parent, predicate, consistency_level, resultHandler, this, protocolFactory, transport); manager.call(method_call); } public static class get_count_call extends TAsyncMethodCall { - private byte[] key; + private ByteBuffer key; private ColumnParent column_parent; private SlicePredicate predicate; private ConsistencyLevel consistency_level; - public get_count_call(byte[] key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException { + public get_count_call(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); this.key = key; this.column_parent = column_parent; @@ -1732,18 +1733,18 @@ public class Cassandra { } } - public void multiget_slice(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException { + public void multiget_slice(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException { checkReady(); multiget_slice_call method_call = new multiget_slice_call(keys, column_parent, predicate, consistency_level, resultHandler, this, protocolFactory, transport); manager.call(method_call); } public static class multiget_slice_call extends TAsyncMethodCall { - private List keys; + private List keys; private ColumnParent column_parent; private SlicePredicate predicate; private ConsistencyLevel consistency_level; - public multiget_slice_call(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException { + public multiget_slice_call(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); this.keys = keys; this.column_parent = column_parent; @@ -1762,7 +1763,7 @@ public class Cassandra { prot.writeMessageEnd(); } - public Map> getResult() throws InvalidRequestException, UnavailableException, TimedOutException, TException { + public Map> getResult() throws InvalidRequestException, UnavailableException, TimedOutException, TException { if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } @@ -1772,18 +1773,18 @@ public class Cassandra { } } - public void multiget_count(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException { + public void multiget_count(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException { checkReady(); multiget_count_call method_call = new multiget_count_call(keys, column_parent, predicate, consistency_level, resultHandler, this, protocolFactory, transport); manager.call(method_call); } public static class multiget_count_call extends TAsyncMethodCall { - private List keys; + private List keys; private ColumnParent column_parent; private SlicePredicate predicate; private ConsistencyLevel consistency_level; - public multiget_count_call(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException { + public multiget_count_call(List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); this.keys = keys; this.column_parent = column_parent; @@ -1802,7 +1803,7 @@ public class Cassandra { prot.writeMessageEnd(); } - public Map getResult() throws InvalidRequestException, UnavailableException, TimedOutException, TException { + public Map getResult() throws InvalidRequestException, UnavailableException, TimedOutException, TException { if (getState() != State.RESPONSE_READ) { throw new IllegalStateException("Method call not finished!"); } @@ -1892,18 +1893,18 @@ public class Cassandra { } } - public void insert(byte[] key, ColumnParent column_parent, Column column, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException { + public void insert(ByteBuffer key, ColumnParent column_parent, Column column, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException { checkReady(); insert_call method_call = new insert_call(key, column_parent, column, consistency_level, resultHandler, this, protocolFactory, transport); manager.call(method_call); } public static class insert_call extends TAsyncMethodCall { - private byte[] key; + private ByteBuffer key; private ColumnParent column_parent; private Column column; private ConsistencyLevel consistency_level; - public insert_call(byte[] key, ColumnParent column_parent, Column column, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException { + public insert_call(ByteBuffer key, ColumnParent column_parent, Column column, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); this.key = key; this.column_parent = column_parent; @@ -1932,18 +1933,18 @@ public class Cassandra { } } - public void remove(byte[] key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException { + public void remove(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException { checkReady(); remove_call method_call = new remove_call(key, column_path, timestamp, consistency_level, resultHandler, this, protocolFactory, transport); manager.call(method_call); } public static class remove_call extends TAsyncMethodCall { - private byte[] key; + private ByteBuffer key; private ColumnPath column_path; private long timestamp; private ConsistencyLevel consistency_level; - public remove_call(byte[] key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException { + public remove_call(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); this.key = key; this.column_path = column_path; @@ -1972,16 +1973,16 @@ public class Cassandra { } } - public void batch_mutate(Map>> mutation_map, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException { + public void batch_mutate(Map>> mutation_map, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler) throws TException { checkReady(); batch_mutate_call method_call = new batch_mutate_call(mutation_map, consistency_level, resultHandler, this, protocolFactory, transport); manager.call(method_call); } public static class batch_mutate_call extends TAsyncMethodCall { - private Map>> mutation_map; + private Map>> mutation_map; private ConsistencyLevel consistency_level; - public batch_mutate_call(Map>> mutation_map, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException { + public batch_mutate_call(Map>> mutation_map, ConsistencyLevel consistency_level, AsyncMethodCallback resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException { super(client, protocolFactory, transport, resultHandler, false); this.mutation_map = mutation_map; this.consistency_level = consistency_level; @@ -3709,9 +3710,9 @@ public class Cassandra { return new login_args(this); } - @Deprecated - public login_args clone() { - return new login_args(this); + @Override + public void clear() { + this.auth_request = null; } public AuthenticationRequest getAuth_request() { @@ -3751,10 +3752,6 @@ public class Cassandra { } } - public void setFieldValue(int fieldID, Object value) { - setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value); - } - public Object getFieldValue(_Fields field) { switch (field) { case AUTH_REQUEST: @@ -3764,12 +3761,12 @@ public class Cassandra { throw new IllegalStateException(); } - public Object getFieldValue(int fieldId) { - return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId)); - } - /** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */ public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + switch (field) { case AUTH_REQUEST: return isSetAuth_request(); @@ -3777,10 +3774,6 @@ public class Cassandra { throw new IllegalStateException(); } - public boolean isSet(int fieldID) { - return isSet(_Fields.findByThriftIdOrThrow(fieldID)); - } - @Override public boolean equals(Object that) { if (that == null) @@ -3830,7 +3823,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetAuth_request()) { lastComparison = TBaseHelper.compareTo(this.auth_request, typedOther.auth_request); + if (isSetAuth_request()) { + lastComparison = TBaseHelper.compareTo(this.auth_request, typedOther.auth_request); if (lastComparison != 0) { return lastComparison; } @@ -3838,6 +3832,10 @@ public class Cassandra { return 0; } + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + public void read(TProtocol iprot) throws TException { TField field; iprot.readStructBegin(); @@ -4016,9 +4014,10 @@ public class Cassandra { return new login_result(this); } - @Deprecated - public login_result clone() { - return new login_result(this); + @Override + public void clear() { + this.authnx = null; + this.authzx = null; } public AuthenticationException getAuthnx() { @@ -4090,10 +4089,6 @@ public class Cassandra { } } - public void setFieldValue(int fieldID, Object value) { - setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value); - } - public Object getFieldValue(_Fields field) { switch (field) { case AUTHNX: @@ -4106,12 +4101,12 @@ public class Cassandra { throw new IllegalStateException(); } - public Object getFieldValue(int fieldId) { - return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId)); - } - /** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */ public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + switch (field) { case AUTHNX: return isSetAuthnx(); @@ -4121,10 +4116,6 @@ public class Cassandra { throw new IllegalStateException(); } - public boolean isSet(int fieldID) { - return isSet(_Fields.findByThriftIdOrThrow(fieldID)); - } - @Override public boolean equals(Object that) { if (that == null) @@ -4188,7 +4179,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetAuthnx()) { lastComparison = TBaseHelper.compareTo(this.authnx, typedOther.authnx); + if (isSetAuthnx()) { + lastComparison = TBaseHelper.compareTo(this.authnx, typedOther.authnx); if (lastComparison != 0) { return lastComparison; } @@ -4197,7 +4189,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetAuthzx()) { lastComparison = TBaseHelper.compareTo(this.authzx, typedOther.authzx); + if (isSetAuthzx()) { + lastComparison = TBaseHelper.compareTo(this.authzx, typedOther.authzx); if (lastComparison != 0) { return lastComparison; } @@ -4205,6 +4198,10 @@ public class Cassandra { return 0; } + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + public void read(TProtocol iprot) throws TException { TField field; iprot.readStructBegin(); @@ -4387,9 +4384,9 @@ public class Cassandra { return new set_keyspace_args(this); } - @Deprecated - public set_keyspace_args clone() { - return new set_keyspace_args(this); + @Override + public void clear() { + this.keyspace = null; } public String getKeyspace() { @@ -4429,10 +4426,6 @@ public class Cassandra { } } - public void setFieldValue(int fieldID, Object value) { - setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value); - } - public Object getFieldValue(_Fields field) { switch (field) { case KEYSPACE: @@ -4442,12 +4435,12 @@ public class Cassandra { throw new IllegalStateException(); } - public Object getFieldValue(int fieldId) { - return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId)); - } - /** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */ public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + switch (field) { case KEYSPACE: return isSetKeyspace(); @@ -4455,10 +4448,6 @@ public class Cassandra { throw new IllegalStateException(); } - public boolean isSet(int fieldID) { - return isSet(_Fields.findByThriftIdOrThrow(fieldID)); - } - @Override public boolean equals(Object that) { if (that == null) @@ -4508,7 +4497,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetKeyspace()) { lastComparison = TBaseHelper.compareTo(this.keyspace, typedOther.keyspace); + if (isSetKeyspace()) { + lastComparison = TBaseHelper.compareTo(this.keyspace, typedOther.keyspace); if (lastComparison != 0) { return lastComparison; } @@ -4516,6 +4506,10 @@ public class Cassandra { return 0; } + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + public void read(TProtocol iprot) throws TException { TField field; iprot.readStructBegin(); @@ -4681,9 +4675,9 @@ public class Cassandra { return new set_keyspace_result(this); } - @Deprecated - public set_keyspace_result clone() { - return new set_keyspace_result(this); + @Override + public void clear() { + this.ire = null; } public InvalidRequestException getIre() { @@ -4723,10 +4717,6 @@ public class Cassandra { } } - public void setFieldValue(int fieldID, Object value) { - setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value); - } - public Object getFieldValue(_Fields field) { switch (field) { case IRE: @@ -4736,12 +4726,12 @@ public class Cassandra { throw new IllegalStateException(); } - public Object getFieldValue(int fieldId) { - return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId)); - } - /** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */ public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + switch (field) { case IRE: return isSetIre(); @@ -4749,10 +4739,6 @@ public class Cassandra { throw new IllegalStateException(); } - public boolean isSet(int fieldID) { - return isSet(_Fields.findByThriftIdOrThrow(fieldID)); - } - @Override public boolean equals(Object that) { if (that == null) @@ -4802,7 +4788,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetIre()) { lastComparison = TBaseHelper.compareTo(this.ire, typedOther.ire); + if (isSetIre()) { + lastComparison = TBaseHelper.compareTo(this.ire, typedOther.ire); if (lastComparison != 0) { return lastComparison; } @@ -4810,6 +4797,10 @@ public class Cassandra { return 0; } + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + public void read(TProtocol iprot) throws TException { TField field; iprot.readStructBegin(); @@ -4880,7 +4871,7 @@ public class Cassandra { private static final TField COLUMN_PATH_FIELD_DESC = new TField("column_path", TType.STRUCT, (short)2); private static final TField CONSISTENCY_LEVEL_FIELD_DESC = new TField("consistency_level", TType.I32, (short)3); - public byte[] key; + public ByteBuffer key; public ColumnPath column_path; /** * @@ -4977,7 +4968,7 @@ public class Cassandra { } public get_args( - byte[] key, + ByteBuffer key, ColumnPath column_path, ConsistencyLevel consistency_level) { @@ -4992,8 +4983,8 @@ public class Cassandra { */ public get_args(get_args other) { if (other.isSetKey()) { - this.key = new byte[other.key.length]; - System.arraycopy(other.key, 0, key, 0, other.key.length); + this.key = TBaseHelper.copyBinary(other.key); +; } if (other.isSetColumn_path()) { this.column_path = new ColumnPath(other.column_path); @@ -5007,16 +4998,29 @@ public class Cassandra { return new get_args(this); } - @Deprecated - public get_args clone() { - return new get_args(this); + @Override + public void clear() { + this.key = null; + this.column_path = null; + this.consistency_level = ConsistencyLevel.ONE; + } public byte[] getKey() { - return this.key; + setKey(TBaseHelper.rightSize(key)); + return key.array(); + } + + public ByteBuffer BufferForKey() { + return key; } public get_args setKey(byte[] key) { + setKey(ByteBuffer.wrap(key)); + return this; + } + + public get_args setKey(ByteBuffer key) { this.key = key; return this; } @@ -5098,7 +5102,7 @@ public class Cassandra { if (value == null) { unsetKey(); } else { - setKey((byte[])value); + setKey((ByteBuffer)value); } break; @@ -5121,10 +5125,6 @@ public class Cassandra { } } - public void setFieldValue(int fieldID, Object value) { - setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value); - } - public Object getFieldValue(_Fields field) { switch (field) { case KEY: @@ -5140,12 +5140,12 @@ public class Cassandra { throw new IllegalStateException(); } - public Object getFieldValue(int fieldId) { - return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId)); - } - /** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */ public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + switch (field) { case KEY: return isSetKey(); @@ -5157,10 +5157,6 @@ public class Cassandra { throw new IllegalStateException(); } - public boolean isSet(int fieldID) { - return isSet(_Fields.findByThriftIdOrThrow(fieldID)); - } - @Override public boolean equals(Object that) { if (that == null) @@ -5179,7 +5175,7 @@ public class Cassandra { if (this_present_key || that_present_key) { if (!(this_present_key && that_present_key)) return false; - if (!java.util.Arrays.equals(this.key, that.key)) + if (!this.key.equals(that.key)) return false; } @@ -5238,7 +5234,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetKey()) { lastComparison = TBaseHelper.compareTo(this.key, typedOther.key); + if (isSetKey()) { + lastComparison = TBaseHelper.compareTo(this.key, typedOther.key); if (lastComparison != 0) { return lastComparison; } @@ -5247,7 +5244,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetColumn_path()) { lastComparison = TBaseHelper.compareTo(this.column_path, typedOther.column_path); + if (isSetColumn_path()) { + lastComparison = TBaseHelper.compareTo(this.column_path, typedOther.column_path); if (lastComparison != 0) { return lastComparison; } @@ -5256,7 +5254,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetConsistency_level()) { lastComparison = TBaseHelper.compareTo(this.consistency_level, typedOther.consistency_level); + if (isSetConsistency_level()) { + lastComparison = TBaseHelper.compareTo(this.consistency_level, typedOther.consistency_level); if (lastComparison != 0) { return lastComparison; } @@ -5264,6 +5263,10 @@ public class Cassandra { return 0; } + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + public void read(TProtocol iprot) throws TException { TField field; iprot.readStructBegin(); @@ -5339,12 +5342,7 @@ public class Cassandra { if (this.key == null) { sb.append("null"); } else { - int __key_size = Math.min(this.key.length, 128); - for (int i = 0; i < __key_size; i++) { - if (i != 0) sb.append(" "); - sb.append(Integer.toHexString(this.key[i]).length() > 1 ? Integer.toHexString(this.key[i]).substring(Integer.toHexString(this.key[i]).length() - 2).toUpperCase() : "0" + Integer.toHexString(this.key[i]).toUpperCase()); - } - if (this.key.length > 128) sb.append(" ..."); + TBaseHelper.toString(this.key, sb); } first = false; if (!first) sb.append(", "); @@ -5529,9 +5527,13 @@ public class Cassandra { return new get_result(this); } - @Deprecated - public get_result clone() { - return new get_result(this); + @Override + public void clear() { + this.success = null; + this.ire = null; + this.nfe = null; + this.ue = null; + this.te = null; } public ColumnOrSuperColumn getSuccess() { @@ -5699,10 +5701,6 @@ public class Cassandra { } } - public void setFieldValue(int fieldID, Object value) { - setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value); - } - public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: @@ -5724,12 +5722,12 @@ public class Cassandra { throw new IllegalStateException(); } - public Object getFieldValue(int fieldId) { - return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId)); - } - /** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */ public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + switch (field) { case SUCCESS: return isSetSuccess(); @@ -5745,10 +5743,6 @@ public class Cassandra { throw new IllegalStateException(); } - public boolean isSet(int fieldID) { - return isSet(_Fields.findByThriftIdOrThrow(fieldID)); - } - @Override public boolean equals(Object that) { if (that == null) @@ -5854,7 +5848,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetSuccess()) { lastComparison = TBaseHelper.compareTo(this.success, typedOther.success); + if (isSetSuccess()) { + lastComparison = TBaseHelper.compareTo(this.success, typedOther.success); if (lastComparison != 0) { return lastComparison; } @@ -5863,7 +5858,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetIre()) { lastComparison = TBaseHelper.compareTo(this.ire, typedOther.ire); + if (isSetIre()) { + lastComparison = TBaseHelper.compareTo(this.ire, typedOther.ire); if (lastComparison != 0) { return lastComparison; } @@ -5872,7 +5868,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetNfe()) { lastComparison = TBaseHelper.compareTo(this.nfe, typedOther.nfe); + if (isSetNfe()) { + lastComparison = TBaseHelper.compareTo(this.nfe, typedOther.nfe); if (lastComparison != 0) { return lastComparison; } @@ -5881,7 +5878,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetUe()) { lastComparison = TBaseHelper.compareTo(this.ue, typedOther.ue); + if (isSetUe()) { + lastComparison = TBaseHelper.compareTo(this.ue, typedOther.ue); if (lastComparison != 0) { return lastComparison; } @@ -5890,7 +5888,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetTe()) { lastComparison = TBaseHelper.compareTo(this.te, typedOther.te); + if (isSetTe()) { + lastComparison = TBaseHelper.compareTo(this.te, typedOther.te); if (lastComparison != 0) { return lastComparison; } @@ -5898,6 +5897,10 @@ public class Cassandra { return 0; } + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + public void read(TProtocol iprot) throws TException { TField field; iprot.readStructBegin(); @@ -6049,7 +6052,7 @@ public class Cassandra { private static final TField PREDICATE_FIELD_DESC = new TField("predicate", TType.STRUCT, (short)3); private static final TField CONSISTENCY_LEVEL_FIELD_DESC = new TField("consistency_level", TType.I32, (short)4); - public byte[] key; + public ByteBuffer key; public ColumnParent column_parent; public SlicePredicate predicate; /** @@ -6152,7 +6155,7 @@ public class Cassandra { } public get_slice_args( - byte[] key, + ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) @@ -6169,8 +6172,8 @@ public class Cassandra { */ public get_slice_args(get_slice_args other) { if (other.isSetKey()) { - this.key = new byte[other.key.length]; - System.arraycopy(other.key, 0, key, 0, other.key.length); + this.key = TBaseHelper.copyBinary(other.key); +; } if (other.isSetColumn_parent()) { this.column_parent = new ColumnParent(other.column_parent); @@ -6187,16 +6190,30 @@ public class Cassandra { return new get_slice_args(this); } - @Deprecated - public get_slice_args clone() { - return new get_slice_args(this); + @Override + public void clear() { + this.key = null; + this.column_parent = null; + this.predicate = null; + this.consistency_level = ConsistencyLevel.ONE; + } public byte[] getKey() { - return this.key; + setKey(TBaseHelper.rightSize(key)); + return key.array(); + } + + public ByteBuffer BufferForKey() { + return key; } public get_slice_args setKey(byte[] key) { + setKey(ByteBuffer.wrap(key)); + return this; + } + + public get_slice_args setKey(ByteBuffer key) { this.key = key; return this; } @@ -6302,7 +6319,7 @@ public class Cassandra { if (value == null) { unsetKey(); } else { - setKey((byte[])value); + setKey((ByteBuffer)value); } break; @@ -6333,10 +6350,6 @@ public class Cassandra { } } - public void setFieldValue(int fieldID, Object value) { - setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value); - } - public Object getFieldValue(_Fields field) { switch (field) { case KEY: @@ -6355,12 +6368,12 @@ public class Cassandra { throw new IllegalStateException(); } - public Object getFieldValue(int fieldId) { - return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId)); - } - /** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */ public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + switch (field) { case KEY: return isSetKey(); @@ -6374,10 +6387,6 @@ public class Cassandra { throw new IllegalStateException(); } - public boolean isSet(int fieldID) { - return isSet(_Fields.findByThriftIdOrThrow(fieldID)); - } - @Override public boolean equals(Object that) { if (that == null) @@ -6396,7 +6405,7 @@ public class Cassandra { if (this_present_key || that_present_key) { if (!(this_present_key && that_present_key)) return false; - if (!java.util.Arrays.equals(this.key, that.key)) + if (!this.key.equals(that.key)) return false; } @@ -6469,7 +6478,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetKey()) { lastComparison = TBaseHelper.compareTo(this.key, typedOther.key); + if (isSetKey()) { + lastComparison = TBaseHelper.compareTo(this.key, typedOther.key); if (lastComparison != 0) { return lastComparison; } @@ -6478,7 +6488,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetColumn_parent()) { lastComparison = TBaseHelper.compareTo(this.column_parent, typedOther.column_parent); + if (isSetColumn_parent()) { + lastComparison = TBaseHelper.compareTo(this.column_parent, typedOther.column_parent); if (lastComparison != 0) { return lastComparison; } @@ -6487,7 +6498,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetPredicate()) { lastComparison = TBaseHelper.compareTo(this.predicate, typedOther.predicate); + if (isSetPredicate()) { + lastComparison = TBaseHelper.compareTo(this.predicate, typedOther.predicate); if (lastComparison != 0) { return lastComparison; } @@ -6496,7 +6508,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetConsistency_level()) { lastComparison = TBaseHelper.compareTo(this.consistency_level, typedOther.consistency_level); + if (isSetConsistency_level()) { + lastComparison = TBaseHelper.compareTo(this.consistency_level, typedOther.consistency_level); if (lastComparison != 0) { return lastComparison; } @@ -6504,6 +6517,10 @@ public class Cassandra { return 0; } + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + public void read(TProtocol iprot) throws TException { TField field; iprot.readStructBegin(); @@ -6592,12 +6609,7 @@ public class Cassandra { if (this.key == null) { sb.append("null"); } else { - int __key_size = Math.min(this.key.length, 128); - for (int i = 0; i < __key_size; i++) { - if (i != 0) sb.append(" "); - sb.append(Integer.toHexString(this.key[i]).length() > 1 ? Integer.toHexString(this.key[i]).substring(Integer.toHexString(this.key[i]).length() - 2).toUpperCase() : "0" + Integer.toHexString(this.key[i]).toUpperCase()); - } - if (this.key.length > 128) sb.append(" ..."); + TBaseHelper.toString(this.key, sb); } first = false; if (!first) sb.append(", "); @@ -6786,9 +6798,12 @@ public class Cassandra { return new get_slice_result(this); } - @Deprecated - public get_slice_result clone() { - return new get_slice_result(this); + @Override + public void clear() { + this.success = null; + this.ire = null; + this.ue = null; + this.te = null; } public int getSuccessSize() { @@ -6939,10 +6954,6 @@ public class Cassandra { } } - public void setFieldValue(int fieldID, Object value) { - setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value); - } - public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: @@ -6961,12 +6972,12 @@ public class Cassandra { throw new IllegalStateException(); } - public Object getFieldValue(int fieldId) { - return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId)); - } - /** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */ public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + switch (field) { case SUCCESS: return isSetSuccess(); @@ -6980,10 +6991,6 @@ public class Cassandra { throw new IllegalStateException(); } - public boolean isSet(int fieldID) { - return isSet(_Fields.findByThriftIdOrThrow(fieldID)); - } - @Override public boolean equals(Object that) { if (that == null) @@ -7075,7 +7082,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetSuccess()) { lastComparison = TBaseHelper.compareTo(this.success, typedOther.success); + if (isSetSuccess()) { + lastComparison = TBaseHelper.compareTo(this.success, typedOther.success); if (lastComparison != 0) { return lastComparison; } @@ -7084,7 +7092,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetIre()) { lastComparison = TBaseHelper.compareTo(this.ire, typedOther.ire); + if (isSetIre()) { + lastComparison = TBaseHelper.compareTo(this.ire, typedOther.ire); if (lastComparison != 0) { return lastComparison; } @@ -7093,7 +7102,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetUe()) { lastComparison = TBaseHelper.compareTo(this.ue, typedOther.ue); + if (isSetUe()) { + lastComparison = TBaseHelper.compareTo(this.ue, typedOther.ue); if (lastComparison != 0) { return lastComparison; } @@ -7102,7 +7112,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetTe()) { lastComparison = TBaseHelper.compareTo(this.te, typedOther.te); + if (isSetTe()) { + lastComparison = TBaseHelper.compareTo(this.te, typedOther.te); if (lastComparison != 0) { return lastComparison; } @@ -7110,6 +7121,10 @@ public class Cassandra { return 0; } + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + public void read(TProtocol iprot) throws TException { TField field; iprot.readStructBegin(); @@ -7258,7 +7273,7 @@ public class Cassandra { private static final TField PREDICATE_FIELD_DESC = new TField("predicate", TType.STRUCT, (short)3); private static final TField CONSISTENCY_LEVEL_FIELD_DESC = new TField("consistency_level", TType.I32, (short)4); - public byte[] key; + public ByteBuffer key; public ColumnParent column_parent; public SlicePredicate predicate; /** @@ -7361,7 +7376,7 @@ public class Cassandra { } public get_count_args( - byte[] key, + ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) @@ -7378,8 +7393,8 @@ public class Cassandra { */ public get_count_args(get_count_args other) { if (other.isSetKey()) { - this.key = new byte[other.key.length]; - System.arraycopy(other.key, 0, key, 0, other.key.length); + this.key = TBaseHelper.copyBinary(other.key); +; } if (other.isSetColumn_parent()) { this.column_parent = new ColumnParent(other.column_parent); @@ -7396,16 +7411,30 @@ public class Cassandra { return new get_count_args(this); } - @Deprecated - public get_count_args clone() { - return new get_count_args(this); + @Override + public void clear() { + this.key = null; + this.column_parent = null; + this.predicate = null; + this.consistency_level = ConsistencyLevel.ONE; + } public byte[] getKey() { - return this.key; + setKey(TBaseHelper.rightSize(key)); + return key.array(); + } + + public ByteBuffer BufferForKey() { + return key; } public get_count_args setKey(byte[] key) { + setKey(ByteBuffer.wrap(key)); + return this; + } + + public get_count_args setKey(ByteBuffer key) { this.key = key; return this; } @@ -7511,7 +7540,7 @@ public class Cassandra { if (value == null) { unsetKey(); } else { - setKey((byte[])value); + setKey((ByteBuffer)value); } break; @@ -7542,10 +7571,6 @@ public class Cassandra { } } - public void setFieldValue(int fieldID, Object value) { - setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value); - } - public Object getFieldValue(_Fields field) { switch (field) { case KEY: @@ -7564,12 +7589,12 @@ public class Cassandra { throw new IllegalStateException(); } - public Object getFieldValue(int fieldId) { - return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId)); - } - /** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */ public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + switch (field) { case KEY: return isSetKey(); @@ -7583,10 +7608,6 @@ public class Cassandra { throw new IllegalStateException(); } - public boolean isSet(int fieldID) { - return isSet(_Fields.findByThriftIdOrThrow(fieldID)); - } - @Override public boolean equals(Object that) { if (that == null) @@ -7605,7 +7626,7 @@ public class Cassandra { if (this_present_key || that_present_key) { if (!(this_present_key && that_present_key)) return false; - if (!java.util.Arrays.equals(this.key, that.key)) + if (!this.key.equals(that.key)) return false; } @@ -7678,7 +7699,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetKey()) { lastComparison = TBaseHelper.compareTo(this.key, typedOther.key); + if (isSetKey()) { + lastComparison = TBaseHelper.compareTo(this.key, typedOther.key); if (lastComparison != 0) { return lastComparison; } @@ -7687,7 +7709,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetColumn_parent()) { lastComparison = TBaseHelper.compareTo(this.column_parent, typedOther.column_parent); + if (isSetColumn_parent()) { + lastComparison = TBaseHelper.compareTo(this.column_parent, typedOther.column_parent); if (lastComparison != 0) { return lastComparison; } @@ -7696,7 +7719,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetPredicate()) { lastComparison = TBaseHelper.compareTo(this.predicate, typedOther.predicate); + if (isSetPredicate()) { + lastComparison = TBaseHelper.compareTo(this.predicate, typedOther.predicate); if (lastComparison != 0) { return lastComparison; } @@ -7705,7 +7729,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetConsistency_level()) { lastComparison = TBaseHelper.compareTo(this.consistency_level, typedOther.consistency_level); + if (isSetConsistency_level()) { + lastComparison = TBaseHelper.compareTo(this.consistency_level, typedOther.consistency_level); if (lastComparison != 0) { return lastComparison; } @@ -7713,6 +7738,10 @@ public class Cassandra { return 0; } + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + public void read(TProtocol iprot) throws TException { TField field; iprot.readStructBegin(); @@ -7801,12 +7830,7 @@ public class Cassandra { if (this.key == null) { sb.append("null"); } else { - int __key_size = Math.min(this.key.length, 128); - for (int i = 0; i < __key_size; i++) { - if (i != 0) sb.append(" "); - sb.append(Integer.toHexString(this.key[i]).length() > 1 ? Integer.toHexString(this.key[i]).substring(Integer.toHexString(this.key[i]).length() - 2).toUpperCase() : "0" + Integer.toHexString(this.key[i]).toUpperCase()); - } - if (this.key.length > 128) sb.append(" ..."); + TBaseHelper.toString(this.key, sb); } first = false; if (!first) sb.append(", "); @@ -7993,9 +8017,13 @@ public class Cassandra { return new get_count_result(this); } - @Deprecated - public get_count_result clone() { - return new get_count_result(this); + @Override + public void clear() { + setSuccessIsSet(false); + this.success = 0; + this.ire = null; + this.ue = null; + this.te = null; } public int getSuccess() { @@ -8130,10 +8158,6 @@ public class Cassandra { } } - public void setFieldValue(int fieldID, Object value) { - setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value); - } - public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: @@ -8152,12 +8176,12 @@ public class Cassandra { throw new IllegalStateException(); } - public Object getFieldValue(int fieldId) { - return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId)); - } - /** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */ public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + switch (field) { case SUCCESS: return isSetSuccess(); @@ -8171,10 +8195,6 @@ public class Cassandra { throw new IllegalStateException(); } - public boolean isSet(int fieldID) { - return isSet(_Fields.findByThriftIdOrThrow(fieldID)); - } - @Override public boolean equals(Object that) { if (that == null) @@ -8266,7 +8286,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetSuccess()) { lastComparison = TBaseHelper.compareTo(this.success, typedOther.success); + if (isSetSuccess()) { + lastComparison = TBaseHelper.compareTo(this.success, typedOther.success); if (lastComparison != 0) { return lastComparison; } @@ -8275,7 +8296,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetIre()) { lastComparison = TBaseHelper.compareTo(this.ire, typedOther.ire); + if (isSetIre()) { + lastComparison = TBaseHelper.compareTo(this.ire, typedOther.ire); if (lastComparison != 0) { return lastComparison; } @@ -8284,7 +8306,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetUe()) { lastComparison = TBaseHelper.compareTo(this.ue, typedOther.ue); + if (isSetUe()) { + lastComparison = TBaseHelper.compareTo(this.ue, typedOther.ue); if (lastComparison != 0) { return lastComparison; } @@ -8293,7 +8316,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetTe()) { lastComparison = TBaseHelper.compareTo(this.te, typedOther.te); + if (isSetTe()) { + lastComparison = TBaseHelper.compareTo(this.te, typedOther.te); if (lastComparison != 0) { return lastComparison; } @@ -8301,6 +8325,10 @@ public class Cassandra { return 0; } + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + public void read(TProtocol iprot) throws TException { TField field; iprot.readStructBegin(); @@ -8428,7 +8456,7 @@ public class Cassandra { private static final TField PREDICATE_FIELD_DESC = new TField("predicate", TType.STRUCT, (short)3); private static final TField CONSISTENCY_LEVEL_FIELD_DESC = new TField("consistency_level", TType.I32, (short)4); - public List keys; + public List keys; public ColumnParent column_parent; public SlicePredicate predicate; /** @@ -8532,7 +8560,7 @@ public class Cassandra { } public multiget_slice_args( - List keys, + List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) @@ -8549,10 +8577,10 @@ public class Cassandra { */ public multiget_slice_args(multiget_slice_args other) { if (other.isSetKeys()) { - List __this__keys = new ArrayList(); - for (byte[] other_element : other.keys) { - byte[] temp_binary_element = new byte[other_element.length]; - System.arraycopy(other_element, 0, temp_binary_element, 0, other_element.length); + List __this__keys = new ArrayList(); + for (ByteBuffer other_element : other.keys) { + ByteBuffer temp_binary_element = TBaseHelper.copyBinary(other_element); +; __this__keys.add(temp_binary_element); } this.keys = __this__keys; @@ -8572,31 +8600,35 @@ public class Cassandra { return new multiget_slice_args(this); } - @Deprecated - public multiget_slice_args clone() { - return new multiget_slice_args(this); + @Override + public void clear() { + this.keys = null; + this.column_parent = null; + this.predicate = null; + this.consistency_level = ConsistencyLevel.ONE; + } public int getKeysSize() { return (this.keys == null) ? 0 : this.keys.size(); } - public java.util.Iterator getKeysIterator() { + public java.util.Iterator getKeysIterator() { return (this.keys == null) ? null : this.keys.iterator(); } - public void addToKeys(byte[] elem) { + public void addToKeys(ByteBuffer elem) { if (this.keys == null) { - this.keys = new ArrayList(); + this.keys = new ArrayList(); } this.keys.add(elem); } - public List getKeys() { + public List getKeys() { return this.keys; } - public multiget_slice_args setKeys(List keys) { + public multiget_slice_args setKeys(List keys) { this.keys = keys; return this; } @@ -8702,7 +8734,7 @@ public class Cassandra { if (value == null) { unsetKeys(); } else { - setKeys((List)value); + setKeys((List)value); } break; @@ -8733,10 +8765,6 @@ public class Cassandra { } } - public void setFieldValue(int fieldID, Object value) { - setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value); - } - public Object getFieldValue(_Fields field) { switch (field) { case KEYS: @@ -8755,12 +8783,12 @@ public class Cassandra { throw new IllegalStateException(); } - public Object getFieldValue(int fieldId) { - return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId)); - } - /** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */ public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + switch (field) { case KEYS: return isSetKeys(); @@ -8774,10 +8802,6 @@ public class Cassandra { throw new IllegalStateException(); } - public boolean isSet(int fieldID) { - return isSet(_Fields.findByThriftIdOrThrow(fieldID)); - } - @Override public boolean equals(Object that) { if (that == null) @@ -8869,7 +8893,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetKeys()) { lastComparison = TBaseHelper.compareTo(this.keys, typedOther.keys); + if (isSetKeys()) { + lastComparison = TBaseHelper.compareTo(this.keys, typedOther.keys); if (lastComparison != 0) { return lastComparison; } @@ -8878,7 +8903,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetColumn_parent()) { lastComparison = TBaseHelper.compareTo(this.column_parent, typedOther.column_parent); + if (isSetColumn_parent()) { + lastComparison = TBaseHelper.compareTo(this.column_parent, typedOther.column_parent); if (lastComparison != 0) { return lastComparison; } @@ -8887,7 +8913,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetPredicate()) { lastComparison = TBaseHelper.compareTo(this.predicate, typedOther.predicate); + if (isSetPredicate()) { + lastComparison = TBaseHelper.compareTo(this.predicate, typedOther.predicate); if (lastComparison != 0) { return lastComparison; } @@ -8896,7 +8923,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetConsistency_level()) { lastComparison = TBaseHelper.compareTo(this.consistency_level, typedOther.consistency_level); + if (isSetConsistency_level()) { + lastComparison = TBaseHelper.compareTo(this.consistency_level, typedOther.consistency_level); if (lastComparison != 0) { return lastComparison; } @@ -8904,6 +8932,10 @@ public class Cassandra { return 0; } + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + public void read(TProtocol iprot) throws TException { TField field; iprot.readStructBegin(); @@ -8918,10 +8950,10 @@ public class Cassandra { if (field.type == TType.LIST) { { TList _list42 = iprot.readListBegin(); - this.keys = new ArrayList(_list42.size); + this.keys = new ArrayList(_list42.size); for (int _i43 = 0; _i43 < _list42.size; ++_i43) { - byte[] _elem44; + ByteBuffer _elem44; _elem44 = iprot.readBinary(); this.keys.add(_elem44); } @@ -8973,7 +9005,7 @@ public class Cassandra { oprot.writeFieldBegin(KEYS_FIELD_DESC); { oprot.writeListBegin(new TList(TType.STRING, this.keys.size())); - for (byte[] _iter45 : this.keys) + for (ByteBuffer _iter45 : this.keys) { oprot.writeBinary(_iter45); } @@ -9066,7 +9098,7 @@ public class Cassandra { private static final TField UE_FIELD_DESC = new TField("ue", TType.STRUCT, (short)2); private static final TField TE_FIELD_DESC = new TField("te", TType.STRUCT, (short)3); - public Map> success; + public Map> success; public InvalidRequestException ire; public UnavailableException ue; public TimedOutException te; @@ -9162,7 +9194,7 @@ public class Cassandra { } public multiget_slice_result( - Map> success, + Map> success, InvalidRequestException ire, UnavailableException ue, TimedOutException te) @@ -9179,14 +9211,14 @@ public class Cassandra { */ public multiget_slice_result(multiget_slice_result other) { if (other.isSetSuccess()) { - Map> __this__success = new HashMap>(); - for (Map.Entry> other_element : other.success.entrySet()) { + Map> __this__success = new HashMap>(); + for (Map.Entry> other_element : other.success.entrySet()) { - byte[] other_element_key = other_element.getKey(); + ByteBuffer other_element_key = other_element.getKey(); List other_element_value = other_element.getValue(); - byte[] __this__success_copy_key = new byte[other_element_key.length]; - System.arraycopy(other_element_key, 0, __this__success_copy_key, 0, other_element_key.length); + ByteBuffer __this__success_copy_key = TBaseHelper.copyBinary(other_element_key); +; List __this__success_copy_value = new ArrayList(); for (ColumnOrSuperColumn other_element_value_element : other_element_value) { @@ -9212,27 +9244,30 @@ public class Cassandra { return new multiget_slice_result(this); } - @Deprecated - public multiget_slice_result clone() { - return new multiget_slice_result(this); + @Override + public void clear() { + this.success = null; + this.ire = null; + this.ue = null; + this.te = null; } public int getSuccessSize() { return (this.success == null) ? 0 : this.success.size(); } - public void putToSuccess(byte[] key, List val) { + public void putToSuccess(ByteBuffer key, List val) { if (this.success == null) { - this.success = new HashMap>(); + this.success = new HashMap>(); } this.success.put(key, val); } - public Map> getSuccess() { + public Map> getSuccess() { return this.success; } - public multiget_slice_result setSuccess(Map> success) { + public multiget_slice_result setSuccess(Map> success) { this.success = success; return this; } @@ -9330,7 +9365,7 @@ public class Cassandra { if (value == null) { unsetSuccess(); } else { - setSuccess((Map>)value); + setSuccess((Map>)value); } break; @@ -9361,10 +9396,6 @@ public class Cassandra { } } - public void setFieldValue(int fieldID, Object value) { - setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value); - } - public Object getFieldValue(_Fields field) { switch (field) { case SUCCESS: @@ -9383,12 +9414,12 @@ public class Cassandra { throw new IllegalStateException(); } - public Object getFieldValue(int fieldId) { - return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId)); - } - /** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */ public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + switch (field) { case SUCCESS: return isSetSuccess(); @@ -9402,10 +9433,6 @@ public class Cassandra { throw new IllegalStateException(); } - public boolean isSet(int fieldID) { - return isSet(_Fields.findByThriftIdOrThrow(fieldID)); - } - @Override public boolean equals(Object that) { if (that == null) @@ -9497,7 +9524,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetSuccess()) { lastComparison = TBaseHelper.compareTo(this.success, typedOther.success); + if (isSetSuccess()) { + lastComparison = TBaseHelper.compareTo(this.success, typedOther.success); if (lastComparison != 0) { return lastComparison; } @@ -9506,7 +9534,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetIre()) { lastComparison = TBaseHelper.compareTo(this.ire, typedOther.ire); + if (isSetIre()) { + lastComparison = TBaseHelper.compareTo(this.ire, typedOther.ire); if (lastComparison != 0) { return lastComparison; } @@ -9515,7 +9544,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetUe()) { lastComparison = TBaseHelper.compareTo(this.ue, typedOther.ue); + if (isSetUe()) { + lastComparison = TBaseHelper.compareTo(this.ue, typedOther.ue); if (lastComparison != 0) { return lastComparison; } @@ -9524,7 +9554,8 @@ public class Cassandra { if (lastComparison != 0) { return lastComparison; } - if (isSetTe()) { lastComparison = TBaseHelper.compareTo(this.te, typedOther.te); + if (isSetTe()) { + lastComparison = TBaseHelper.compareTo(this.te, typedOther.te); if (lastComparison != 0) { return lastComparison; } @@ -9532,6 +9563,10 @@ public class Cassandra { return 0; } + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + public void read(TProtocol iprot) throws TException { TField field; iprot.readStructBegin(); @@ -9546,10 +9581,10 @@ public class Cassandra { if (field.type == TType.MAP) { { TMap _map46 = iprot.readMapBegin(); - this.success = new HashMap>(2*_map46.size); + this.success = new HashMap>(2*_map46.size); for (int _i47 = 0; _i47 < _map46.size; ++_i47) { - byte[] _key48; + ByteBuffer _key48; List _val49; _key48 = iprot.readBinary(); { @@ -9614,7 +9649,7 @@ public class Cassandra { oprot.writeFieldBegin(SUCCESS_FIELD_DESC); { oprot.writeMapBegin(new TMap(TType.STRING, TType.LIST, this.success.size())); - for (Map.Entry> _iter53 : this.success.entrySet()) + for (Map.Entry> _iter53 : this.success.entrySet()) { oprot.writeBinary(_iter53.getKey()); { @@ -9700,7 +9735,7 @@ public class Cassandra { private static final TField PREDICATE_FIELD_DESC = new TField("predicate", TType.STRUCT, (short)3); private static final TField CONSISTENCY_LEVEL_FIELD_DESC = new TField("consistency_level", TType.I32, (short)4); - public List keys; + public List keys; public ColumnParent column_parent; public SlicePredicate predicate; /** @@ -9804,7 +9839,7 @@ public class Cassandra { } public multiget_count_args( - List keys, + List keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) @@ -9821,10 +9856,10 @@ public class Cassandra { */ public multiget_count_args(multiget_count_args other) { if (other.isSetKeys()) { - List __this__keys = new ArrayList(); - for (byte[] other_element : other.keys) { - byte[] temp_binary_element = new byte[other_element.length]; - System.arraycopy(other_element, 0, temp_binary_element, 0, other_element.length); + List __this__keys = new ArrayList(); + for (ByteBuffer other_element : other.keys) { + ByteBuffer temp_binary_element = TBaseHelper.copyBinary(other_element); +; __this__keys.add(temp_binary_element); } this.keys = __this__keys; @@ -9844,31 +9879,35 @@ public class Cassandra { return new multiget_count_args(this); } - @Deprecated - public multiget_count_args clone() { - return new multiget_count_args(this); + @Override + public void clear() { + this.keys = null; + this.column_parent = null; + this.predicate = null; + this.consistency_level = ConsistencyLevel.ONE; + } public int getKeysSize() { return (this.keys == null) ? 0 : this.keys.size(); } - public java.util.Iterator getKeysIterator() { + public java.util.Iterator getKeysIterator() { return (this.keys == null) ? null : this.keys.iterator(); } - public void addToKeys(byte[] elem) { + public void addToKeys(ByteBuffer elem) { if (this.keys == null) { - this.keys = new ArrayList(); + this.keys = new ArrayList(); } this.keys.add(elem); } - public List getKeys() { + public List getKeys() { return this.keys; } - public multiget_count_args setKeys(List keys) { [... 4001 lines stripped ...]