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 2013/12/06 16:52:22 UTC
[05/16] add describe_local_ring for Hadoop's benefit patch by Piotr Kołaczkowski; reviewed by jbellis for CASSANDRA-6268
http://git-wip-us.apache.org/repos/asf/cassandra/blob/86e949f3/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java
----------------------------------------------------------------------
diff --git a/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java b/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java
index 7edbbd0..5c8d286 100644
--- a/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java
+++ b/interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java
@@ -5,7 +5,7 @@
*/
package org.apache.cassandra.thrift;
/*
- *
+ *
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
@@ -13,16 +13,16 @@ package org.apache.cassandra.thrift;
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
- *
+ *
*/
@@ -53,7 +53,7 @@ public class Cassandra {
/**
* Get the Column or SuperColumn at the given column_path. If no value is present, NotFoundException is thrown. (This is
* the only method that can throw an exception under non-failure conditions.)
- *
+ *
* @param key
* @param column_path
* @param consistency_level
@@ -63,7 +63,7 @@ public class Cassandra {
/**
* Get the group of columns contained by column_parent (either a ColumnFamily name or a ColumnFamily/SuperColumn name
* pair) specified by the given SlicePredicate. If no matching values are found, an empty list is returned.
- *
+ *
* @param key
* @param column_parent
* @param predicate
@@ -74,7 +74,7 @@ public class Cassandra {
/**
* returns the number of columns matching <code>predicate</code> for a particular <code>key</code>,
* <code>ColumnFamily</code> and optionally <code>SuperColumn</code>.
- *
+ *
* @param key
* @param column_parent
* @param predicate
@@ -84,7 +84,7 @@ public class Cassandra {
/**
* Performs a get_slice for column_parent and predicate for the given keys in parallel.
- *
+ *
* @param keys
* @param column_parent
* @param predicate
@@ -94,7 +94,7 @@ public class Cassandra {
/**
* Perform a get_count in parallel on the given list<binary> keys. The return value maps keys to the count found.
- *
+ *
* @param keys
* @param column_parent
* @param predicate
@@ -104,7 +104,7 @@ public class Cassandra {
/**
* returns a subset of columns for a contiguous range of keys.
- *
+ *
* @param column_parent
* @param predicate
* @param range
@@ -114,7 +114,7 @@ public class Cassandra {
/**
* returns a range of columns, wrapping to the next rows if necessary to collect max_results.
- *
+ *
* @param column_family
* @param range
* @param start_column
@@ -124,8 +124,8 @@ public class Cassandra {
/**
* Returns the subset of columns specified in SlicePredicate for the rows matching the IndexClause
- * @deprecated; use get_range_slices instead with range.row_filter specified
- *
+ * @deprecated use get_range_slices instead with range.row_filter specified
+ *
* @param column_parent
* @param index_clause
* @param column_predicate
@@ -135,7 +135,7 @@ public class Cassandra {
/**
* Insert a Column at the given column_parent.column_family and optional column_parent.super_column.
- *
+ *
* @param key
* @param column_parent
* @param column
@@ -145,7 +145,7 @@ public class Cassandra {
/**
* Increment or decrement a counter.
- *
+ *
* @param key
* @param column_parent
* @param column
@@ -157,7 +157,7 @@ public class Cassandra {
* 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.
- *
+ *
* @param key
* @param column_path
* @param timestamp
@@ -169,7 +169,7 @@ public class Cassandra {
* 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
@@ -178,10 +178,10 @@ public class Cassandra {
/**
* 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.
* *
- *
+ *
* @param mutation_map
* @param consistency_level
*/
@@ -189,10 +189,10 @@ public class Cassandra {
/**
* Atomically 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.
* *
- *
+ *
* @param mutation_map
* @param consistency_level
*/
@@ -205,7 +205,7 @@ public class Cassandra {
* only marks the data as deleted.
* The operation succeeds only if all hosts in the cluster at available and will throw an UnavailableException if
* some hosts are down.
- *
+ *
* @param cfname
*/
public void truncate(String cfname) throws InvalidRequestException, UnavailableException, TimedOutException, org.apache.thrift.TException;
@@ -238,15 +238,22 @@ public class Cassandra {
* to list of endpoints, because you can't use Thrift structs as
* map keys:
* https://issues.apache.org/jira/browse/THRIFT-162
- *
+ *
* for the same reason, we can't return a set here, even though
* order is neither important nor predictable.
- *
+ *
* @param keyspace
*/
public List<TokenRange> describe_ring(String keyspace) throws InvalidRequestException, org.apache.thrift.TException;
/**
+ * same as describe_ring, but considers only nodes in the local DC
+ *
+ * @param keyspace
+ */
+ public List<TokenRange> describe_local_ring(String keyspace) throws InvalidRequestException, org.apache.thrift.TException;
+
+ /**
* get the mapping between token->node ip
* without taking replication into consideration
* https://issues.apache.org/jira/browse/CASSANDRA-4092
@@ -265,7 +272,7 @@ public class Cassandra {
/**
* describe specified keyspace
- *
+ *
* @param keyspace
*/
public KsDef describe_keyspace(String keyspace) throws NotFoundException, InvalidRequestException, org.apache.thrift.TException;
@@ -273,10 +280,10 @@ public class Cassandra {
/**
* experimental API for hadoop/parallel query support.
* may change violently and without warning.
- *
+ *
* returns list of token strings such that first subrange is (list[0], list[1]],
* next is (list[1], list[2]], etc.
- *
+ *
* @param cfName
* @param start_token
* @param end_token
@@ -294,42 +301,42 @@ public class Cassandra {
/**
* adds a column family. returns the new schema id.
- *
+ *
* @param cf_def
*/
public String system_add_column_family(CfDef cf_def) throws InvalidRequestException, SchemaDisagreementException, org.apache.thrift.TException;
/**
* drops a column family. returns the new schema id.
- *
+ *
* @param column_family
*/
public String system_drop_column_family(String column_family) throws InvalidRequestException, SchemaDisagreementException, org.apache.thrift.TException;
/**
* adds a keyspace and any column families that are part of it. returns the new schema id.
- *
+ *
* @param ks_def
*/
public String system_add_keyspace(KsDef ks_def) throws InvalidRequestException, SchemaDisagreementException, org.apache.thrift.TException;
/**
* drops a keyspace and any column families that are part of it. returns the new schema id.
- *
+ *
* @param keyspace
*/
public String system_drop_keyspace(String keyspace) throws InvalidRequestException, SchemaDisagreementException, org.apache.thrift.TException;
/**
* updates properties of a keyspace. returns the new schema id.
- *
+ *
* @param ks_def
*/
public String system_update_keyspace(KsDef ks_def) throws InvalidRequestException, SchemaDisagreementException, org.apache.thrift.TException;
/**
* updates properties of a column family. returns the new schema id.
- *
+ *
* @param cf_def
*/
public String system_update_column_family(CfDef cf_def) throws InvalidRequestException, SchemaDisagreementException, org.apache.thrift.TException;
@@ -337,7 +344,7 @@ public class Cassandra {
/**
* Executes a CQL (Cassandra Query Language) statement and returns a
* CqlResult containing the results.
- *
+ *
* @param query
* @param compression
*/
@@ -350,7 +357,7 @@ public class Cassandra {
* - the type of CQL statement
* - an id token of the compiled CQL stored on the server side.
* - a count of the discovered bound markers in the statement
- *
+ *
* @param query
* @param compression
*/
@@ -361,7 +368,7 @@ public class Cassandra {
/**
* Executes a prepared CQL (Cassandra Query Language) statement by passing an id token and a list of variables
* to bind and returns a CqlResult containing the results.
- *
+ *
* @param itemId
* @param values
*/
@@ -371,7 +378,7 @@ public class Cassandra {
/**
* @deprecated This is now a no-op. Please use the CQL3 specific methods instead.
- *
+ *
* @param version
*/
public void set_cql_version(String version) throws InvalidRequestException, org.apache.thrift.TException;
@@ -424,6 +431,8 @@ public class Cassandra {
public void describe_ring(String keyspace, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.describe_ring_call> resultHandler) throws org.apache.thrift.TException;
+ public void describe_local_ring(String keyspace, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.describe_local_ring_call> resultHandler) throws org.apache.thrift.TException;
+
public void describe_token_map(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.describe_token_map_call> resultHandler) throws org.apache.thrift.TException;
public void describe_partitioner(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.describe_partitioner_call> resultHandler) throws org.apache.thrift.TException;
@@ -1153,6 +1162,32 @@ public class Cassandra {
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "describe_ring failed: unknown result");
}
+ public List<TokenRange> describe_local_ring(String keyspace) throws InvalidRequestException, org.apache.thrift.TException
+ {
+ send_describe_local_ring(keyspace);
+ return recv_describe_local_ring();
+ }
+
+ public void send_describe_local_ring(String keyspace) throws org.apache.thrift.TException
+ {
+ describe_local_ring_args args = new describe_local_ring_args();
+ args.setKeyspace(keyspace);
+ sendBase("describe_local_ring", args);
+ }
+
+ public List<TokenRange> recv_describe_local_ring() throws InvalidRequestException, org.apache.thrift.TException
+ {
+ describe_local_ring_result result = new describe_local_ring_result();
+ receiveBase(result, "describe_local_ring");
+ if (result.isSetSuccess()) {
+ return result.success;
+ }
+ if (result.ire != null) {
+ throw result.ire;
+ }
+ throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "describe_local_ring failed: unknown result");
+ }
+
public Map<String,String> describe_token_map() throws InvalidRequestException, org.apache.thrift.TException
{
send_describe_token_map();
@@ -2546,6 +2581,38 @@ public class Cassandra {
}
}
+ public void describe_local_ring(String keyspace, org.apache.thrift.async.AsyncMethodCallback<describe_local_ring_call> resultHandler) throws org.apache.thrift.TException {
+ checkReady();
+ describe_local_ring_call method_call = new describe_local_ring_call(keyspace, resultHandler, this, ___protocolFactory, ___transport);
+ this.___currentMethod = method_call;
+ ___manager.call(method_call);
+ }
+
+ public static class describe_local_ring_call extends org.apache.thrift.async.TAsyncMethodCall {
+ private String keyspace;
+ public describe_local_ring_call(String keyspace, org.apache.thrift.async.AsyncMethodCallback<describe_local_ring_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.keyspace = keyspace;
+ }
+
+ public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
+ prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("describe_local_ring", org.apache.thrift.protocol.TMessageType.CALL, 0));
+ describe_local_ring_args args = new describe_local_ring_args();
+ args.setKeyspace(keyspace);
+ args.write(prot);
+ prot.writeMessageEnd();
+ }
+
+ public List<TokenRange> getResult() throws InvalidRequestException, 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_describe_local_ring();
+ }
+ }
+
public void describe_token_map(org.apache.thrift.async.AsyncMethodCallback<describe_token_map_call> resultHandler) throws org.apache.thrift.TException {
checkReady();
describe_token_map_call method_call = new describe_token_map_call(resultHandler, this, ___protocolFactory, ___transport);
@@ -3251,6 +3318,7 @@ public class Cassandra {
processMap.put("describe_cluster_name", new describe_cluster_name());
processMap.put("describe_version", new describe_version());
processMap.put("describe_ring", new describe_ring());
+ processMap.put("describe_local_ring", new describe_local_ring());
processMap.put("describe_token_map", new describe_token_map());
processMap.put("describe_partitioner", new describe_partitioner());
processMap.put("describe_snitch", new describe_snitch());
@@ -3771,6 +3839,26 @@ public class Cassandra {
}
}
+ private static class describe_local_ring<I extends Iface> extends org.apache.thrift.ProcessFunction<I, describe_local_ring_args> {
+ public describe_local_ring() {
+ super("describe_local_ring");
+ }
+
+ protected describe_local_ring_args getEmptyArgsInstance() {
+ return new describe_local_ring_args();
+ }
+
+ protected describe_local_ring_result getResult(I iface, describe_local_ring_args args) throws org.apache.thrift.TException {
+ describe_local_ring_result result = new describe_local_ring_result();
+ try {
+ result.success = iface.describe_local_ring(args.keyspace);
+ } catch (InvalidRequestException ire) {
+ result.ire = ire;
+ }
+ return result;
+ }
+ }
+
private static class describe_token_map<I extends Iface> extends org.apache.thrift.ProcessFunction<I, describe_token_map_args> {
public describe_token_map() {
super("describe_token_map");
@@ -4269,7 +4357,7 @@ public class Cassandra {
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.AUTH_REQUEST, new org.apache.thrift.meta_data.FieldMetaData("auth_request", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ tmpMap.put(_Fields.AUTH_REQUEST, new org.apache.thrift.meta_data.FieldMetaData("auth_request", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, AuthenticationRequest.class)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(login_args.class, metaDataMap);
@@ -4430,7 +4518,7 @@ public class Cassandra {
while (true)
{
field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (field.id) {
@@ -4438,7 +4526,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.auth_request = new AuthenticationRequest();
this.auth_request.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -4582,9 +4670,9 @@ public class Cassandra {
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.AUTHNX, new org.apache.thrift.meta_data.FieldMetaData("authnx", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.AUTHNX, new org.apache.thrift.meta_data.FieldMetaData("authnx", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
- tmpMap.put(_Fields.AUTHZX, new org.apache.thrift.meta_data.FieldMetaData("authzx", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.AUTHZX, new org.apache.thrift.meta_data.FieldMetaData("authzx", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(login_result.class, metaDataMap);
@@ -4812,7 +4900,7 @@ public class Cassandra {
while (true)
{
field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (field.id) {
@@ -4820,7 +4908,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.authnx = new AuthenticationException();
this.authnx.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -4828,7 +4916,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.authzx = new AuthorizationException();
this.authzx.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -4975,7 +5063,7 @@ public class Cassandra {
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.KEYSPACE, new org.apache.thrift.meta_data.FieldMetaData("keyspace", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ tmpMap.put(_Fields.KEYSPACE, new org.apache.thrift.meta_data.FieldMetaData("keyspace", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(set_keyspace_args.class, metaDataMap);
@@ -5136,14 +5224,14 @@ public class Cassandra {
while (true)
{
field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (field.id) {
case 1: // KEYSPACE
if (field.type == org.apache.thrift.protocol.TType.STRING) {
this.keyspace = iprot.readString();
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -5282,7 +5370,7 @@ public class Cassandra {
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.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(set_keyspace_result.class, metaDataMap);
@@ -5443,7 +5531,7 @@ public class Cassandra {
while (true)
{
field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (field.id) {
@@ -5451,7 +5539,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.ire = new InvalidRequestException();
this.ire.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -5526,7 +5614,7 @@ public class Cassandra {
public ByteBuffer key; // required
public ColumnPath column_path; // required
/**
- *
+ *
* @see ConsistencyLevel
*/
public ConsistencyLevel consistency_level; // required
@@ -5536,7 +5624,7 @@ public class Cassandra {
KEY((short)1, "key"),
COLUMN_PATH((short)2, "column_path"),
/**
- *
+ *
* @see ConsistencyLevel
*/
CONSISTENCY_LEVEL((short)3, "consistency_level");
@@ -5604,11 +5692,11 @@ public class Cassandra {
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,
+ 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,
+ 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.CONSISTENCY_LEVEL, new org.apache.thrift.meta_data.FieldMetaData("consistency_level", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ 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(get_args.class, metaDataMap);
@@ -5717,7 +5805,7 @@ public class Cassandra {
}
/**
- *
+ *
* @see ConsistencyLevel
*/
public ConsistencyLevel getConsistency_level() {
@@ -5725,7 +5813,7 @@ public class Cassandra {
}
/**
- *
+ *
* @see ConsistencyLevel
*/
public get_args setConsistency_level(ConsistencyLevel consistency_level) {
@@ -5925,14 +6013,14 @@ public class Cassandra {
while (true)
{
field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (field.id) {
case 1: // KEY
if (field.type == org.apache.thrift.protocol.TType.STRING) {
this.key = iprot.readBinary();
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -5940,14 +6028,14 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.column_path = new ColumnPath();
this.column_path.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
case 3: // CONSISTENCY_LEVEL
if (field.type == org.apache.thrift.protocol.TType.I32) {
this.consistency_level = ConsistencyLevel.findByValue(iprot.readI32());
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -6138,15 +6226,15 @@ public class Cassandra {
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.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ColumnOrSuperColumn.class)));
- tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
- tmpMap.put(_Fields.NFE, new org.apache.thrift.meta_data.FieldMetaData("nfe", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.NFE, new org.apache.thrift.meta_data.FieldMetaData("nfe", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
- tmpMap.put(_Fields.UE, new org.apache.thrift.meta_data.FieldMetaData("ue", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.UE, new org.apache.thrift.meta_data.FieldMetaData("ue", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
- tmpMap.put(_Fields.TE, new org.apache.thrift.meta_data.FieldMetaData("te", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.TE, new org.apache.thrift.meta_data.FieldMetaData("te", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(get_result.class, metaDataMap);
@@ -6575,7 +6663,7 @@ public class Cassandra {
while (true)
{
field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (field.id) {
@@ -6583,7 +6671,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.success = new ColumnOrSuperColumn();
this.success.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -6591,7 +6679,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.ire = new InvalidRequestException();
this.ire.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -6599,7 +6687,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.nfe = new NotFoundException();
this.nfe.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -6607,7 +6695,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.ue = new UnavailableException();
this.ue.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -6615,7 +6703,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.te = new TimedOutException();
this.te.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -6740,7 +6828,7 @@ public class Cassandra {
public ColumnParent column_parent; // required
public SlicePredicate predicate; // required
/**
- *
+ *
* @see ConsistencyLevel
*/
public ConsistencyLevel consistency_level; // required
@@ -6751,7 +6839,7 @@ public class Cassandra {
COLUMN_PARENT((short)2, "column_parent"),
PREDICATE((short)3, "predicate"),
/**
- *
+ *
* @see ConsistencyLevel
*/
CONSISTENCY_LEVEL((short)4, "consistency_level");
@@ -6821,13 +6909,13 @@ public class Cassandra {
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,
+ 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_PARENT, new org.apache.thrift.meta_data.FieldMetaData("column_parent", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ 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.PREDICATE, new org.apache.thrift.meta_data.FieldMetaData("predicate", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ tmpMap.put(_Fields.PREDICATE, new org.apache.thrift.meta_data.FieldMetaData("predicate", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, SlicePredicate.class)));
- tmpMap.put(_Fields.CONSISTENCY_LEVEL, new org.apache.thrift.meta_data.FieldMetaData("consistency_level", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ 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(get_slice_args.class, metaDataMap);
@@ -6966,7 +7054,7 @@ public class Cassandra {
}
/**
- *
+ *
* @see ConsistencyLevel
*/
public ConsistencyLevel getConsistency_level() {
@@ -6974,7 +7062,7 @@ public class Cassandra {
}
/**
- *
+ *
* @see ConsistencyLevel
*/
public get_slice_args setConsistency_level(ConsistencyLevel consistency_level) {
@@ -7211,14 +7299,14 @@ public class Cassandra {
while (true)
{
field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (field.id) {
case 1: // KEY
if (field.type == org.apache.thrift.protocol.TType.STRING) {
this.key = iprot.readBinary();
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -7226,7 +7314,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.column_parent = new ColumnParent();
this.column_parent.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -7234,14 +7322,14 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.predicate = new SlicePredicate();
this.predicate.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
case 4: // CONSISTENCY_LEVEL
if (field.type == org.apache.thrift.protocol.TType.I32) {
this.consistency_level = ConsistencyLevel.findByValue(iprot.readI32());
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -7443,14 +7531,14 @@ public class Cassandra {
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.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ColumnOrSuperColumn.class))));
- tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
- tmpMap.put(_Fields.UE, new org.apache.thrift.meta_data.FieldMetaData("ue", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.UE, new org.apache.thrift.meta_data.FieldMetaData("ue", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
- tmpMap.put(_Fields.TE, new org.apache.thrift.meta_data.FieldMetaData("te", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.TE, new org.apache.thrift.meta_data.FieldMetaData("te", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(get_slice_result.class, metaDataMap);
@@ -7831,7 +7919,7 @@ public class Cassandra {
while (true)
{
field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (field.id) {
@@ -7849,7 +7937,7 @@ public class Cassandra {
}
iprot.readListEnd();
}
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -7857,7 +7945,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.ire = new InvalidRequestException();
this.ire.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -7865,7 +7953,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.ue = new UnavailableException();
this.ue.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -7873,7 +7961,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.te = new TimedOutException();
this.te.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -7993,7 +8081,7 @@ public class Cassandra {
public ColumnParent column_parent; // required
public SlicePredicate predicate; // required
/**
- *
+ *
* @see ConsistencyLevel
*/
public ConsistencyLevel consistency_level; // required
@@ -8004,7 +8092,7 @@ public class Cassandra {
COLUMN_PARENT((short)2, "column_parent"),
PREDICATE((short)3, "predicate"),
/**
- *
+ *
* @see ConsistencyLevel
*/
CONSISTENCY_LEVEL((short)4, "consistency_level");
@@ -8074,13 +8162,13 @@ public class Cassandra {
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,
+ 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_PARENT, new org.apache.thrift.meta_data.FieldMetaData("column_parent", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ 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.PREDICATE, new org.apache.thrift.meta_data.FieldMetaData("predicate", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ tmpMap.put(_Fields.PREDICATE, new org.apache.thrift.meta_data.FieldMetaData("predicate", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, SlicePredicate.class)));
- tmpMap.put(_Fields.CONSISTENCY_LEVEL, new org.apache.thrift.meta_data.FieldMetaData("consistency_level", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ 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(get_count_args.class, metaDataMap);
@@ -8219,7 +8307,7 @@ public class Cassandra {
}
/**
- *
+ *
* @see ConsistencyLevel
*/
public ConsistencyLevel getConsistency_level() {
@@ -8227,7 +8315,7 @@ public class Cassandra {
}
/**
- *
+ *
* @see ConsistencyLevel
*/
public get_count_args setConsistency_level(ConsistencyLevel consistency_level) {
@@ -8464,14 +8552,14 @@ public class Cassandra {
while (true)
{
field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (field.id) {
case 1: // KEY
if (field.type == org.apache.thrift.protocol.TType.STRING) {
this.key = iprot.readBinary();
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -8479,7 +8567,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.column_parent = new ColumnParent();
this.column_parent.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -8487,14 +8575,14 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.predicate = new SlicePredicate();
this.predicate.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
case 4: // CONSISTENCY_LEVEL
if (field.type == org.apache.thrift.protocol.TType.I32) {
this.consistency_level = ConsistencyLevel.findByValue(iprot.readI32());
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -8698,13 +8786,13 @@ public class Cassandra {
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.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
- tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
- tmpMap.put(_Fields.UE, new org.apache.thrift.meta_data.FieldMetaData("ue", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.UE, new org.apache.thrift.meta_data.FieldMetaData("ue", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
- tmpMap.put(_Fields.TE, new org.apache.thrift.meta_data.FieldMetaData("te", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.TE, new org.apache.thrift.meta_data.FieldMetaData("te", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(get_count_result.class, metaDataMap);
@@ -9067,7 +9155,7 @@ public class Cassandra {
while (true)
{
field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (field.id) {
@@ -9075,7 +9163,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.I32) {
this.success = iprot.readI32();
setSuccessIsSet(true);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -9083,7 +9171,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.ire = new InvalidRequestException();
this.ire.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -9091,7 +9179,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.ue = new UnavailableException();
this.ue.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -9099,7 +9187,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.te = new TimedOutException();
this.te.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -9208,7 +9296,7 @@ public class Cassandra {
public ColumnParent column_parent; // required
public SlicePredicate predicate; // required
/**
- *
+ *
* @see ConsistencyLevel
*/
public ConsistencyLevel consistency_level; // required
@@ -9219,7 +9307,7 @@ public class Cassandra {
COLUMN_PARENT((short)2, "column_parent"),
PREDICATE((short)3, "predicate"),
/**
- *
+ *
* @see ConsistencyLevel
*/
CONSISTENCY_LEVEL((short)4, "consistency_level");
@@ -9289,14 +9377,14 @@ public class Cassandra {
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.KEYS, new org.apache.thrift.meta_data.FieldMetaData("keys", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ tmpMap.put(_Fields.KEYS, new org.apache.thrift.meta_data.FieldMetaData("keys", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true))));
- tmpMap.put(_Fields.COLUMN_PARENT, new org.apache.thrift.meta_data.FieldMetaData("column_parent", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ 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.PREDICATE, new org.apache.thrift.meta_data.FieldMetaData("predicate", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ tmpMap.put(_Fields.PREDICATE, new org.apache.thrift.meta_data.FieldMetaData("predicate", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, SlicePredicate.class)));
- tmpMap.put(_Fields.CONSISTENCY_LEVEL, new org.apache.thrift.meta_data.FieldMetaData("consistency_level", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ 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(multiget_slice_args.class, metaDataMap);
@@ -9445,7 +9533,7 @@ public class Cassandra {
}
/**
- *
+ *
* @see ConsistencyLevel
*/
public ConsistencyLevel getConsistency_level() {
@@ -9453,7 +9541,7 @@ public class Cassandra {
}
/**
- *
+ *
* @see ConsistencyLevel
*/
public multiget_slice_args setConsistency_level(ConsistencyLevel consistency_level) {
@@ -9690,7 +9778,7 @@ public class Cassandra {
while (true)
{
field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (field.id) {
@@ -9707,7 +9795,7 @@ public class Cassandra {
}
iprot.readListEnd();
}
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -9715,7 +9803,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.column_parent = new ColumnParent();
this.column_parent.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -9723,14 +9811,14 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.predicate = new SlicePredicate();
this.predicate.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
case 4: // CONSISTENCY_LEVEL
if (field.type == org.apache.thrift.protocol.TType.I32) {
this.consistency_level = ConsistencyLevel.findByValue(iprot.readI32());
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -9939,16 +10027,16 @@ public class Cassandra {
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.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true),
- new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true),
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, ColumnOrSuperColumn.class)))));
- tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
- tmpMap.put(_Fields.UE, new org.apache.thrift.meta_data.FieldMetaData("ue", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.UE, new org.apache.thrift.meta_data.FieldMetaData("ue", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
- tmpMap.put(_Fields.TE, new org.apache.thrift.meta_data.FieldMetaData("te", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.TE, new org.apache.thrift.meta_data.FieldMetaData("te", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(multiget_slice_result.class, metaDataMap);
@@ -10337,7 +10425,7 @@ public class Cassandra {
while (true)
{
field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (field.id) {
@@ -10367,7 +10455,7 @@ public class Cassandra {
}
iprot.readMapEnd();
}
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -10375,7 +10463,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.ire = new InvalidRequestException();
this.ire.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -10383,7 +10471,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.ue = new UnavailableException();
this.ue.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -10391,7 +10479,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.te = new TimedOutException();
this.te.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -10519,7 +10607,7 @@ public class Cassandra {
public ColumnParent column_parent; // required
public SlicePredicate predicate; // required
/**
- *
+ *
* @see ConsistencyLevel
*/
public ConsistencyLevel consistency_level; // required
@@ -10530,7 +10618,7 @@ public class Cassandra {
COLUMN_PARENT((short)2, "column_parent"),
PREDICATE((short)3, "predicate"),
/**
- *
+ *
* @see ConsistencyLevel
*/
CONSISTENCY_LEVEL((short)4, "consistency_level");
@@ -10600,14 +10688,14 @@ public class Cassandra {
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.KEYS, new org.apache.thrift.meta_data.FieldMetaData("keys", org.apache.thrift.TFieldRequirementType.REQUIRED,
- new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ tmpMap.put(_Fields.KEYS, new org.apache.thrift.meta_data.FieldMetaData("keys", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true))));
- tmpMap.put(_Fields.COLUMN_PARENT, new org.apache.thrift.meta_data.FieldMetaData("column_parent", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ 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.PREDICATE, new org.apache.thrift.meta_data.FieldMetaData("predicate", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ tmpMap.put(_Fields.PREDICATE, new org.apache.thrift.meta_data.FieldMetaData("predicate", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, SlicePredicate.class)));
- tmpMap.put(_Fields.CONSISTENCY_LEVEL, new org.apache.thrift.meta_data.FieldMetaData("consistency_level", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ 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(multiget_count_args.class, metaDataMap);
@@ -10756,7 +10844,7 @@ public class Cassandra {
}
/**
- *
+ *
* @see ConsistencyLevel
*/
public ConsistencyLevel getConsistency_level() {
@@ -10764,7 +10852,7 @@ public class Cassandra {
}
/**
- *
+ *
* @see ConsistencyLevel
*/
public multiget_count_args setConsistency_level(ConsistencyLevel consistency_level) {
@@ -11001,7 +11089,7 @@ public class Cassandra {
while (true)
{
field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (field.id) {
@@ -11018,7 +11106,7 @@ public class Cassandra {
}
iprot.readListEnd();
}
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -11026,7 +11114,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.column_parent = new ColumnParent();
this.column_parent.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -11034,14 +11122,14 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.predicate = new SlicePredicate();
this.predicate.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
case 4: // CONSISTENCY_LEVEL
if (field.type == org.apache.thrift.protocol.TType.I32) {
this.consistency_level = ConsistencyLevel.findByValue(iprot.readI32());
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -11250,15 +11338,15 @@ public class Cassandra {
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.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true),
+ tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true),
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))));
- tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
- tmpMap.put(_Fields.UE, new org.apache.thrift.meta_data.FieldMetaData("ue", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.UE, new org.apache.thrift.meta_data.FieldMetaData("ue", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
- tmpMap.put(_Fields.TE, new org.apache.thrift.meta_data.FieldMetaData("te", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.TE, new org.apache.thrift.meta_data.FieldMetaData("te", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(multiget_count_result.class, metaDataMap);
@@ -11644,7 +11732,7 @@ public class Cassandra {
while (true)
{
field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (field.id) {
@@ -11663,7 +11751,7 @@ public class Cassandra {
}
iprot.readMapEnd();
}
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -11671,7 +11759,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.ire = new InvalidRequestException();
this.ire.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -11679,7 +11767,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.ue = new UnavailableException();
this.ue.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -11687,7 +11775,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.te = new TimedOutException();
this.te.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -11808,7 +11896,7 @@ public class Cassandra {
public SlicePredicate predicate; // required
public KeyRange range; // required
/**
- *
+ *
* @see ConsistencyLevel
*/
public ConsistencyLevel consistency_level; // required
@@ -11819,7 +11907,7 @@ public class Cassandra {
PREDICATE((short)2, "predicate"),
RANGE((short)3, "range"),
/**
- *
+ *
* @see ConsistencyLevel
*/
CONSISTENCY_LEVEL((short)4, "consistency_level");
@@ -11889,13 +11977,13 @@ public class Cassandra {
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.COLUMN_PARENT, new org.apache.thrift.meta_data.FieldMetaData("column_parent", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ 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.PREDICATE, new org.apache.thrift.meta_data.FieldMetaData("predicate", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ tmpMap.put(_Fields.PREDICATE, new org.apache.thrift.meta_data.FieldMetaData("predicate", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, SlicePredicate.class)));
- tmpMap.put(_Fields.RANGE, new org.apache.thrift.meta_data.FieldMetaData("range", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ tmpMap.put(_Fields.RANGE, new org.apache.thrift.meta_data.FieldMetaData("range", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, KeyRange.class)));
- tmpMap.put(_Fields.CONSISTENCY_LEVEL, new org.apache.thrift.meta_data.FieldMetaData("consistency_level", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ 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(get_range_slices_args.class, metaDataMap);
@@ -12023,7 +12111,7 @@ public class Cassandra {
}
/**
- *
+ *
* @see ConsistencyLevel
*/
public ConsistencyLevel getConsistency_level() {
@@ -12031,7 +12119,7 @@ public class Cassandra {
}
/**
- *
+ *
* @see ConsistencyLevel
*/
public get_range_slices_args setConsistency_level(ConsistencyLevel consistency_level) {
@@ -12268,7 +12356,7 @@ public class Cassandra {
while (true)
{
field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (field.id) {
@@ -12276,7 +12364,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.column_parent = new ColumnParent();
this.column_parent.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -12284,7 +12372,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.predicate = new SlicePredicate();
this.predicate.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -12292,14 +12380,14 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.range = new KeyRange();
this.range.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
case 4: // CONSISTENCY_LEVEL
if (field.type == org.apache.thrift.protocol.TType.I32) {
this.consistency_level = ConsistencyLevel.findByValue(iprot.readI32());
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -12501,14 +12589,14 @@ public class Cassandra {
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.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, KeySlice.class))));
- tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
- tmpMap.put(_Fields.UE, new org.apache.thrift.meta_data.FieldMetaData("ue", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.UE, new org.apache.thrift.meta_data.FieldMetaData("ue", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
- tmpMap.put(_Fields.TE, new org.apache.thrift.meta_data.FieldMetaData("te", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.TE, new org.apache.thrift.meta_data.FieldMetaData("te", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(get_range_slices_result.class, metaDataMap);
@@ -12889,7 +12977,7 @@ public class Cassandra {
while (true)
{
field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (field.id) {
@@ -12907,7 +12995,7 @@ public class Cassandra {
}
iprot.readListEnd();
}
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -12915,7 +13003,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.ire = new InvalidRequestException();
this.ire.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -12923,7 +13011,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.ue = new UnavailableException();
this.ue.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -12931,7 +13019,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.te = new TimedOutException();
this.te.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -13051,7 +13139,7 @@ public class Cassandra {
public KeyRange range; // required
public ByteBuffer start_column; // required
/**
- *
+ *
* @see ConsistencyLevel
*/
public ConsistencyLevel consistency_level; // required
@@ -13062,7 +13150,7 @@ public class Cassandra {
RANGE((short)2, "range"),
START_COLUMN((short)3, "start_column"),
/**
- *
+ *
* @see ConsistencyLevel
*/
CONSISTENCY_LEVEL((short)4, "consistency_level");
@@ -13132,13 +13220,13 @@ public class Cassandra {
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.COLUMN_FAMILY, new org.apache.thrift.meta_data.FieldMetaData("column_family", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ tmpMap.put(_Fields.COLUMN_FAMILY, new org.apache.thrift.meta_data.FieldMetaData("column_family", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- tmpMap.put(_Fields.RANGE, new org.apache.thrift.meta_data.FieldMetaData("range", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ tmpMap.put(_Fields.RANGE, new org.apache.thrift.meta_data.FieldMetaData("range", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, KeyRange.class)));
- tmpMap.put(_Fields.START_COLUMN, new org.apache.thrift.meta_data.FieldMetaData("start_column", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ tmpMap.put(_Fields.START_COLUMN, new org.apache.thrift.meta_data.FieldMetaData("start_column", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true)));
- tmpMap.put(_Fields.CONSISTENCY_LEVEL, new org.apache.thrift.meta_data.FieldMetaData("consistency_level", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ 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(get_paged_slice_args.class, metaDataMap);
@@ -13277,7 +13365,7 @@ public class Cassandra {
}
/**
- *
+ *
* @see ConsistencyLevel
*/
public ConsistencyLevel getConsistency_level() {
@@ -13285,7 +13373,7 @@ public class Cassandra {
}
/**
- *
+ *
* @see ConsistencyLevel
*/
public get_paged_slice_args setConsistency_level(ConsistencyLevel consistency_level) {
@@ -13522,14 +13610,14 @@ public class Cassandra {
while (true)
{
field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (field.id) {
case 1: // COLUMN_FAMILY
if (field.type == org.apache.thrift.protocol.TType.STRING) {
this.column_family = iprot.readString();
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -13537,21 +13625,21 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.range = new KeyRange();
this.range.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
case 3: // START_COLUMN
if (field.type == org.apache.thrift.protocol.TType.STRING) {
this.start_column = iprot.readBinary();
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
case 4: // CONSISTENCY_LEVEL
if (field.type == org.apache.thrift.protocol.TType.I32) {
this.consistency_level = ConsistencyLevel.findByValue(iprot.readI32());
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -13753,14 +13841,14 @@ public class Cassandra {
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.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, KeySlice.class))));
- tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.IRE, new org.apache.thrift.meta_data.FieldMetaData("ire", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
- tmpMap.put(_Fields.UE, new org.apache.thrift.meta_data.FieldMetaData("ue", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.UE, new org.apache.thrift.meta_data.FieldMetaData("ue", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
- tmpMap.put(_Fields.TE, new org.apache.thrift.meta_data.FieldMetaData("te", org.apache.thrift.TFieldRequirementType.DEFAULT,
+ tmpMap.put(_Fields.TE, new org.apache.thrift.meta_data.FieldMetaData("te", org.apache.thrift.TFieldRequirementType.DEFAULT,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(get_paged_slice_result.class, metaDataMap);
@@ -14141,7 +14229,7 @@ public class Cassandra {
while (true)
{
field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
break;
}
switch (field.id) {
@@ -14159,7 +14247,7 @@ public class Cassandra {
}
iprot.readListEnd();
}
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -14167,7 +14255,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.ire = new InvalidRequestException();
this.ire.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -14175,7 +14263,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.ue = new UnavailableException();
this.ue.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -14183,7 +14271,7 @@ public class Cassandra {
if (field.type == org.apache.thrift.protocol.TType.STRUCT) {
this.te = new TimedOutException();
this.te.read(iprot);
- } else {
+ } else {
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
}
break;
@@ -14303,7 +14391,7 @@ public class Cassandra {
public IndexClause index_clause; // required
public SlicePredicate column_predicate; // required
/**
- *
+ *
* @see ConsistencyLevel
*/
public ConsistencyLevel consistency_level; // required
@@ -14314,7 +14402,7 @@ public class Cassandra {
INDEX_CLAUSE((short)2, "index_clause"),
COLUMN_PREDICATE((short)3, "column_predicate"),
/**
- *
+ *
* @see ConsistencyLevel
*/
CONSISTENCY_LEVEL((short)4, "consistency_level");
@@ -14384,13 +14472,13 @@ public class Cassandra {
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.COLUMN_PARENT, new org.apache.thrift.meta_data.FieldMetaData("column_parent", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ 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.INDEX_CLAUSE, new org.apache.thrift.meta_data.FieldMetaData("index_clause", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ tmpMap.put(_Fields.INDEX_CLAUSE, new org.apache.thrift.meta_data.FieldMetaData("index_clause", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, IndexClause.class)));
- tmpMap.put(_Fields.COLUMN_PREDICATE, new org.apache.thrift.meta_data.FieldMetaData("column_predicate", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ tmpMap.put(_Fields.COLUMN_PREDICATE, new org.apache.thrift.meta_data.FieldMetaData("column_predicate", org.apache.thrift.TFieldRequirementType.REQUIRED,
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, SlicePredicate.class)));
- tmpMap.put(_Fields.CONSISTENCY_LEVEL, new org.apache.thrift.meta_data.FieldMetaData("consistency_level", org.apache.thrift.TFieldRequirementType.REQUIRED,
+ 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(get_indexed_slices_args.class, metaDataMap);
@@ -14518,7 +14606,7 @@ public class Cassandra {
}
/**
- *
+ *
* @see ConsistencyLevel
*/
public ConsistencyLevel getConsistency_level() {
@@ -14526,7 +14614,7 @@ public class Cassandra {
}
/**
- *
+ *
* @see ConsistencyLevel
*/
public get_indexed_slices_args setConsistency_level(ConsistencyLevel consistency_level) {
@@ -14763,7 +14851,7 @@ public class Cassandra {
while (true)
{
field = iprot.readFieldBegin();
- if (field.type == org.apache.thrift.protocol.TType.STOP) {
+ if (field.type == org.apache.thrift.protocol.TType.STOP) {
<TRUNCATED>