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/10/22 05:23:31 UTC
svn commit: r1026200 [2/11] - in /cassandra/trunk: ./ interface/
interface/thrift/gen-java/org/apache/cassandra/thrift/
src/java/org/apache/cassandra/auth/ src/java/org/apache/cassandra/avro/
src/java/org/apache/cassandra/cli/ src/java/org/apache/cassa...
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<ColumnOrSuperColumn> get_slice(byte[] key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException;
+ public List<ColumnOrSuperColumn> get_slice(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException;
/**
* returns the number of columns matching <code>predicate</code> for a particular <code>key</code>,
@@ -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<byte[],List<ColumnOrSuperColumn>> multiget_slice(List<byte[]> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException;
+ public Map<ByteBuffer,List<ColumnOrSuperColumn>> multiget_slice(List<ByteBuffer> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException;
/**
* Perform a get_count in parallel on the given list<binary> keys. The return value maps keys to the count found.
@@ -105,7 +106,7 @@ public class Cassandra {
* @param predicate
* @param consistency_level
*/
- public Map<byte[],Integer> multiget_count(List<byte[]> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException;
+ public Map<ByteBuffer,Integer> multiget_count(List<ByteBuffer> 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<byte[],Map<String,List<Mutation>>> mutation_map, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException;
+ public void batch_mutate(Map<ByteBuffer,Map<String,List<Mutation>>> 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<AsyncClient.set_keyspace_call> resultHandler) throws TException;
- public void get(byte[] key, ColumnPath column_path, ConsistencyLevel consistency_level, AsyncMethodCallback<AsyncClient.get_call> resultHandler) throws TException;
+ public void get(ByteBuffer key, ColumnPath column_path, ConsistencyLevel consistency_level, AsyncMethodCallback<AsyncClient.get_call> resultHandler) throws TException;
- public void get_slice(byte[] key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<AsyncClient.get_slice_call> resultHandler) throws TException;
+ public void get_slice(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<AsyncClient.get_slice_call> resultHandler) throws TException;
- public void get_count(byte[] key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<AsyncClient.get_count_call> resultHandler) throws TException;
+ public void get_count(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<AsyncClient.get_count_call> resultHandler) throws TException;
- public void multiget_slice(List<byte[]> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<AsyncClient.multiget_slice_call> resultHandler) throws TException;
+ public void multiget_slice(List<ByteBuffer> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<AsyncClient.multiget_slice_call> resultHandler) throws TException;
- public void multiget_count(List<byte[]> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<AsyncClient.multiget_count_call> resultHandler) throws TException;
+ public void multiget_count(List<ByteBuffer> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<AsyncClient.multiget_count_call> resultHandler) throws TException;
public void get_range_slices(ColumnParent column_parent, SlicePredicate predicate, KeyRange range, ConsistencyLevel consistency_level, AsyncMethodCallback<AsyncClient.get_range_slices_call> resultHandler) throws TException;
public void get_indexed_slices(ColumnParent column_parent, IndexClause index_clause, SlicePredicate column_predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<AsyncClient.get_indexed_slices_call> resultHandler) throws TException;
- public void insert(byte[] key, ColumnParent column_parent, Column column, ConsistencyLevel consistency_level, AsyncMethodCallback<AsyncClient.insert_call> resultHandler) throws TException;
+ public void insert(ByteBuffer key, ColumnParent column_parent, Column column, ConsistencyLevel consistency_level, AsyncMethodCallback<AsyncClient.insert_call> resultHandler) throws TException;
- public void remove(byte[] key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level, AsyncMethodCallback<AsyncClient.remove_call> resultHandler) throws TException;
+ public void remove(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level, AsyncMethodCallback<AsyncClient.remove_call> resultHandler) throws TException;
- public void batch_mutate(Map<byte[],Map<String,List<Mutation>>> mutation_map, ConsistencyLevel consistency_level, AsyncMethodCallback<AsyncClient.batch_mutate_call> resultHandler) throws TException;
+ public void batch_mutate(Map<ByteBuffer,Map<String,List<Mutation>>> mutation_map, ConsistencyLevel consistency_level, AsyncMethodCallback<AsyncClient.batch_mutate_call> resultHandler) throws TException;
public void truncate(String cfname, AsyncMethodCallback<AsyncClient.truncate_call> 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<ColumnOrSuperColumn> get_slice(byte[] key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException
+ public List<ColumnOrSuperColumn> 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<byte[],List<ColumnOrSuperColumn>> multiget_slice(List<byte[]> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException
+ public Map<ByteBuffer,List<ColumnOrSuperColumn>> multiget_slice(List<ByteBuffer> 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<byte[]> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws TException
+ public void send_multiget_slice(List<ByteBuffer> 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<byte[],List<ColumnOrSuperColumn>> recv_multiget_slice() throws InvalidRequestException, UnavailableException, TimedOutException, TException
+ public Map<ByteBuffer,List<ColumnOrSuperColumn>> 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<byte[],Integer> multiget_count(List<byte[]> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException
+ public Map<ByteBuffer,Integer> multiget_count(List<ByteBuffer> 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<byte[]> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws TException
+ public void send_multiget_count(List<ByteBuffer> 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<byte[],Integer> recv_multiget_count() throws InvalidRequestException, UnavailableException, TimedOutException, TException
+ public Map<ByteBuffer,Integer> 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<byte[],Map<String,List<Mutation>>> mutation_map, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException
+ public void batch_mutate(Map<ByteBuffer,Map<String,List<Mutation>>> 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<byte[],Map<String,List<Mutation>>> mutation_map, ConsistencyLevel consistency_level) throws TException
+ public void send_batch_mutate(Map<ByteBuffer,Map<String,List<Mutation>>> 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<get_call> resultHandler) throws TException {
+ public void get(ByteBuffer key, ColumnPath column_path, ConsistencyLevel consistency_level, AsyncMethodCallback<get_call> 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<get_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
+ public get_call(ByteBuffer key, ColumnPath column_path, ConsistencyLevel consistency_level, AsyncMethodCallback<get_call> 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<get_slice_call> resultHandler) throws TException {
+ public void get_slice(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<get_slice_call> 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<get_slice_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
+ public get_slice_call(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<get_slice_call> 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<get_count_call> resultHandler) throws TException {
+ public void get_count(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<get_count_call> 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<get_count_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
+ public get_count_call(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<get_count_call> 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<byte[]> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<multiget_slice_call> resultHandler) throws TException {
+ public void multiget_slice(List<ByteBuffer> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<multiget_slice_call> 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<byte[]> keys;
+ private List<ByteBuffer> keys;
private ColumnParent column_parent;
private SlicePredicate predicate;
private ConsistencyLevel consistency_level;
- public multiget_slice_call(List<byte[]> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<multiget_slice_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
+ public multiget_slice_call(List<ByteBuffer> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<multiget_slice_call> 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<byte[],List<ColumnOrSuperColumn>> getResult() throws InvalidRequestException, UnavailableException, TimedOutException, TException {
+ public Map<ByteBuffer,List<ColumnOrSuperColumn>> 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<byte[]> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<multiget_count_call> resultHandler) throws TException {
+ public void multiget_count(List<ByteBuffer> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<multiget_count_call> 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<byte[]> keys;
+ private List<ByteBuffer> keys;
private ColumnParent column_parent;
private SlicePredicate predicate;
private ConsistencyLevel consistency_level;
- public multiget_count_call(List<byte[]> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<multiget_count_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
+ public multiget_count_call(List<ByteBuffer> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, AsyncMethodCallback<multiget_count_call> 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<byte[],Integer> getResult() throws InvalidRequestException, UnavailableException, TimedOutException, TException {
+ public Map<ByteBuffer,Integer> 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<insert_call> resultHandler) throws TException {
+ public void insert(ByteBuffer key, ColumnParent column_parent, Column column, ConsistencyLevel consistency_level, AsyncMethodCallback<insert_call> 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<insert_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
+ public insert_call(ByteBuffer key, ColumnParent column_parent, Column column, ConsistencyLevel consistency_level, AsyncMethodCallback<insert_call> 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<remove_call> resultHandler) throws TException {
+ public void remove(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level, AsyncMethodCallback<remove_call> 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<remove_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
+ public remove_call(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level, AsyncMethodCallback<remove_call> 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<byte[],Map<String,List<Mutation>>> mutation_map, ConsistencyLevel consistency_level, AsyncMethodCallback<batch_mutate_call> resultHandler) throws TException {
+ public void batch_mutate(Map<ByteBuffer,Map<String,List<Mutation>>> mutation_map, ConsistencyLevel consistency_level, AsyncMethodCallback<batch_mutate_call> 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<byte[],Map<String,List<Mutation>>> mutation_map;
+ private Map<ByteBuffer,Map<String,List<Mutation>>> mutation_map;
private ConsistencyLevel consistency_level;
- public batch_mutate_call(Map<byte[],Map<String,List<Mutation>>> mutation_map, ConsistencyLevel consistency_level, AsyncMethodCallback<batch_mutate_call> resultHandler, TAsyncClient client, TProtocolFactory protocolFactory, TNonblockingTransport transport) throws TException {
+ public batch_mutate_call(Map<ByteBuffer,Map<String,List<Mutation>>> mutation_map, ConsistencyLevel consistency_level, AsyncMethodCallback<batch_mutate_call> 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<byte[]> keys;
+ public List<ByteBuffer> keys;
public ColumnParent column_parent;
public SlicePredicate predicate;
/**
@@ -8532,7 +8560,7 @@ public class Cassandra {
}
public multiget_slice_args(
- List<byte[]> keys,
+ List<ByteBuffer> 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<byte[]> __this__keys = new ArrayList<byte[]>();
- 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<ByteBuffer> __this__keys = new ArrayList<ByteBuffer>();
+ 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<byte[]> getKeysIterator() {
+ public java.util.Iterator<ByteBuffer> 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<byte[]>();
+ this.keys = new ArrayList<ByteBuffer>();
}
this.keys.add(elem);
}
- public List<byte[]> getKeys() {
+ public List<ByteBuffer> getKeys() {
return this.keys;
}
- public multiget_slice_args setKeys(List<byte[]> keys) {
+ public multiget_slice_args setKeys(List<ByteBuffer> keys) {
this.keys = keys;
return this;
}
@@ -8702,7 +8734,7 @@ public class Cassandra {
if (value == null) {
unsetKeys();
} else {
- setKeys((List<byte[]>)value);
+ setKeys((List<ByteBuffer>)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<byte[]>(_list42.size);
+ this.keys = new ArrayList<ByteBuffer>(_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<byte[],List<ColumnOrSuperColumn>> success;
+ public Map<ByteBuffer,List<ColumnOrSuperColumn>> success;
public InvalidRequestException ire;
public UnavailableException ue;
public TimedOutException te;
@@ -9162,7 +9194,7 @@ public class Cassandra {
}
public multiget_slice_result(
- Map<byte[],List<ColumnOrSuperColumn>> success,
+ Map<ByteBuffer,List<ColumnOrSuperColumn>> 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<byte[],List<ColumnOrSuperColumn>> __this__success = new HashMap<byte[],List<ColumnOrSuperColumn>>();
- for (Map.Entry<byte[], List<ColumnOrSuperColumn>> other_element : other.success.entrySet()) {
+ Map<ByteBuffer,List<ColumnOrSuperColumn>> __this__success = new HashMap<ByteBuffer,List<ColumnOrSuperColumn>>();
+ for (Map.Entry<ByteBuffer, List<ColumnOrSuperColumn>> other_element : other.success.entrySet()) {
- byte[] other_element_key = other_element.getKey();
+ ByteBuffer other_element_key = other_element.getKey();
List<ColumnOrSuperColumn> 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<ColumnOrSuperColumn> __this__success_copy_value = new ArrayList<ColumnOrSuperColumn>();
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<ColumnOrSuperColumn> val) {
+ public void putToSuccess(ByteBuffer key, List<ColumnOrSuperColumn> val) {
if (this.success == null) {
- this.success = new HashMap<byte[],List<ColumnOrSuperColumn>>();
+ this.success = new HashMap<ByteBuffer,List<ColumnOrSuperColumn>>();
}
this.success.put(key, val);
}
- public Map<byte[],List<ColumnOrSuperColumn>> getSuccess() {
+ public Map<ByteBuffer,List<ColumnOrSuperColumn>> getSuccess() {
return this.success;
}
- public multiget_slice_result setSuccess(Map<byte[],List<ColumnOrSuperColumn>> success) {
+ public multiget_slice_result setSuccess(Map<ByteBuffer,List<ColumnOrSuperColumn>> success) {
this.success = success;
return this;
}
@@ -9330,7 +9365,7 @@ public class Cassandra {
if (value == null) {
unsetSuccess();
} else {
- setSuccess((Map<byte[],List<ColumnOrSuperColumn>>)value);
+ setSuccess((Map<ByteBuffer,List<ColumnOrSuperColumn>>)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<byte[],List<ColumnOrSuperColumn>>(2*_map46.size);
+ this.success = new HashMap<ByteBuffer,List<ColumnOrSuperColumn>>(2*_map46.size);
for (int _i47 = 0; _i47 < _map46.size; ++_i47)
{
- byte[] _key48;
+ ByteBuffer _key48;
List<ColumnOrSuperColumn> _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<byte[], List<ColumnOrSuperColumn>> _iter53 : this.success.entrySet())
+ for (Map.Entry<ByteBuffer, List<ColumnOrSuperColumn>> _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<byte[]> keys;
+ public List<ByteBuffer> keys;
public ColumnParent column_parent;
public SlicePredicate predicate;
/**
@@ -9804,7 +9839,7 @@ public class Cassandra {
}
public multiget_count_args(
- List<byte[]> keys,
+ List<ByteBuffer> 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<byte[]> __this__keys = new ArrayList<byte[]>();
- 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<ByteBuffer> __this__keys = new ArrayList<ByteBuffer>();
+ 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<byte[]> getKeysIterator() {
+ public java.util.Iterator<ByteBuffer> 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<byte[]>();
+ this.keys = new ArrayList<ByteBuffer>();
}
this.keys.add(elem);
}
- public List<byte[]> getKeys() {
+ public List<ByteBuffer> getKeys() {
return this.keys;
}
- public multiget_count_args setKeys(List<byte[]> keys) {
[... 4001 lines stripped ...]