You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by sl...@apache.org on 2011/04/10 19:31:15 UTC
svn commit: r1090842 [2/3] - in /cassandra/trunk: interface/
interface/thrift/gen-java/org/apache/cassandra/thrift/
src/java/org/apache/cassandra/cli/ src/java/org/apache/cassandra/db/
src/java/org/apache/cassandra/thrift/ test/system/ tools/stress/src...
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=1090842&r1=1090841&r2=1090842&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 Sun Apr 10 17:31:15 2011
@@ -133,15 +133,20 @@ public class Cassandra {
public void insert(ByteBuffer key, ColumnParent column_parent, Column column, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException;
/**
+ * Increment or decrement a counter.
+ *
+ * @param key
+ * @param column_parent
+ * @param column
+ * @param consistency_level
+ */
+ public void add(ByteBuffer key, ColumnParent column_parent, CounterColumn column, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException;
+
+ /**
* Remove data from the row specified by key at the granularity specified by column_path, and the given timestamp. Note
* that all the values in column_path besides column_path.column_family are truly optional: you can remove the entire
* row by just specifying the ColumnFamily, or you can remove a SuperColumn or a single Column by specifying those levels too.
*
- * Note that counters have limited support for deletes: if you remove
- * a counter, you must wait to issue any following update until the
- * delete has reached all the nodes and all of them have been fully
- * compacted.
- *
* @param key
* @param column_path
* @param timestamp
@@ -150,6 +155,17 @@ public class Cassandra {
public void remove(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException;
/**
+ * Remove a counter at the specified location.
+ * Note that counters have limited support for deletes: if you remove a counter, you must wait to issue any following update
+ * until the delete has reached all the nodes and all of them have been fully compacted.
+ *
+ * @param key
+ * @param path
+ * @param consistency_level
+ */
+ public void remove_counter(ByteBuffer key, ColumnPath path, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException;
+
+ /**
* Mutate many columns or super columns for many row keys. See also: Mutation.
*
* mutation_map maps key to column family to a list of Mutation objects to take place at that scope.
@@ -173,54 +189,6 @@ public class Cassandra {
public void truncate(String cfname) throws InvalidRequestException, UnavailableException, org.apache.thrift.TException;
/**
- * Increment or decrement a counter.
- *
- * @param key
- * @param column_parent
- * @param column
- * @param consistency_level
- */
- public void add(ByteBuffer key, ColumnParent column_parent, CounterColumn column, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException;
-
- /**
- * Return the counter at the specified column path.
- *
- * @param key
- * @param path
- * @param consistency_level
- */
- public Counter get_counter(ByteBuffer key, ColumnPath path, ConsistencyLevel consistency_level) throws InvalidRequestException, NotFoundException, UnavailableException, TimedOutException, org.apache.thrift.TException;
-
- /**
- * Get a list of counters from the specified columns.
- *
- * @param key
- * @param column_parent
- * @param predicate
- * @param consistency_level
- */
- public List<Counter> get_counter_slice(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException;
-
- /**
- * Get counter slices from multiple keys.
- *
- * @param keys
- * @param column_parent
- * @param predicate
- * @param consistency_level
- */
- public Map<ByteBuffer,List<Counter>> multiget_counter_slice(List<ByteBuffer> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException;
-
- /**
- * Remove a counter at the specified location.
- *
- * @param key
- * @param path
- * @param consistency_level
- */
- public void remove_counter(ByteBuffer key, ColumnPath path, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException;
-
- /**
* for each schema version present in the cluster, returns a list of nodes at that version.
* hosts that do not respond will be under the key DatabaseDescriptor.INITIAL_VERSION.
* the cluster is all on the same version if the size of the map is 1.
@@ -362,21 +330,15 @@ public class Cassandra {
public void insert(ByteBuffer key, ColumnParent column_parent, Column column, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.insert_call> resultHandler) throws org.apache.thrift.TException;
- public void remove(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.remove_call> resultHandler) throws org.apache.thrift.TException;
-
- public void batch_mutate(Map<ByteBuffer,Map<String,List<Mutation>>> mutation_map, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.batch_mutate_call> resultHandler) throws org.apache.thrift.TException;
-
- public void truncate(String cfname, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.truncate_call> resultHandler) throws org.apache.thrift.TException;
-
public void add(ByteBuffer key, ColumnParent column_parent, CounterColumn column, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.add_call> resultHandler) throws org.apache.thrift.TException;
- public void get_counter(ByteBuffer key, ColumnPath path, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.get_counter_call> resultHandler) throws org.apache.thrift.TException;
+ public void remove(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.remove_call> resultHandler) throws org.apache.thrift.TException;
- public void get_counter_slice(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.get_counter_slice_call> resultHandler) throws org.apache.thrift.TException;
+ public void remove_counter(ByteBuffer key, ColumnPath path, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.remove_counter_call> resultHandler) throws org.apache.thrift.TException;
- public void multiget_counter_slice(List<ByteBuffer> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.multiget_counter_slice_call> resultHandler) throws org.apache.thrift.TException;
+ public void batch_mutate(Map<ByteBuffer,Map<String,List<Mutation>>> mutation_map, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.batch_mutate_call> resultHandler) throws org.apache.thrift.TException;
- public void remove_counter(ByteBuffer key, ColumnPath path, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.remove_counter_call> resultHandler) throws org.apache.thrift.TException;
+ public void truncate(String cfname, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.truncate_call> resultHandler) throws org.apache.thrift.TException;
public void describe_schema_versions(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.describe_schema_versions_call> resultHandler) throws org.apache.thrift.TException;
@@ -907,133 +869,6 @@ public class Cassandra {
return;
}
- public void remove(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
- {
- send_remove(key, column_path, timestamp, consistency_level);
- recv_remove();
- }
-
- public void send_remove(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
- {
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
- remove_args args = new remove_args();
- args.setKey(key);
- args.setColumn_path(column_path);
- args.setTimestamp(timestamp);
- args.setConsistency_level(consistency_level);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
- }
-
- public void recv_remove() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
- {
- org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
- if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
- org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
- if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "remove failed: out of sequence response");
- }
- remove_result result = new remove_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
- if (result.ire != null) {
- throw result.ire;
- }
- if (result.ue != null) {
- throw result.ue;
- }
- if (result.te != null) {
- throw result.te;
- }
- return;
- }
-
- public void batch_mutate(Map<ByteBuffer,Map<String,List<Mutation>>> mutation_map, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
- {
- send_batch_mutate(mutation_map, consistency_level);
- recv_batch_mutate();
- }
-
- public void send_batch_mutate(Map<ByteBuffer,Map<String,List<Mutation>>> mutation_map, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
- {
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("batch_mutate", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
- batch_mutate_args args = new batch_mutate_args();
- args.setMutation_map(mutation_map);
- args.setConsistency_level(consistency_level);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
- }
-
- public void recv_batch_mutate() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
- {
- org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
- if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
- org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
- if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "batch_mutate failed: out of sequence response");
- }
- batch_mutate_result result = new batch_mutate_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
- if (result.ire != null) {
- throw result.ire;
- }
- if (result.ue != null) {
- throw result.ue;
- }
- if (result.te != null) {
- throw result.te;
- }
- return;
- }
-
- public void truncate(String cfname) throws InvalidRequestException, UnavailableException, org.apache.thrift.TException
- {
- send_truncate(cfname);
- recv_truncate();
- }
-
- public void send_truncate(String cfname) throws org.apache.thrift.TException
- {
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("truncate", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
- truncate_args args = new truncate_args();
- args.setCfname(cfname);
- args.write(oprot_);
- oprot_.writeMessageEnd();
- oprot_.getTransport().flush();
- }
-
- public void recv_truncate() throws InvalidRequestException, UnavailableException, org.apache.thrift.TException
- {
- org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
- if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
- org.apache.thrift.TApplicationException x = org.apache.thrift.TApplicationException.read(iprot_);
- iprot_.readMessageEnd();
- throw x;
- }
- if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "truncate failed: out of sequence response");
- }
- truncate_result result = new truncate_result();
- result.read(iprot_);
- iprot_.readMessageEnd();
- if (result.ire != null) {
- throw result.ire;
- }
- if (result.ue != null) {
- throw result.ue;
- }
- return;
- }
-
public void add(ByteBuffer key, ColumnParent column_parent, CounterColumn column, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
{
send_add(key, column_parent, column, consistency_level);
@@ -1079,25 +914,26 @@ public class Cassandra {
return;
}
- public Counter get_counter(ByteBuffer key, ColumnPath path, ConsistencyLevel consistency_level) throws InvalidRequestException, NotFoundException, UnavailableException, TimedOutException, org.apache.thrift.TException
+ public void remove(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
{
- send_get_counter(key, path, consistency_level);
- return recv_get_counter();
+ send_remove(key, column_path, timestamp, consistency_level);
+ recv_remove();
}
- public void send_get_counter(ByteBuffer key, ColumnPath path, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
+ public void send_remove(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_counter", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
- get_counter_args args = new get_counter_args();
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
+ remove_args args = new remove_args();
args.setKey(key);
- args.setPath(path);
+ args.setColumn_path(column_path);
+ args.setTimestamp(timestamp);
args.setConsistency_level(consistency_level);
args.write(oprot_);
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
- public Counter recv_get_counter() throws InvalidRequestException, NotFoundException, UnavailableException, TimedOutException, org.apache.thrift.TException
+ public void recv_remove() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
{
org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
@@ -1106,49 +942,42 @@ public class Cassandra {
throw x;
}
if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "get_counter failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "remove failed: out of sequence response");
}
- get_counter_result result = new get_counter_result();
+ remove_result result = new remove_result();
result.read(iprot_);
iprot_.readMessageEnd();
- if (result.isSetSuccess()) {
- return result.success;
- }
if (result.ire != null) {
throw result.ire;
}
- if (result.nfe != null) {
- throw result.nfe;
- }
if (result.ue != null) {
throw result.ue;
}
if (result.te != null) {
throw result.te;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_counter failed: unknown result");
+ return;
}
- public List<Counter> get_counter_slice(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
+ public void remove_counter(ByteBuffer key, ColumnPath path, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
{
- send_get_counter_slice(key, column_parent, predicate, consistency_level);
- return recv_get_counter_slice();
+ send_remove_counter(key, path, consistency_level);
+ recv_remove_counter();
}
- public void send_get_counter_slice(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
+ public void send_remove_counter(ByteBuffer key, ColumnPath path, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_counter_slice", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
- get_counter_slice_args args = new get_counter_slice_args();
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove_counter", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
+ remove_counter_args args = new remove_counter_args();
args.setKey(key);
- args.setColumn_parent(column_parent);
- args.setPredicate(predicate);
+ args.setPath(path);
args.setConsistency_level(consistency_level);
args.write(oprot_);
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
- public List<Counter> recv_get_counter_slice() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
+ public void recv_remove_counter() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
{
org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
@@ -1157,14 +986,11 @@ public class Cassandra {
throw x;
}
if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "get_counter_slice failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "remove_counter failed: out of sequence response");
}
- get_counter_slice_result result = new get_counter_slice_result();
+ remove_counter_result result = new remove_counter_result();
result.read(iprot_);
iprot_.readMessageEnd();
- if (result.isSetSuccess()) {
- return result.success;
- }
if (result.ire != null) {
throw result.ire;
}
@@ -1174,29 +1000,27 @@ public class Cassandra {
if (result.te != null) {
throw result.te;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get_counter_slice failed: unknown result");
+ return;
}
- public Map<ByteBuffer,List<Counter>> multiget_counter_slice(List<ByteBuffer> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
+ public void batch_mutate(Map<ByteBuffer,Map<String,List<Mutation>>> mutation_map, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
{
- send_multiget_counter_slice(keys, column_parent, predicate, consistency_level);
- return recv_multiget_counter_slice();
+ send_batch_mutate(mutation_map, consistency_level);
+ recv_batch_mutate();
}
- public void send_multiget_counter_slice(List<ByteBuffer> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
+ public void send_batch_mutate(Map<ByteBuffer,Map<String,List<Mutation>>> mutation_map, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("multiget_counter_slice", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
- multiget_counter_slice_args args = new multiget_counter_slice_args();
- args.setKeys(keys);
- args.setColumn_parent(column_parent);
- args.setPredicate(predicate);
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("batch_mutate", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
+ batch_mutate_args args = new batch_mutate_args();
+ args.setMutation_map(mutation_map);
args.setConsistency_level(consistency_level);
args.write(oprot_);
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
- public Map<ByteBuffer,List<Counter>> recv_multiget_counter_slice() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
+ public void recv_batch_mutate() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
{
org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
@@ -1205,14 +1029,11 @@ public class Cassandra {
throw x;
}
if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "multiget_counter_slice failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "batch_mutate failed: out of sequence response");
}
- multiget_counter_slice_result result = new multiget_counter_slice_result();
+ batch_mutate_result result = new batch_mutate_result();
result.read(iprot_);
iprot_.readMessageEnd();
- if (result.isSetSuccess()) {
- return result.success;
- }
if (result.ire != null) {
throw result.ire;
}
@@ -1222,28 +1043,26 @@ public class Cassandra {
if (result.te != null) {
throw result.te;
}
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "multiget_counter_slice failed: unknown result");
+ return;
}
- public void remove_counter(ByteBuffer key, ColumnPath path, ConsistencyLevel consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
+ public void truncate(String cfname) throws InvalidRequestException, UnavailableException, org.apache.thrift.TException
{
- send_remove_counter(key, path, consistency_level);
- recv_remove_counter();
+ send_truncate(cfname);
+ recv_truncate();
}
- public void send_remove_counter(ByteBuffer key, ColumnPath path, ConsistencyLevel consistency_level) throws org.apache.thrift.TException
+ public void send_truncate(String cfname) throws org.apache.thrift.TException
{
- oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove_counter", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
- remove_counter_args args = new remove_counter_args();
- args.setKey(key);
- args.setPath(path);
- args.setConsistency_level(consistency_level);
+ oprot_.writeMessageBegin(new org.apache.thrift.protocol.TMessage("truncate", org.apache.thrift.protocol.TMessageType.CALL, ++seqid_));
+ truncate_args args = new truncate_args();
+ args.setCfname(cfname);
args.write(oprot_);
oprot_.writeMessageEnd();
oprot_.getTransport().flush();
}
- public void recv_remove_counter() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException
+ public void recv_truncate() throws InvalidRequestException, UnavailableException, org.apache.thrift.TException
{
org.apache.thrift.protocol.TMessage msg = iprot_.readMessageBegin();
if (msg.type == org.apache.thrift.protocol.TMessageType.EXCEPTION) {
@@ -1252,9 +1071,9 @@ public class Cassandra {
throw x;
}
if (msg.seqid != seqid_) {
- throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "remove_counter failed: out of sequence response");
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.BAD_SEQUENCE_ID, "truncate failed: out of sequence response");
}
- remove_counter_result result = new remove_counter_result();
+ truncate_result result = new truncate_result();
result.read(iprot_);
iprot_.readMessageEnd();
if (result.ire != null) {
@@ -1263,9 +1082,6 @@ public class Cassandra {
if (result.ue != null) {
throw result.ue;
}
- if (result.te != null) {
- throw result.te;
- }
return;
}
@@ -2316,114 +2132,6 @@ public class Cassandra {
}
}
- public void remove(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<remove_call> resultHandler) throws org.apache.thrift.TException {
- checkReady();
- remove_call method_call = new remove_call(key, column_path, timestamp, consistency_level, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
- }
-
- public static class remove_call extends org.apache.thrift.async.TAsyncMethodCall {
- private ByteBuffer key;
- private ColumnPath column_path;
- private long timestamp;
- private ConsistencyLevel consistency_level;
- public remove_call(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<remove_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.key = key;
- this.column_path = column_path;
- this.timestamp = timestamp;
- this.consistency_level = consistency_level;
- }
-
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove", org.apache.thrift.protocol.TMessageType.CALL, 0));
- remove_args args = new remove_args();
- args.setKey(key);
- args.setColumn_path(column_path);
- args.setTimestamp(timestamp);
- args.setConsistency_level(consistency_level);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public void getResult() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException {
- if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_remove();
- }
- }
-
- public void batch_mutate(Map<ByteBuffer,Map<String,List<Mutation>>> mutation_map, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<batch_mutate_call> resultHandler) throws org.apache.thrift.TException {
- checkReady();
- batch_mutate_call method_call = new batch_mutate_call(mutation_map, consistency_level, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
- }
-
- public static class batch_mutate_call extends org.apache.thrift.async.TAsyncMethodCall {
- private Map<ByteBuffer,Map<String,List<Mutation>>> mutation_map;
- private ConsistencyLevel consistency_level;
- public batch_mutate_call(Map<ByteBuffer,Map<String,List<Mutation>>> mutation_map, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<batch_mutate_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.mutation_map = mutation_map;
- this.consistency_level = consistency_level;
- }
-
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("batch_mutate", org.apache.thrift.protocol.TMessageType.CALL, 0));
- batch_mutate_args args = new batch_mutate_args();
- args.setMutation_map(mutation_map);
- args.setConsistency_level(consistency_level);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public void getResult() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException {
- if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_batch_mutate();
- }
- }
-
- public void truncate(String cfname, org.apache.thrift.async.AsyncMethodCallback<truncate_call> resultHandler) throws org.apache.thrift.TException {
- checkReady();
- truncate_call method_call = new truncate_call(cfname, resultHandler, this, protocolFactory, transport);
- this.currentMethod = method_call;
- manager.call(method_call);
- }
-
- public static class truncate_call extends org.apache.thrift.async.TAsyncMethodCall {
- private String cfname;
- public truncate_call(String cfname, org.apache.thrift.async.AsyncMethodCallback<truncate_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
- super(client, protocolFactory, transport, resultHandler, false);
- this.cfname = cfname;
- }
-
- public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("truncate", org.apache.thrift.protocol.TMessageType.CALL, 0));
- truncate_args args = new truncate_args();
- args.setCfname(cfname);
- args.write(prot);
- prot.writeMessageEnd();
- }
-
- public void getResult() throws InvalidRequestException, UnavailableException, org.apache.thrift.TException {
- if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
- throw new IllegalStateException("Method call not finished!");
- }
- org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
- org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_truncate();
- }
- }
-
public void add(ByteBuffer key, ColumnParent column_parent, CounterColumn column, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<add_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
add_call method_call = new add_call(key, column_parent, column, consistency_level, resultHandler, this, protocolFactory, transport);
@@ -2465,161 +2173,149 @@ public class Cassandra {
}
}
- public void get_counter(ByteBuffer key, ColumnPath path, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<get_counter_call> resultHandler) throws org.apache.thrift.TException {
+ public void remove(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<remove_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- get_counter_call method_call = new get_counter_call(key, path, consistency_level, resultHandler, this, protocolFactory, transport);
+ remove_call method_call = new remove_call(key, column_path, timestamp, consistency_level, resultHandler, this, protocolFactory, transport);
this.currentMethod = method_call;
manager.call(method_call);
}
- public static class get_counter_call extends org.apache.thrift.async.TAsyncMethodCall {
+ public static class remove_call extends org.apache.thrift.async.TAsyncMethodCall {
private ByteBuffer key;
- private ColumnPath path;
+ private ColumnPath column_path;
+ private long timestamp;
private ConsistencyLevel consistency_level;
- public get_counter_call(ByteBuffer key, ColumnPath path, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<get_counter_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ public remove_call(ByteBuffer key, ColumnPath column_path, long timestamp, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<remove_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.key = key;
- this.path = path;
+ this.column_path = column_path;
+ this.timestamp = timestamp;
this.consistency_level = consistency_level;
}
public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_counter", org.apache.thrift.protocol.TMessageType.CALL, 0));
- get_counter_args args = new get_counter_args();
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ remove_args args = new remove_args();
args.setKey(key);
- args.setPath(path);
+ args.setColumn_path(column_path);
+ args.setTimestamp(timestamp);
args.setConsistency_level(consistency_level);
args.write(prot);
prot.writeMessageEnd();
}
- public Counter getResult() throws InvalidRequestException, NotFoundException, UnavailableException, TimedOutException, org.apache.thrift.TException {
+ public void getResult() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_get_counter();
+ (new Client(prot)).recv_remove();
}
}
- public void get_counter_slice(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<get_counter_slice_call> resultHandler) throws org.apache.thrift.TException {
+ public void remove_counter(ByteBuffer key, ColumnPath path, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<remove_counter_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- get_counter_slice_call method_call = new get_counter_slice_call(key, column_parent, predicate, consistency_level, resultHandler, this, protocolFactory, transport);
+ remove_counter_call method_call = new remove_counter_call(key, path, consistency_level, resultHandler, this, protocolFactory, transport);
this.currentMethod = method_call;
manager.call(method_call);
}
- public static class get_counter_slice_call extends org.apache.thrift.async.TAsyncMethodCall {
+ public static class remove_counter_call extends org.apache.thrift.async.TAsyncMethodCall {
private ByteBuffer key;
- private ColumnParent column_parent;
- private SlicePredicate predicate;
+ private ColumnPath path;
private ConsistencyLevel consistency_level;
- public get_counter_slice_call(ByteBuffer key, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<get_counter_slice_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ public remove_counter_call(ByteBuffer key, ColumnPath path, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<remove_counter_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
this.key = key;
- this.column_parent = column_parent;
- this.predicate = predicate;
+ this.path = path;
this.consistency_level = consistency_level;
}
public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_counter_slice", org.apache.thrift.protocol.TMessageType.CALL, 0));
- get_counter_slice_args args = new get_counter_slice_args();
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove_counter", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ remove_counter_args args = new remove_counter_args();
args.setKey(key);
- args.setColumn_parent(column_parent);
- args.setPredicate(predicate);
+ args.setPath(path);
args.setConsistency_level(consistency_level);
args.write(prot);
prot.writeMessageEnd();
}
- public List<Counter> getResult() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException {
+ public void getResult() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_get_counter_slice();
+ (new Client(prot)).recv_remove_counter();
}
}
- public void multiget_counter_slice(List<ByteBuffer> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<multiget_counter_slice_call> resultHandler) throws org.apache.thrift.TException {
+ public void batch_mutate(Map<ByteBuffer,Map<String,List<Mutation>>> mutation_map, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<batch_mutate_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- multiget_counter_slice_call method_call = new multiget_counter_slice_call(keys, column_parent, predicate, consistency_level, resultHandler, this, protocolFactory, transport);
+ batch_mutate_call method_call = new batch_mutate_call(mutation_map, consistency_level, resultHandler, this, protocolFactory, transport);
this.currentMethod = method_call;
manager.call(method_call);
}
- public static class multiget_counter_slice_call extends org.apache.thrift.async.TAsyncMethodCall {
- private List<ByteBuffer> keys;
- private ColumnParent column_parent;
- private SlicePredicate predicate;
+ public static class batch_mutate_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private Map<ByteBuffer,Map<String,List<Mutation>>> mutation_map;
private ConsistencyLevel consistency_level;
- public multiget_counter_slice_call(List<ByteBuffer> keys, ColumnParent column_parent, SlicePredicate predicate, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<multiget_counter_slice_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ public batch_mutate_call(Map<ByteBuffer,Map<String,List<Mutation>>> mutation_map, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<batch_mutate_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
- this.keys = keys;
- this.column_parent = column_parent;
- this.predicate = predicate;
+ this.mutation_map = mutation_map;
this.consistency_level = consistency_level;
}
public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("multiget_counter_slice", org.apache.thrift.protocol.TMessageType.CALL, 0));
- multiget_counter_slice_args args = new multiget_counter_slice_args();
- args.setKeys(keys);
- args.setColumn_parent(column_parent);
- args.setPredicate(predicate);
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("batch_mutate", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ batch_mutate_args args = new batch_mutate_args();
+ args.setMutation_map(mutation_map);
args.setConsistency_level(consistency_level);
args.write(prot);
prot.writeMessageEnd();
}
- public Map<ByteBuffer,List<Counter>> getResult() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException {
+ public void getResult() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- return (new Client(prot)).recv_multiget_counter_slice();
+ (new Client(prot)).recv_batch_mutate();
}
}
- public void remove_counter(ByteBuffer key, ColumnPath path, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<remove_counter_call> resultHandler) throws org.apache.thrift.TException {
+ public void truncate(String cfname, org.apache.thrift.async.AsyncMethodCallback<truncate_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
- remove_counter_call method_call = new remove_counter_call(key, path, consistency_level, resultHandler, this, protocolFactory, transport);
+ truncate_call method_call = new truncate_call(cfname, resultHandler, this, protocolFactory, transport);
this.currentMethod = method_call;
manager.call(method_call);
}
- public static class remove_counter_call extends org.apache.thrift.async.TAsyncMethodCall {
- private ByteBuffer key;
- private ColumnPath path;
- private ConsistencyLevel consistency_level;
- public remove_counter_call(ByteBuffer key, ColumnPath path, ConsistencyLevel consistency_level, org.apache.thrift.async.AsyncMethodCallback<remove_counter_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+ public static class truncate_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String cfname;
+ public truncate_call(String cfname, org.apache.thrift.async.AsyncMethodCallback<truncate_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
super(client, protocolFactory, transport, resultHandler, false);
- this.key = key;
- this.path = path;
- this.consistency_level = consistency_level;
+ this.cfname = cfname;
}
public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
- prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove_counter", org.apache.thrift.protocol.TMessageType.CALL, 0));
- remove_counter_args args = new remove_counter_args();
- args.setKey(key);
- args.setPath(path);
- args.setConsistency_level(consistency_level);
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("truncate", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ truncate_args args = new truncate_args();
+ args.setCfname(cfname);
args.write(prot);
prot.writeMessageEnd();
}
- public void getResult() throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException {
+ public void getResult() throws InvalidRequestException, UnavailableException, org.apache.thrift.TException {
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {
throw new IllegalStateException("Method call not finished!");
}
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
- (new Client(prot)).recv_remove_counter();
+ (new Client(prot)).recv_truncate();
}
}
@@ -3146,14 +2842,11 @@ public class Cassandra {
processMap_.put("get_range_slices", new get_range_slices());
processMap_.put("get_indexed_slices", new get_indexed_slices());
processMap_.put("insert", new insert());
+ processMap_.put("add", new add());
processMap_.put("remove", new remove());
+ processMap_.put("remove_counter", new remove_counter());
processMap_.put("batch_mutate", new batch_mutate());
processMap_.put("truncate", new truncate());
- processMap_.put("add", new add());
- processMap_.put("get_counter", new get_counter());
- processMap_.put("get_counter_slice", new get_counter_slice());
- processMap_.put("multiget_counter_slice", new multiget_counter_slice());
- processMap_.put("remove_counter", new remove_counter());
processMap_.put("describe_schema_versions", new describe_schema_versions());
processMap_.put("describe_keyspaces", new describe_keyspaces());
processMap_.put("describe_cluster_name", new describe_cluster_name());
@@ -3614,25 +3307,25 @@ public class Cassandra {
}
- private class remove implements ProcessFunction {
+ private class add implements ProcessFunction {
public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
{
- remove_args args = new remove_args();
+ add_args args = new add_args();
try {
args.read(iprot);
} catch (org.apache.thrift.protocol.TProtocolException e) {
iprot.readMessageEnd();
org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage());
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
+ oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("add", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
x.write(oprot);
oprot.writeMessageEnd();
oprot.getTransport().flush();
return;
}
iprot.readMessageEnd();
- remove_result result = new remove_result();
+ add_result result = new add_result();
try {
- iface_.remove(args.key, args.column_path, args.timestamp, args.consistency_level);
+ iface_.add(args.key, args.column_parent, args.column, args.consistency_level);
} catch (InvalidRequestException ire) {
result.ire = ire;
} catch (UnavailableException ue) {
@@ -3640,15 +3333,15 @@ public class Cassandra {
} catch (TimedOutException te) {
result.te = te;
} catch (Throwable th) {
- LOGGER.error("Internal error processing remove", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing remove");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
+ LOGGER.error("Internal error processing add", th);
+ org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing add");
+ oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("add", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
x.write(oprot);
oprot.writeMessageEnd();
oprot.getTransport().flush();
return;
}
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
+ oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("add", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
result.write(oprot);
oprot.writeMessageEnd();
oprot.getTransport().flush();
@@ -3656,25 +3349,25 @@ public class Cassandra {
}
- private class batch_mutate implements ProcessFunction {
+ private class remove implements ProcessFunction {
public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
{
- batch_mutate_args args = new batch_mutate_args();
+ remove_args args = new remove_args();
try {
args.read(iprot);
} catch (org.apache.thrift.protocol.TProtocolException e) {
iprot.readMessageEnd();
org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage());
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("batch_mutate", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
+ oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
x.write(oprot);
oprot.writeMessageEnd();
oprot.getTransport().flush();
return;
}
iprot.readMessageEnd();
- batch_mutate_result result = new batch_mutate_result();
+ remove_result result = new remove_result();
try {
- iface_.batch_mutate(args.mutation_map, args.consistency_level);
+ iface_.remove(args.key, args.column_path, args.timestamp, args.consistency_level);
} catch (InvalidRequestException ire) {
result.ire = ire;
} catch (UnavailableException ue) {
@@ -3682,15 +3375,15 @@ public class Cassandra {
} catch (TimedOutException te) {
result.te = te;
} catch (Throwable th) {
- LOGGER.error("Internal error processing batch_mutate", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing batch_mutate");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("batch_mutate", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
+ LOGGER.error("Internal error processing remove", th);
+ org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing remove");
+ oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
x.write(oprot);
oprot.writeMessageEnd();
oprot.getTransport().flush();
return;
}
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("batch_mutate", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
+ oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
result.write(oprot);
oprot.writeMessageEnd();
oprot.getTransport().flush();
@@ -3698,151 +3391,25 @@ public class Cassandra {
}
- private class truncate implements ProcessFunction {
+ private class remove_counter implements ProcessFunction {
public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
{
- truncate_args args = new truncate_args();
+ remove_counter_args args = new remove_counter_args();
try {
args.read(iprot);
} catch (org.apache.thrift.protocol.TProtocolException e) {
iprot.readMessageEnd();
org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage());
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("truncate", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
+ oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove_counter", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
x.write(oprot);
oprot.writeMessageEnd();
oprot.getTransport().flush();
return;
}
iprot.readMessageEnd();
- truncate_result result = new truncate_result();
+ remove_counter_result result = new remove_counter_result();
try {
- iface_.truncate(args.cfname);
- } catch (InvalidRequestException ire) {
- result.ire = ire;
- } catch (UnavailableException ue) {
- result.ue = ue;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing truncate", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing truncate");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("truncate", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("truncate", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- }
-
- }
-
- private class add implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- add_args args = new add_args();
- try {
- args.read(iprot);
- } catch (org.apache.thrift.protocol.TProtocolException e) {
- iprot.readMessageEnd();
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage());
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("add", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
- add_result result = new add_result();
- try {
- iface_.add(args.key, args.column_parent, args.column, args.consistency_level);
- } catch (InvalidRequestException ire) {
- result.ire = ire;
- } catch (UnavailableException ue) {
- result.ue = ue;
- } catch (TimedOutException te) {
- result.te = te;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing add", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing add");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("add", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("add", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- }
-
- }
-
- private class get_counter implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- get_counter_args args = new get_counter_args();
- try {
- args.read(iprot);
- } catch (org.apache.thrift.protocol.TProtocolException e) {
- iprot.readMessageEnd();
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage());
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_counter", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
- get_counter_result result = new get_counter_result();
- try {
- result.success = iface_.get_counter(args.key, args.path, args.consistency_level);
- } catch (InvalidRequestException ire) {
- result.ire = ire;
- } catch (NotFoundException nfe) {
- result.nfe = nfe;
- } catch (UnavailableException ue) {
- result.ue = ue;
- } catch (TimedOutException te) {
- result.te = te;
- } catch (Throwable th) {
- LOGGER.error("Internal error processing get_counter", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing get_counter");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_counter", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_counter", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
- result.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- }
-
- }
-
- private class get_counter_slice implements ProcessFunction {
- public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
- {
- get_counter_slice_args args = new get_counter_slice_args();
- try {
- args.read(iprot);
- } catch (org.apache.thrift.protocol.TProtocolException e) {
- iprot.readMessageEnd();
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage());
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_counter_slice", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
- x.write(oprot);
- oprot.writeMessageEnd();
- oprot.getTransport().flush();
- return;
- }
- iprot.readMessageEnd();
- get_counter_slice_result result = new get_counter_slice_result();
- try {
- result.success = iface_.get_counter_slice(args.key, args.column_parent, args.predicate, args.consistency_level);
+ iface_.remove_counter(args.key, args.path, args.consistency_level);
} catch (InvalidRequestException ire) {
result.ire = ire;
} catch (UnavailableException ue) {
@@ -3850,15 +3417,15 @@ public class Cassandra {
} catch (TimedOutException te) {
result.te = te;
} catch (Throwable th) {
- LOGGER.error("Internal error processing get_counter_slice", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing get_counter_slice");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_counter_slice", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
+ LOGGER.error("Internal error processing remove_counter", th);
+ org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing remove_counter");
+ oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove_counter", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
x.write(oprot);
oprot.writeMessageEnd();
oprot.getTransport().flush();
return;
}
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get_counter_slice", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
+ oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove_counter", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
result.write(oprot);
oprot.writeMessageEnd();
oprot.getTransport().flush();
@@ -3866,25 +3433,25 @@ public class Cassandra {
}
- private class multiget_counter_slice implements ProcessFunction {
+ private class batch_mutate implements ProcessFunction {
public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
{
- multiget_counter_slice_args args = new multiget_counter_slice_args();
+ batch_mutate_args args = new batch_mutate_args();
try {
args.read(iprot);
} catch (org.apache.thrift.protocol.TProtocolException e) {
iprot.readMessageEnd();
org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage());
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("multiget_counter_slice", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
+ oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("batch_mutate", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
x.write(oprot);
oprot.writeMessageEnd();
oprot.getTransport().flush();
return;
}
iprot.readMessageEnd();
- multiget_counter_slice_result result = new multiget_counter_slice_result();
+ batch_mutate_result result = new batch_mutate_result();
try {
- result.success = iface_.multiget_counter_slice(args.keys, args.column_parent, args.predicate, args.consistency_level);
+ iface_.batch_mutate(args.mutation_map, args.consistency_level);
} catch (InvalidRequestException ire) {
result.ire = ire;
} catch (UnavailableException ue) {
@@ -3892,15 +3459,15 @@ public class Cassandra {
} catch (TimedOutException te) {
result.te = te;
} catch (Throwable th) {
- LOGGER.error("Internal error processing multiget_counter_slice", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing multiget_counter_slice");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("multiget_counter_slice", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
+ LOGGER.error("Internal error processing batch_mutate", th);
+ org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing batch_mutate");
+ oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("batch_mutate", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
x.write(oprot);
oprot.writeMessageEnd();
oprot.getTransport().flush();
return;
}
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("multiget_counter_slice", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
+ oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("batch_mutate", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
result.write(oprot);
oprot.writeMessageEnd();
oprot.getTransport().flush();
@@ -3908,41 +3475,39 @@ public class Cassandra {
}
- private class remove_counter implements ProcessFunction {
+ private class truncate implements ProcessFunction {
public void process(int seqid, org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
{
- remove_counter_args args = new remove_counter_args();
+ truncate_args args = new truncate_args();
try {
args.read(iprot);
} catch (org.apache.thrift.protocol.TProtocolException e) {
iprot.readMessageEnd();
org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.PROTOCOL_ERROR, e.getMessage());
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove_counter", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
+ oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("truncate", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
x.write(oprot);
oprot.writeMessageEnd();
oprot.getTransport().flush();
return;
}
iprot.readMessageEnd();
- remove_counter_result result = new remove_counter_result();
+ truncate_result result = new truncate_result();
try {
- iface_.remove_counter(args.key, args.path, args.consistency_level);
+ iface_.truncate(args.cfname);
} catch (InvalidRequestException ire) {
result.ire = ire;
} catch (UnavailableException ue) {
result.ue = ue;
- } catch (TimedOutException te) {
- result.te = te;
} catch (Throwable th) {
- LOGGER.error("Internal error processing remove_counter", th);
- org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing remove_counter");
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove_counter", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
+ LOGGER.error("Internal error processing truncate", th);
+ org.apache.thrift.TApplicationException x = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, "Internal error processing truncate");
+ oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("truncate", org.apache.thrift.protocol.TMessageType.EXCEPTION, seqid));
x.write(oprot);
oprot.writeMessageEnd();
oprot.getTransport().flush();
return;
}
- oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("remove_counter", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
+ oprot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("truncate", org.apache.thrift.protocol.TMessageType.REPLY, seqid));
result.write(oprot);
oprot.writeMessageEnd();
oprot.getTransport().flush();
@@ -15737,17 +15302,17 @@ public class Cassandra {
}
- public static class remove_args implements org.apache.thrift.TBase<remove_args, remove_args._Fields>, java.io.Serializable, Cloneable {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("remove_args");
+ public static class add_args implements org.apache.thrift.TBase<add_args, add_args._Fields>, java.io.Serializable, Cloneable {
+ private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("add_args");
private static final org.apache.thrift.protocol.TField KEY_FIELD_DESC = new org.apache.thrift.protocol.TField("key", org.apache.thrift.protocol.TType.STRING, (short)1);
- private static final org.apache.thrift.protocol.TField COLUMN_PATH_FIELD_DESC = new org.apache.thrift.protocol.TField("column_path", org.apache.thrift.protocol.TType.STRUCT, (short)2);
- private static final org.apache.thrift.protocol.TField TIMESTAMP_FIELD_DESC = new org.apache.thrift.protocol.TField("timestamp", org.apache.thrift.protocol.TType.I64, (short)3);
+ private static final org.apache.thrift.protocol.TField COLUMN_PARENT_FIELD_DESC = new org.apache.thrift.protocol.TField("column_parent", org.apache.thrift.protocol.TType.STRUCT, (short)2);
+ private static final org.apache.thrift.protocol.TField COLUMN_FIELD_DESC = new org.apache.thrift.protocol.TField("column", org.apache.thrift.protocol.TType.STRUCT, (short)3);
private static final org.apache.thrift.protocol.TField CONSISTENCY_LEVEL_FIELD_DESC = new org.apache.thrift.protocol.TField("consistency_level", org.apache.thrift.protocol.TType.I32, (short)4);
public ByteBuffer key;
- public ColumnPath column_path;
- public long timestamp;
+ public ColumnParent column_parent;
+ public CounterColumn column;
/**
*
* @see ConsistencyLevel
@@ -15757,8 +15322,8 @@ public class Cassandra {
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
KEY((short)1, "key"),
- COLUMN_PATH((short)2, "column_path"),
- TIMESTAMP((short)3, "timestamp"),
+ COLUMN_PARENT((short)2, "column_parent"),
+ COLUMN((short)3, "column"),
/**
*
* @see ConsistencyLevel
@@ -15780,10 +15345,10 @@ public class Cassandra {
switch(fieldId) {
case 1: // KEY
return KEY;
- case 2: // COLUMN_PATH
- return COLUMN_PATH;
- case 3: // TIMESTAMP
- return TIMESTAMP;
+ case 2: // COLUMN_PARENT
+ return COLUMN_PARENT;
+ case 3: // COLUMN
+ return COLUMN;
case 4: // CONSISTENCY_LEVEL
return CONSISTENCY_LEVEL;
default:
@@ -15826,72 +15391,68 @@ public class Cassandra {
}
// isset id assignments
- private static final int __TIMESTAMP_ISSET_ID = 0;
- private BitSet __isset_bit_vector = new BitSet(1);
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
static {
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
tmpMap.put(_Fields.KEY, new org.apache.thrift.meta_data.FieldMetaData("key", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true)));
- tmpMap.put(_Fields.COLUMN_PATH, new org.apache.thrift.meta_data.FieldMetaData("column_path", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ColumnPath.class)));
- tmpMap.put(_Fields.TIMESTAMP, new org.apache.thrift.meta_data.FieldMetaData("timestamp", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
- tmpMap.put(_Fields.CONSISTENCY_LEVEL, new org.apache.thrift.meta_data.FieldMetaData("consistency_level", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.COLUMN_PARENT, new org.apache.thrift.meta_data.FieldMetaData("column_parent", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ColumnParent.class)));
+ tmpMap.put(_Fields.COLUMN, new org.apache.thrift.meta_data.FieldMetaData("column", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, CounterColumn.class)));
+ tmpMap.put(_Fields.CONSISTENCY_LEVEL, new org.apache.thrift.meta_data.FieldMetaData("consistency_level", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, ConsistencyLevel.class)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(remove_args.class, metaDataMap);
+ org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(add_args.class, metaDataMap);
}
- public remove_args() {
+ public add_args() {
this.consistency_level = org.apache.cassandra.thrift.ConsistencyLevel.ONE;
}
- public remove_args(
+ public add_args(
ByteBuffer key,
- ColumnPath column_path,
- long timestamp,
+ ColumnParent column_parent,
+ CounterColumn column,
ConsistencyLevel consistency_level)
{
this();
this.key = key;
- this.column_path = column_path;
- this.timestamp = timestamp;
- setTimestampIsSet(true);
+ this.column_parent = column_parent;
+ this.column = column;
this.consistency_level = consistency_level;
}
/**
* Performs a deep copy on <i>other</i>.
*/
- public remove_args(remove_args other) {
- __isset_bit_vector.clear();
- __isset_bit_vector.or(other.__isset_bit_vector);
+ public add_args(add_args other) {
if (other.isSetKey()) {
this.key = org.apache.thrift.TBaseHelper.copyBinary(other.key);
;
}
- if (other.isSetColumn_path()) {
- this.column_path = new ColumnPath(other.column_path);
+ if (other.isSetColumn_parent()) {
+ this.column_parent = new ColumnParent(other.column_parent);
+ }
+ if (other.isSetColumn()) {
+ this.column = new CounterColumn(other.column);
}
- this.timestamp = other.timestamp;
if (other.isSetConsistency_level()) {
this.consistency_level = other.consistency_level;
}
}
- public remove_args deepCopy() {
- return new remove_args(this);
+ public add_args deepCopy() {
+ return new add_args(this);
}
@Override
public void clear() {
this.key = null;
- this.column_path = null;
- setTimestampIsSet(false);
- this.timestamp = 0;
+ this.column_parent = null;
+ this.column = null;
this.consistency_level = org.apache.cassandra.thrift.ConsistencyLevel.ONE;
}
@@ -15905,12 +15466,12 @@ public class Cassandra {
return key;
}
- public remove_args setKey(byte[] key) {
+ public add_args setKey(byte[] key) {
setKey(key == null ? (ByteBuffer)null : ByteBuffer.wrap(key));
return this;
}
- public remove_args setKey(ByteBuffer key) {
+ public add_args setKey(ByteBuffer key) {
this.key = key;
return this;
}
@@ -15930,51 +15491,52 @@ public class Cassandra {
}
}
- public ColumnPath getColumn_path() {
- return this.column_path;
+ public ColumnParent getColumn_parent() {
+ return this.column_parent;
}
- public remove_args setColumn_path(ColumnPath column_path) {
- this.column_path = column_path;
+ public add_args setColumn_parent(ColumnParent column_parent) {
+ this.column_parent = column_parent;
return this;
}
- public void unsetColumn_path() {
- this.column_path = null;
+ public void unsetColumn_parent() {
+ this.column_parent = null;
}
- /** Returns true if field column_path is set (has been assigned a value) and false otherwise */
- public boolean isSetColumn_path() {
- return this.column_path != null;
+ /** Returns true if field column_parent is set (has been assigned a value) and false otherwise */
+ public boolean isSetColumn_parent() {
+ return this.column_parent != null;
}
- public void setColumn_pathIsSet(boolean value) {
+ public void setColumn_parentIsSet(boolean value) {
if (!value) {
- this.column_path = null;
+ this.column_parent = null;
}
}
- public long getTimestamp() {
- return this.timestamp;
+ public CounterColumn getColumn() {
+ return this.column;
}
- public remove_args setTimestamp(long timestamp) {
- this.timestamp = timestamp;
- setTimestampIsSet(true);
+ public add_args setColumn(CounterColumn column) {
+ this.column = column;
return this;
}
- public void unsetTimestamp() {
- __isset_bit_vector.clear(__TIMESTAMP_ISSET_ID);
+ public void unsetColumn() {
+ this.column = null;
}
- /** Returns true if field timestamp is set (has been assigned a value) and false otherwise */
- public boolean isSetTimestamp() {
- return __isset_bit_vector.get(__TIMESTAMP_ISSET_ID);
+ /** Returns true if field column is set (has been assigned a value) and false otherwise */
+ public boolean isSetColumn() {
+ return this.column != null;
}
- public void setTimestampIsSet(boolean value) {
- __isset_bit_vector.set(__TIMESTAMP_ISSET_ID, value);
+ public void setColumnIsSet(boolean value) {
+ if (!value) {
+ this.column = null;
+ }
}
/**
@@ -15989,7 +15551,7 @@ public class Cassandra {
*
* @see ConsistencyLevel
*/
- public remove_args setConsistency_level(ConsistencyLevel consistency_level) {
+ public add_args setConsistency_level(ConsistencyLevel consistency_level) {
this.consistency_level = consistency_level;
return this;
}
@@ -16019,19 +15581,19 @@ public class Cassandra {
}
break;
- case COLUMN_PATH:
+ case COLUMN_PARENT:
if (value == null) {
- unsetColumn_path();
+ unsetColumn_parent();
} else {
- setColumn_path((ColumnPath)value);
+ setColumn_parent((ColumnParent)value);
}
break;
- case TIMESTAMP:
+ case COLUMN:
if (value == null) {
- unsetTimestamp();
+ unsetColumn();
} else {
- setTimestamp((Long)value);
+ setColumn((CounterColumn)value);
}
break;
@@ -16051,11 +15613,11 @@ public class Cassandra {
case KEY:
return getKey();
- case COLUMN_PATH:
- return getColumn_path();
+ case COLUMN_PARENT:
+ return getColumn_parent();
- case TIMESTAMP:
- return new Long(getTimestamp());
+ case COLUMN:
+ return getColumn();
case CONSISTENCY_LEVEL:
return getConsistency_level();
@@ -16073,10 +15635,10 @@ public class Cassandra {
switch (field) {
case KEY:
return isSetKey();
- case COLUMN_PATH:
- return isSetColumn_path();
- case TIMESTAMP:
- return isSetTimestamp();
+ case COLUMN_PARENT:
+ return isSetColumn_parent();
+ case COLUMN:
+ return isSetColumn();
case CONSISTENCY_LEVEL:
return isSetConsistency_level();
}
@@ -16087,12 +15649,12 @@ public class Cassandra {
public boolean equals(Object that) {
if (that == null)
return false;
- if (that instanceof remove_args)
- return this.equals((remove_args)that);
+ if (that instanceof add_args)
+ return this.equals((add_args)that);
return false;
}
- public boolean equals(remove_args that) {
+ public boolean equals(add_args that) {
if (that == null)
return false;
@@ -16105,21 +15667,21 @@ public class Cassandra {
return false;
}
- boolean this_present_column_path = true && this.isSetColumn_path();
- boolean that_present_column_path = true && that.isSetColumn_path();
- if (this_present_column_path || that_present_column_path) {
- if (!(this_present_column_path && that_present_column_path))
+ boolean this_present_column_parent = true && this.isSetColumn_parent();
+ boolean that_present_column_parent = true && that.isSetColumn_parent();
+ if (this_present_column_parent || that_present_column_parent) {
+ if (!(this_present_column_parent && that_present_column_parent))
return false;
- if (!this.column_path.equals(that.column_path))
+ if (!this.column_parent.equals(that.column_parent))
return false;
}
- boolean this_present_timestamp = true;
- boolean that_present_timestamp = true;
- if (this_present_timestamp || that_present_timestamp) {
- if (!(this_present_timestamp && that_present_timestamp))
+ boolean this_present_column = true && this.isSetColumn();
+ boolean that_present_column = true && that.isSetColumn();
+ if (this_present_column || that_present_column) {
+ if (!(this_present_column && that_present_column))
return false;
- if (this.timestamp != that.timestamp)
+ if (!this.column.equals(that.column))
return false;
}
@@ -16144,15 +15706,15 @@ public class Cassandra {
if (present_key)
builder.append(key);
- boolean present_column_path = true && (isSetColumn_path());
- builder.append(present_column_path);
- if (present_column_path)
- builder.append(column_path);
+ boolean present_column_parent = true && (isSetColumn_parent());
+ builder.append(present_column_parent);
+ if (present_column_parent)
+ builder.append(column_parent);
- boolean present_timestamp = true;
- builder.append(present_timestamp);
- if (present_timestamp)
- builder.append(timestamp);
+ boolean present_column = true && (isSetColumn());
+ builder.append(present_column);
+ if (present_column)
+ builder.append(column);
boolean present_consistency_level = true && (isSetConsistency_level());
builder.append(present_consistency_level);
@@ -16162,13 +15724,13 @@ public class Cassandra {
return builder.toHashCode();
}
- public int compareTo(remove_args other) {
+ public int compareTo(add_args other) {
if (!getClass().equals(other.getClass())) {
return getClass().getName().compareTo(other.getClass().getName());
}
int lastComparison = 0;
- remove_args typedOther = (remove_args)other;
+ add_args typedOther = (add_args)other;
lastComparison = Boolean.valueOf(isSetKey()).compareTo(typedOther.isSetKey());
if (lastComparison != 0) {
@@ -16180,22 +15742,22 @@ public class Cassandra {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetColumn_path()).compareTo(typedOther.isSetColumn_path());
+ lastComparison = Boolean.valueOf(isSetColumn_parent()).compareTo(typedOther.isSetColumn_parent());
if (lastComparison != 0) {
return lastComparison;
}
- if (isSetColumn_path()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.column_path, typedOther.column_path);
+ if (isSetColumn_parent()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.column_parent, typedOther.column_parent);
if (lastComparison != 0) {
return lastComparison;
}
}
- lastComparison = Boolean.valueOf(isSetTimestamp()).compareTo(typedOther.isSetTimestamp());
[... 6877 lines stripped ...]