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 2009/11/19 20:03:48 UTC
svn commit: r882248 [1/2] - in /incubator/cassandra/trunk: interface/
interface/gen-java/org/apache/cassandra/service/
src/java/org/apache/cassandra/cli/ src/java/org/apache/cassandra/service/
Author: jbellis
Date: Thu Nov 19 19:03:47 2009
New Revision: 882248
URL: http://svn.apache.org/viewvc?rev=882248&view=rev
Log:
expose TimedOutException distinct from UnavailableException
patch by jbellis; reviewed by gdusbabek for CASSANDRA-563
Added:
incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/TimedOutException.java
Modified:
incubator/cassandra/trunk/interface/cassandra.thrift
incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/Cassandra.java
incubator/cassandra/trunk/src/java/org/apache/cassandra/cli/CliClient.java
incubator/cassandra/trunk/src/java/org/apache/cassandra/service/CassandraServer.java
incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageProxy.java
Modified: incubator/cassandra/trunk/interface/cassandra.thrift
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/interface/cassandra.thrift?rev=882248&r1=882247&r2=882248&view=diff
==============================================================================
--- incubator/cassandra/trunk/interface/cassandra.thrift (original)
+++ incubator/cassandra/trunk/interface/cassandra.thrift Thu Nov 19 19:03:47 2009
@@ -81,6 +81,10 @@
exception UnavailableException {
}
+# RPC timeout was exceeded. either a node failed mid-operation, or load was too high, or the requested op was too large.
+exception TimedOutException {
+}
+
# (note that internal server errors will raise a TApplicationException, courtesy of Thrift)
@@ -132,33 +136,33 @@
2:required string key,
3:required ColumnPath column_path,
4:required ConsistencyLevel consistency_level=1)
- throws (1: InvalidRequestException ire, 2: NotFoundException nfe, 3: UnavailableException ue),
+ throws (1:InvalidRequestException ire, 2:NotFoundException nfe, 3:UnavailableException ue, 4:TimedOutException te),
list<ColumnOrSuperColumn> get_slice(1:required string keyspace,
2:required string key,
3:required ColumnParent column_parent,
4:required SlicePredicate predicate,
5:required ConsistencyLevel consistency_level=1)
- throws (1: InvalidRequestException ire, 3: UnavailableException ue),
+ throws (1:InvalidRequestException ire, 2:UnavailableException ue, 3:TimedOutException te),
map<string,ColumnOrSuperColumn> multiget(1:required string keyspace,
2:required list<string> keys,
3:required ColumnPath column_path,
4:required ConsistencyLevel consistency_level=1)
- throws (1: InvalidRequestException ire, 2: UnavailableException ue),
+ throws (1:InvalidRequestException ire, 2:UnavailableException ue, 3:TimedOutException te),
map<string,list<ColumnOrSuperColumn>> multiget_slice(1:required string keyspace,
2:required list<string> keys,
3:required ColumnParent column_parent,
4:required SlicePredicate predicate,
5:required ConsistencyLevel consistency_level=1)
- throws (1: InvalidRequestException ire, 2: UnavailableException ue),
+ throws (1:InvalidRequestException ire, 2:UnavailableException ue, 3:TimedOutException te),
i32 get_count(1:required string keyspace,
2:required string key,
3:required ColumnParent column_parent,
4:required ConsistencyLevel consistency_level=1)
- throws (1: InvalidRequestException ire, 2: UnavailableException ue),
+ throws (1:InvalidRequestException ire, 2:UnavailableException ue, 3:TimedOutException te),
/** @deprecated; use get_range_slice instead */
list<string> get_key_range(1:required string keyspace,
@@ -167,7 +171,7 @@
4:required string finish="",
5:required i32 count=100,
6:required ConsistencyLevel consistency_level=1)
- throws (1: InvalidRequestException ire, 2: UnavailableException ue),
+ throws (1:InvalidRequestException ire, 2:UnavailableException ue, 3:TimedOutException te),
list<KeySlice> get_range_slice(1:required string keyspace,
2:required ColumnParent column_parent,
@@ -176,7 +180,7 @@
5:required string finish_key="",
6:required i32 row_count=100,
7:required ConsistencyLevel consistency_level=1)
- throws (1: InvalidRequestException ire, 2: UnavailableException ue),
+ throws (1:InvalidRequestException ire, 2:UnavailableException ue, 3:TimedOutException te),
# modification methods
void insert(1:required string keyspace,
@@ -185,20 +189,20 @@
4:required binary value,
5:required i64 timestamp,
6:required ConsistencyLevel consistency_level=0)
- throws (1: InvalidRequestException ire, 2: UnavailableException ue),
+ throws (1:InvalidRequestException ire, 2:UnavailableException ue, 3:TimedOutException te),
void batch_insert(1:required string keyspace,
2:required string key,
3:required map<string, list<ColumnOrSuperColumn>> cfmap,
4:required ConsistencyLevel consistency_level=0)
- throws (1: InvalidRequestException ire, 2: UnavailableException ue),
+ throws (1:InvalidRequestException ire, 2:UnavailableException ue, 3:TimedOutException te),
void remove(1:required string keyspace,
2:required string key,
3:required ColumnPath column_path,
4:required i64 timestamp,
5:ConsistencyLevel consistency_level=0)
- throws (1: InvalidRequestException ire, 2: UnavailableException ue),
+ throws (1:InvalidRequestException ire, 2:UnavailableException ue, 3:TimedOutException te),
// Meta-APIs -- APIs to get information about the node or cluster,
@@ -212,6 +216,6 @@
// describe specified keyspace
map<string, map<string, string>> describe_keyspace(1:required string keyspace)
- throws (1: NotFoundException nfe),
+ throws (1:NotFoundException nfe),
}
Modified: incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/Cassandra.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/Cassandra.java?rev=882248&r1=882247&r2=882248&view=diff
==============================================================================
--- incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/Cassandra.java (original)
+++ incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/Cassandra.java Thu Nov 19 19:03:47 2009
@@ -46,15 +46,15 @@
public interface Iface {
- public ColumnOrSuperColumn get(String keyspace, String key, ColumnPath column_path, int consistency_level) throws InvalidRequestException, NotFoundException, UnavailableException, TException;
+ public ColumnOrSuperColumn get(String keyspace, String key, ColumnPath column_path, int consistency_level) throws InvalidRequestException, NotFoundException, UnavailableException, TimedOutException, TException;
- public List<ColumnOrSuperColumn> get_slice(String keyspace, String key, ColumnParent column_parent, SlicePredicate predicate, int consistency_level) throws InvalidRequestException, UnavailableException, TException;
+ public List<ColumnOrSuperColumn> get_slice(String keyspace, String key, ColumnParent column_parent, SlicePredicate predicate, int consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException;
- public Map<String,ColumnOrSuperColumn> multiget(String keyspace, List<String> keys, ColumnPath column_path, int consistency_level) throws InvalidRequestException, UnavailableException, TException;
+ public Map<String,ColumnOrSuperColumn> multiget(String keyspace, List<String> keys, ColumnPath column_path, int consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException;
- public Map<String,List<ColumnOrSuperColumn>> multiget_slice(String keyspace, List<String> keys, ColumnParent column_parent, SlicePredicate predicate, int consistency_level) throws InvalidRequestException, UnavailableException, TException;
+ public Map<String,List<ColumnOrSuperColumn>> multiget_slice(String keyspace, List<String> keys, ColumnParent column_parent, SlicePredicate predicate, int consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException;
- public int get_count(String keyspace, String key, ColumnParent column_parent, int consistency_level) throws InvalidRequestException, UnavailableException, TException;
+ public int get_count(String keyspace, String key, ColumnParent column_parent, int consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException;
/**
* @deprecated; use get_range_slice instead
@@ -66,15 +66,15 @@
* @param count
* @param consistency_level
*/
- public List<String> get_key_range(String keyspace, String column_family, String start, String finish, int count, int consistency_level) throws InvalidRequestException, UnavailableException, TException;
+ public List<String> get_key_range(String keyspace, String column_family, String start, String finish, int count, int consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException;
- public List<KeySlice> get_range_slice(String keyspace, ColumnParent column_parent, SlicePredicate predicate, String start_key, String finish_key, int row_count, int consistency_level) throws InvalidRequestException, UnavailableException, TException;
+ public List<KeySlice> get_range_slice(String keyspace, ColumnParent column_parent, SlicePredicate predicate, String start_key, String finish_key, int row_count, int consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException;
- public void insert(String keyspace, String key, ColumnPath column_path, byte[] value, long timestamp, int consistency_level) throws InvalidRequestException, UnavailableException, TException;
+ public void insert(String keyspace, String key, ColumnPath column_path, byte[] value, long timestamp, int consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException;
- public void batch_insert(String keyspace, String key, Map<String,List<ColumnOrSuperColumn>> cfmap, int consistency_level) throws InvalidRequestException, UnavailableException, TException;
+ public void batch_insert(String keyspace, String key, Map<String,List<ColumnOrSuperColumn>> cfmap, int consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException;
- public void remove(String keyspace, String key, ColumnPath column_path, long timestamp, int consistency_level) throws InvalidRequestException, UnavailableException, TException;
+ public void remove(String keyspace, String key, ColumnPath column_path, long timestamp, int consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException;
public String get_string_property(String property) throws TException;
@@ -111,7 +111,7 @@
return this.oprot_;
}
- public ColumnOrSuperColumn get(String keyspace, String key, ColumnPath column_path, int consistency_level) throws InvalidRequestException, NotFoundException, UnavailableException, TException
+ public ColumnOrSuperColumn get(String keyspace, String key, ColumnPath column_path, int consistency_level) throws InvalidRequestException, NotFoundException, UnavailableException, TimedOutException, TException
{
send_get(keyspace, key, column_path, consistency_level);
return recv_get();
@@ -130,7 +130,7 @@
oprot_.getTransport().flush();
}
- public ColumnOrSuperColumn recv_get() throws InvalidRequestException, NotFoundException, UnavailableException, TException
+ public ColumnOrSuperColumn recv_get() throws InvalidRequestException, NotFoundException, UnavailableException, TimedOutException, TException
{
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
@@ -153,10 +153,13 @@
if (result.ue != null) {
throw result.ue;
}
+ if (result.te != null) {
+ throw result.te;
+ }
throw new TApplicationException(TApplicationException.MISSING_RESULT, "get failed: unknown result");
}
- public List<ColumnOrSuperColumn> get_slice(String keyspace, String key, ColumnParent column_parent, SlicePredicate predicate, int consistency_level) throws InvalidRequestException, UnavailableException, TException
+ public List<ColumnOrSuperColumn> get_slice(String keyspace, String key, ColumnParent column_parent, SlicePredicate predicate, int consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException
{
send_get_slice(keyspace, key, column_parent, predicate, consistency_level);
return recv_get_slice();
@@ -176,7 +179,7 @@
oprot_.getTransport().flush();
}
- public List<ColumnOrSuperColumn> recv_get_slice() throws InvalidRequestException, UnavailableException, TException
+ public List<ColumnOrSuperColumn> recv_get_slice() throws InvalidRequestException, UnavailableException, TimedOutException, TException
{
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
@@ -196,10 +199,13 @@
if (result.ue != null) {
throw result.ue;
}
+ if (result.te != null) {
+ throw result.te;
+ }
throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_slice failed: unknown result");
}
- public Map<String,ColumnOrSuperColumn> multiget(String keyspace, List<String> keys, ColumnPath column_path, int consistency_level) throws InvalidRequestException, UnavailableException, TException
+ public Map<String,ColumnOrSuperColumn> multiget(String keyspace, List<String> keys, ColumnPath column_path, int consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException
{
send_multiget(keyspace, keys, column_path, consistency_level);
return recv_multiget();
@@ -218,7 +224,7 @@
oprot_.getTransport().flush();
}
- public Map<String,ColumnOrSuperColumn> recv_multiget() throws InvalidRequestException, UnavailableException, TException
+ public Map<String,ColumnOrSuperColumn> recv_multiget() throws InvalidRequestException, UnavailableException, TimedOutException, TException
{
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
@@ -238,10 +244,13 @@
if (result.ue != null) {
throw result.ue;
}
+ if (result.te != null) {
+ throw result.te;
+ }
throw new TApplicationException(TApplicationException.MISSING_RESULT, "multiget failed: unknown result");
}
- public Map<String,List<ColumnOrSuperColumn>> multiget_slice(String keyspace, List<String> keys, ColumnParent column_parent, SlicePredicate predicate, int consistency_level) throws InvalidRequestException, UnavailableException, TException
+ public Map<String,List<ColumnOrSuperColumn>> multiget_slice(String keyspace, List<String> keys, ColumnParent column_parent, SlicePredicate predicate, int consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException
{
send_multiget_slice(keyspace, keys, column_parent, predicate, consistency_level);
return recv_multiget_slice();
@@ -261,7 +270,7 @@
oprot_.getTransport().flush();
}
- public Map<String,List<ColumnOrSuperColumn>> recv_multiget_slice() throws InvalidRequestException, UnavailableException, TException
+ public Map<String,List<ColumnOrSuperColumn>> recv_multiget_slice() throws InvalidRequestException, UnavailableException, TimedOutException, TException
{
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
@@ -281,10 +290,13 @@
if (result.ue != null) {
throw result.ue;
}
+ if (result.te != null) {
+ throw result.te;
+ }
throw new TApplicationException(TApplicationException.MISSING_RESULT, "multiget_slice failed: unknown result");
}
- public int get_count(String keyspace, String key, ColumnParent column_parent, int consistency_level) throws InvalidRequestException, UnavailableException, TException
+ public int get_count(String keyspace, String key, ColumnParent column_parent, int consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException
{
send_get_count(keyspace, key, column_parent, consistency_level);
return recv_get_count();
@@ -303,7 +315,7 @@
oprot_.getTransport().flush();
}
- public int recv_get_count() throws InvalidRequestException, UnavailableException, TException
+ public int recv_get_count() throws InvalidRequestException, UnavailableException, TimedOutException, TException
{
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
@@ -323,10 +335,13 @@
if (result.ue != null) {
throw result.ue;
}
+ if (result.te != null) {
+ throw result.te;
+ }
throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_count failed: unknown result");
}
- public List<String> get_key_range(String keyspace, String column_family, String start, String finish, int count, int consistency_level) throws InvalidRequestException, UnavailableException, TException
+ public List<String> get_key_range(String keyspace, String column_family, String start, String finish, int count, int consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException
{
send_get_key_range(keyspace, column_family, start, finish, count, consistency_level);
return recv_get_key_range();
@@ -347,7 +362,7 @@
oprot_.getTransport().flush();
}
- public List<String> recv_get_key_range() throws InvalidRequestException, UnavailableException, TException
+ public List<String> recv_get_key_range() throws InvalidRequestException, UnavailableException, TimedOutException, TException
{
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
@@ -367,10 +382,13 @@
if (result.ue != null) {
throw result.ue;
}
+ if (result.te != null) {
+ throw result.te;
+ }
throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_key_range failed: unknown result");
}
- public List<KeySlice> get_range_slice(String keyspace, ColumnParent column_parent, SlicePredicate predicate, String start_key, String finish_key, int row_count, int consistency_level) throws InvalidRequestException, UnavailableException, TException
+ public List<KeySlice> get_range_slice(String keyspace, ColumnParent column_parent, SlicePredicate predicate, String start_key, String finish_key, int row_count, int consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException
{
send_get_range_slice(keyspace, column_parent, predicate, start_key, finish_key, row_count, consistency_level);
return recv_get_range_slice();
@@ -392,7 +410,7 @@
oprot_.getTransport().flush();
}
- public List<KeySlice> recv_get_range_slice() throws InvalidRequestException, UnavailableException, TException
+ public List<KeySlice> recv_get_range_slice() throws InvalidRequestException, UnavailableException, TimedOutException, TException
{
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
@@ -412,10 +430,13 @@
if (result.ue != null) {
throw result.ue;
}
+ if (result.te != null) {
+ throw result.te;
+ }
throw new TApplicationException(TApplicationException.MISSING_RESULT, "get_range_slice failed: unknown result");
}
- public void insert(String keyspace, String key, ColumnPath column_path, byte[] value, long timestamp, int consistency_level) throws InvalidRequestException, UnavailableException, TException
+ public void insert(String keyspace, String key, ColumnPath column_path, byte[] value, long timestamp, int consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException
{
send_insert(keyspace, key, column_path, value, timestamp, consistency_level);
recv_insert();
@@ -436,7 +457,7 @@
oprot_.getTransport().flush();
}
- public void recv_insert() throws InvalidRequestException, UnavailableException, TException
+ public void recv_insert() throws InvalidRequestException, UnavailableException, TimedOutException, TException
{
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
@@ -453,10 +474,13 @@
if (result.ue != null) {
throw result.ue;
}
+ if (result.te != null) {
+ throw result.te;
+ }
return;
}
- public void batch_insert(String keyspace, String key, Map<String,List<ColumnOrSuperColumn>> cfmap, int consistency_level) throws InvalidRequestException, UnavailableException, TException
+ public void batch_insert(String keyspace, String key, Map<String,List<ColumnOrSuperColumn>> cfmap, int consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException
{
send_batch_insert(keyspace, key, cfmap, consistency_level);
recv_batch_insert();
@@ -475,7 +499,7 @@
oprot_.getTransport().flush();
}
- public void recv_batch_insert() throws InvalidRequestException, UnavailableException, TException
+ public void recv_batch_insert() throws InvalidRequestException, UnavailableException, TimedOutException, TException
{
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
@@ -492,10 +516,13 @@
if (result.ue != null) {
throw result.ue;
}
+ if (result.te != null) {
+ throw result.te;
+ }
return;
}
- public void remove(String keyspace, String key, ColumnPath column_path, long timestamp, int consistency_level) throws InvalidRequestException, UnavailableException, TException
+ public void remove(String keyspace, String key, ColumnPath column_path, long timestamp, int consistency_level) throws InvalidRequestException, UnavailableException, TimedOutException, TException
{
send_remove(keyspace, key, column_path, timestamp, consistency_level);
recv_remove();
@@ -515,7 +542,7 @@
oprot_.getTransport().flush();
}
- public void recv_remove() throws InvalidRequestException, UnavailableException, TException
+ public void recv_remove() throws InvalidRequestException, UnavailableException, TimedOutException, TException
{
TMessage msg = iprot_.readMessageBegin();
if (msg.type == TMessageType.EXCEPTION) {
@@ -532,6 +559,9 @@
if (result.ue != null) {
throw result.ue;
}
+ if (result.te != null) {
+ throw result.te;
+ }
return;
}
@@ -698,6 +728,8 @@
result.nfe = nfe;
} catch (UnavailableException ue) {
result.ue = ue;
+ } catch (TimedOutException te) {
+ result.te = te;
} catch (Throwable th) {
LOGGER.error("Internal error processing get", th);
TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing get");
@@ -728,6 +760,8 @@
result.ire = ire;
} catch (UnavailableException ue) {
result.ue = ue;
+ } catch (TimedOutException te) {
+ result.te = te;
} catch (Throwable th) {
LOGGER.error("Internal error processing get_slice", th);
TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing get_slice");
@@ -758,6 +792,8 @@
result.ire = ire;
} catch (UnavailableException ue) {
result.ue = ue;
+ } catch (TimedOutException te) {
+ result.te = te;
} catch (Throwable th) {
LOGGER.error("Internal error processing multiget", th);
TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing multiget");
@@ -788,6 +824,8 @@
result.ire = ire;
} catch (UnavailableException ue) {
result.ue = ue;
+ } catch (TimedOutException te) {
+ result.te = te;
} catch (Throwable th) {
LOGGER.error("Internal error processing multiget_slice", th);
TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing multiget_slice");
@@ -819,6 +857,8 @@
result.ire = ire;
} catch (UnavailableException ue) {
result.ue = ue;
+ } catch (TimedOutException te) {
+ result.te = te;
} catch (Throwable th) {
LOGGER.error("Internal error processing get_count", th);
TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing get_count");
@@ -849,6 +889,8 @@
result.ire = ire;
} catch (UnavailableException ue) {
result.ue = ue;
+ } catch (TimedOutException te) {
+ result.te = te;
} catch (Throwable th) {
LOGGER.error("Internal error processing get_key_range", th);
TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing get_key_range");
@@ -879,6 +921,8 @@
result.ire = ire;
} catch (UnavailableException ue) {
result.ue = ue;
+ } catch (TimedOutException te) {
+ result.te = te;
} catch (Throwable th) {
LOGGER.error("Internal error processing get_range_slice", th);
TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing get_range_slice");
@@ -909,6 +953,8 @@
result.ire = ire;
} catch (UnavailableException ue) {
result.ue = ue;
+ } catch (TimedOutException te) {
+ result.te = te;
} catch (Throwable th) {
LOGGER.error("Internal error processing insert", th);
TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing insert");
@@ -939,6 +985,8 @@
result.ire = ire;
} catch (UnavailableException ue) {
result.ue = ue;
+ } catch (TimedOutException te) {
+ result.te = te;
} catch (Throwable th) {
LOGGER.error("Internal error processing batch_insert", th);
TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing batch_insert");
@@ -969,6 +1017,8 @@
result.ire = ire;
} catch (UnavailableException ue) {
result.ue = ue;
+ } catch (TimedOutException te) {
+ result.te = te;
} catch (Throwable th) {
LOGGER.error("Internal error processing remove", th);
TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing remove");
@@ -1563,15 +1613,18 @@
private static final TField IRE_FIELD_DESC = new TField("ire", TType.STRUCT, (short)1);
private static final TField NFE_FIELD_DESC = new TField("nfe", TType.STRUCT, (short)2);
private static final TField UE_FIELD_DESC = new TField("ue", TType.STRUCT, (short)3);
+ private static final TField TE_FIELD_DESC = new TField("te", TType.STRUCT, (short)4);
public ColumnOrSuperColumn success;
public InvalidRequestException ire;
public NotFoundException nfe;
public UnavailableException ue;
+ public TimedOutException te;
public static final int SUCCESS = 0;
public static final int IRE = 1;
public static final int NFE = 2;
public static final int UE = 3;
+ public static final int TE = 4;
// isset id assignments
@@ -1584,6 +1637,8 @@
new FieldValueMetaData(TType.STRUCT)));
put(UE, new FieldMetaData("ue", TFieldRequirementType.DEFAULT,
new FieldValueMetaData(TType.STRUCT)));
+ put(TE, new FieldMetaData("te", TFieldRequirementType.DEFAULT,
+ new FieldValueMetaData(TType.STRUCT)));
}});
static {
@@ -1597,13 +1652,15 @@
ColumnOrSuperColumn success,
InvalidRequestException ire,
NotFoundException nfe,
- UnavailableException ue)
+ UnavailableException ue,
+ TimedOutException te)
{
this();
this.success = success;
this.ire = ire;
this.nfe = nfe;
this.ue = ue;
+ this.te = te;
}
/**
@@ -1622,6 +1679,9 @@
if (other.isSetUe()) {
this.ue = new UnavailableException(other.ue);
}
+ if (other.isSetTe()) {
+ this.te = new TimedOutException(other.te);
+ }
}
public get_result deepCopy() {
@@ -1729,6 +1789,30 @@
}
}
+ public TimedOutException getTe() {
+ return this.te;
+ }
+
+ public get_result setTe(TimedOutException te) {
+ this.te = te;
+ return this;
+ }
+
+ public void unsetTe() {
+ this.te = null;
+ }
+
+ // Returns true if field te is set (has been asigned a value) and false otherwise
+ public boolean isSetTe() {
+ return this.te != null;
+ }
+
+ public void setTeIsSet(boolean value) {
+ if (!value) {
+ this.te = null;
+ }
+ }
+
public void setFieldValue(int fieldID, Object value) {
switch (fieldID) {
case SUCCESS:
@@ -1763,6 +1847,14 @@
}
break;
+ case TE:
+ if (value == null) {
+ unsetTe();
+ } else {
+ setTe((TimedOutException)value);
+ }
+ break;
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -1782,6 +1874,9 @@
case UE:
return getUe();
+ case TE:
+ return getTe();
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -1798,6 +1893,8 @@
return isSetNfe();
case UE:
return isSetUe();
+ case TE:
+ return isSetTe();
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -1852,6 +1949,15 @@
return false;
}
+ boolean this_present_te = true && this.isSetTe();
+ boolean that_present_te = true && that.isSetTe();
+ if (this_present_te || that_present_te) {
+ if (!(this_present_te && that_present_te))
+ return false;
+ if (!this.te.equals(that.te))
+ return false;
+ }
+
return true;
}
@@ -1900,6 +2006,14 @@
if (lastComparison != 0) {
return lastComparison;
}
+ lastComparison = Boolean.valueOf(isSetTe()).compareTo(isSetTe());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ lastComparison = TBaseHelper.compareTo(te, typedOther.te);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
return 0;
}
@@ -1946,6 +2060,14 @@
TProtocolUtil.skip(iprot, field.type);
}
break;
+ case TE:
+ if (field.type == TType.STRUCT) {
+ this.te = new TimedOutException();
+ this.te.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
default:
TProtocolUtil.skip(iprot, field.type);
break;
@@ -1978,6 +2100,10 @@
oprot.writeFieldBegin(UE_FIELD_DESC);
this.ue.write(oprot);
oprot.writeFieldEnd();
+ } else if (this.isSetTe()) {
+ oprot.writeFieldBegin(TE_FIELD_DESC);
+ this.te.write(oprot);
+ oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
@@ -2019,6 +2145,14 @@
sb.append(this.ue);
}
first = false;
+ if (!first) sb.append(", ");
+ sb.append("te:");
+ if (this.te == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.te);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
@@ -2631,14 +2765,17 @@
private static final TStruct STRUCT_DESC = new TStruct("get_slice_result");
private static final TField SUCCESS_FIELD_DESC = new TField("success", TType.LIST, (short)0);
private static final TField IRE_FIELD_DESC = new TField("ire", TType.STRUCT, (short)1);
- private static final TField UE_FIELD_DESC = new TField("ue", TType.STRUCT, (short)3);
+ private static final TField UE_FIELD_DESC = new TField("ue", TType.STRUCT, (short)2);
+ private static final TField TE_FIELD_DESC = new TField("te", TType.STRUCT, (short)3);
public List<ColumnOrSuperColumn> success;
public InvalidRequestException ire;
public UnavailableException ue;
+ public TimedOutException te;
public static final int SUCCESS = 0;
public static final int IRE = 1;
- public static final int UE = 3;
+ public static final int UE = 2;
+ public static final int TE = 3;
// isset id assignments
@@ -2650,6 +2787,8 @@
new FieldValueMetaData(TType.STRUCT)));
put(UE, new FieldMetaData("ue", TFieldRequirementType.DEFAULT,
new FieldValueMetaData(TType.STRUCT)));
+ put(TE, new FieldMetaData("te", TFieldRequirementType.DEFAULT,
+ new FieldValueMetaData(TType.STRUCT)));
}});
static {
@@ -2662,12 +2801,14 @@
public get_slice_result(
List<ColumnOrSuperColumn> success,
InvalidRequestException ire,
- UnavailableException ue)
+ UnavailableException ue,
+ TimedOutException te)
{
this();
this.success = success;
this.ire = ire;
this.ue = ue;
+ this.te = te;
}
/**
@@ -2687,6 +2828,9 @@
if (other.isSetUe()) {
this.ue = new UnavailableException(other.ue);
}
+ if (other.isSetTe()) {
+ this.te = new TimedOutException(other.te);
+ }
}
public get_slice_result deepCopy() {
@@ -2770,6 +2914,30 @@
}
}
+ public TimedOutException getTe() {
+ return this.te;
+ }
+
+ public get_slice_result setTe(TimedOutException te) {
+ this.te = te;
+ return this;
+ }
+
+ public void unsetTe() {
+ this.te = null;
+ }
+
+ // Returns true if field te is set (has been asigned a value) and false otherwise
+ public boolean isSetTe() {
+ return this.te != null;
+ }
+
+ public void setTeIsSet(boolean value) {
+ if (!value) {
+ this.te = null;
+ }
+ }
+
public void setFieldValue(int fieldID, Object value) {
switch (fieldID) {
case SUCCESS:
@@ -2796,6 +2964,14 @@
}
break;
+ case TE:
+ if (value == null) {
+ unsetTe();
+ } else {
+ setTe((TimedOutException)value);
+ }
+ break;
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -2812,6 +2988,9 @@
case UE:
return getUe();
+ case TE:
+ return getTe();
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -2826,6 +3005,8 @@
return isSetIre();
case UE:
return isSetUe();
+ case TE:
+ return isSetTe();
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -2871,6 +3052,15 @@
return false;
}
+ boolean this_present_te = true && this.isSetTe();
+ boolean that_present_te = true && that.isSetTe();
+ if (this_present_te || that_present_te) {
+ if (!(this_present_te && that_present_te))
+ return false;
+ if (!this.te.equals(that.te))
+ return false;
+ }
+
return true;
}
@@ -2911,6 +3101,14 @@
if (lastComparison != 0) {
return lastComparison;
}
+ lastComparison = Boolean.valueOf(isSetTe()).compareTo(isSetTe());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ lastComparison = TBaseHelper.compareTo(te, typedOther.te);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
return 0;
}
@@ -2959,6 +3157,14 @@
TProtocolUtil.skip(iprot, field.type);
}
break;
+ case TE:
+ if (field.type == TType.STRUCT) {
+ this.te = new TimedOutException();
+ this.te.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
default:
TProtocolUtil.skip(iprot, field.type);
break;
@@ -2994,6 +3200,10 @@
oprot.writeFieldBegin(UE_FIELD_DESC);
this.ue.write(oprot);
oprot.writeFieldEnd();
+ } else if (this.isSetTe()) {
+ oprot.writeFieldBegin(TE_FIELD_DESC);
+ this.te.write(oprot);
+ oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
@@ -3027,6 +3237,14 @@
sb.append(this.ue);
}
first = false;
+ if (!first) sb.append(", ");
+ sb.append("te:");
+ if (this.te == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.te);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
@@ -3574,13 +3792,16 @@
private static final TField SUCCESS_FIELD_DESC = new TField("success", TType.MAP, (short)0);
private static final TField IRE_FIELD_DESC = new TField("ire", TType.STRUCT, (short)1);
private static final TField UE_FIELD_DESC = new TField("ue", TType.STRUCT, (short)2);
+ private static final TField TE_FIELD_DESC = new TField("te", TType.STRUCT, (short)3);
public Map<String,ColumnOrSuperColumn> success;
public InvalidRequestException ire;
public UnavailableException ue;
+ public TimedOutException te;
public static final int SUCCESS = 0;
public static final int IRE = 1;
public static final int UE = 2;
+ public static final int TE = 3;
// isset id assignments
@@ -3593,6 +3814,8 @@
new FieldValueMetaData(TType.STRUCT)));
put(UE, new FieldMetaData("ue", TFieldRequirementType.DEFAULT,
new FieldValueMetaData(TType.STRUCT)));
+ put(TE, new FieldMetaData("te", TFieldRequirementType.DEFAULT,
+ new FieldValueMetaData(TType.STRUCT)));
}});
static {
@@ -3605,12 +3828,14 @@
public multiget_result(
Map<String,ColumnOrSuperColumn> success,
InvalidRequestException ire,
- UnavailableException ue)
+ UnavailableException ue,
+ TimedOutException te)
{
this();
this.success = success;
this.ire = ire;
this.ue = ue;
+ this.te = te;
}
/**
@@ -3638,6 +3863,9 @@
if (other.isSetUe()) {
this.ue = new UnavailableException(other.ue);
}
+ if (other.isSetTe()) {
+ this.te = new TimedOutException(other.te);
+ }
}
public multiget_result deepCopy() {
@@ -3721,6 +3949,30 @@
}
}
+ public TimedOutException getTe() {
+ return this.te;
+ }
+
+ public multiget_result setTe(TimedOutException te) {
+ this.te = te;
+ return this;
+ }
+
+ public void unsetTe() {
+ this.te = null;
+ }
+
+ // Returns true if field te is set (has been asigned a value) and false otherwise
+ public boolean isSetTe() {
+ return this.te != null;
+ }
+
+ public void setTeIsSet(boolean value) {
+ if (!value) {
+ this.te = null;
+ }
+ }
+
public void setFieldValue(int fieldID, Object value) {
switch (fieldID) {
case SUCCESS:
@@ -3747,6 +3999,14 @@
}
break;
+ case TE:
+ if (value == null) {
+ unsetTe();
+ } else {
+ setTe((TimedOutException)value);
+ }
+ break;
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -3763,6 +4023,9 @@
case UE:
return getUe();
+ case TE:
+ return getTe();
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -3777,6 +4040,8 @@
return isSetIre();
case UE:
return isSetUe();
+ case TE:
+ return isSetTe();
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -3822,6 +4087,15 @@
return false;
}
+ boolean this_present_te = true && this.isSetTe();
+ boolean that_present_te = true && that.isSetTe();
+ if (this_present_te || that_present_te) {
+ if (!(this_present_te && that_present_te))
+ return false;
+ if (!this.te.equals(that.te))
+ return false;
+ }
+
return true;
}
@@ -3877,6 +4151,14 @@
TProtocolUtil.skip(iprot, field.type);
}
break;
+ case TE:
+ if (field.type == TType.STRUCT) {
+ this.te = new TimedOutException();
+ this.te.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
default:
TProtocolUtil.skip(iprot, field.type);
break;
@@ -3913,6 +4195,10 @@
oprot.writeFieldBegin(UE_FIELD_DESC);
this.ue.write(oprot);
oprot.writeFieldEnd();
+ } else if (this.isSetTe()) {
+ oprot.writeFieldBegin(TE_FIELD_DESC);
+ this.te.write(oprot);
+ oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
@@ -3946,6 +4232,14 @@
sb.append(this.ue);
}
first = false;
+ if (!first) sb.append(", ");
+ sb.append("te:");
+ if (this.te == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.te);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
@@ -4581,13 +4875,16 @@
private static final TField SUCCESS_FIELD_DESC = new TField("success", TType.MAP, (short)0);
private static final TField IRE_FIELD_DESC = new TField("ire", TType.STRUCT, (short)1);
private static final TField UE_FIELD_DESC = new TField("ue", TType.STRUCT, (short)2);
+ private static final TField TE_FIELD_DESC = new TField("te", TType.STRUCT, (short)3);
public Map<String,List<ColumnOrSuperColumn>> success;
public InvalidRequestException ire;
public UnavailableException ue;
+ public TimedOutException te;
public static final int SUCCESS = 0;
public static final int IRE = 1;
public static final int UE = 2;
+ public static final int TE = 3;
// isset id assignments
@@ -4601,6 +4898,8 @@
new FieldValueMetaData(TType.STRUCT)));
put(UE, new FieldMetaData("ue", TFieldRequirementType.DEFAULT,
new FieldValueMetaData(TType.STRUCT)));
+ put(TE, new FieldMetaData("te", TFieldRequirementType.DEFAULT,
+ new FieldValueMetaData(TType.STRUCT)));
}});
static {
@@ -4613,12 +4912,14 @@
public multiget_slice_result(
Map<String,List<ColumnOrSuperColumn>> success,
InvalidRequestException ire,
- UnavailableException ue)
+ UnavailableException ue,
+ TimedOutException te)
{
this();
this.success = success;
this.ire = ire;
this.ue = ue;
+ this.te = te;
}
/**
@@ -4649,6 +4950,9 @@
if (other.isSetUe()) {
this.ue = new UnavailableException(other.ue);
}
+ if (other.isSetTe()) {
+ this.te = new TimedOutException(other.te);
+ }
}
public multiget_slice_result deepCopy() {
@@ -4732,6 +5036,30 @@
}
}
+ public TimedOutException getTe() {
+ return this.te;
+ }
+
+ public multiget_slice_result setTe(TimedOutException te) {
+ this.te = te;
+ return this;
+ }
+
+ public void unsetTe() {
+ this.te = null;
+ }
+
+ // Returns true if field te is set (has been asigned a value) and false otherwise
+ public boolean isSetTe() {
+ return this.te != null;
+ }
+
+ public void setTeIsSet(boolean value) {
+ if (!value) {
+ this.te = null;
+ }
+ }
+
public void setFieldValue(int fieldID, Object value) {
switch (fieldID) {
case SUCCESS:
@@ -4758,6 +5086,14 @@
}
break;
+ case TE:
+ if (value == null) {
+ unsetTe();
+ } else {
+ setTe((TimedOutException)value);
+ }
+ break;
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -4774,6 +5110,9 @@
case UE:
return getUe();
+ case TE:
+ return getTe();
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -4788,6 +5127,8 @@
return isSetIre();
case UE:
return isSetUe();
+ case TE:
+ return isSetTe();
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -4833,6 +5174,15 @@
return false;
}
+ boolean this_present_te = true && this.isSetTe();
+ boolean that_present_te = true && that.isSetTe();
+ if (this_present_te || that_present_te) {
+ if (!(this_present_te && that_present_te))
+ return false;
+ if (!this.te.equals(that.te))
+ return false;
+ }
+
return true;
}
@@ -4898,6 +5248,14 @@
TProtocolUtil.skip(iprot, field.type);
}
break;
+ case TE:
+ if (field.type == TType.STRUCT) {
+ this.te = new TimedOutException();
+ this.te.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
default:
TProtocolUtil.skip(iprot, field.type);
break;
@@ -4941,6 +5299,10 @@
oprot.writeFieldBegin(UE_FIELD_DESC);
this.ue.write(oprot);
oprot.writeFieldEnd();
+ } else if (this.isSetTe()) {
+ oprot.writeFieldBegin(TE_FIELD_DESC);
+ this.te.write(oprot);
+ oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
@@ -4974,6 +5336,14 @@
sb.append(this.ue);
}
first = false;
+ if (!first) sb.append(", ");
+ sb.append("te:");
+ if (this.te == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.te);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
@@ -5499,13 +5869,16 @@
private static final TField SUCCESS_FIELD_DESC = new TField("success", TType.I32, (short)0);
private static final TField IRE_FIELD_DESC = new TField("ire", TType.STRUCT, (short)1);
private static final TField UE_FIELD_DESC = new TField("ue", TType.STRUCT, (short)2);
+ private static final TField TE_FIELD_DESC = new TField("te", TType.STRUCT, (short)3);
public int success;
public InvalidRequestException ire;
public UnavailableException ue;
+ public TimedOutException te;
public static final int SUCCESS = 0;
public static final int IRE = 1;
public static final int UE = 2;
+ public static final int TE = 3;
// isset id assignments
private static final int __SUCCESS_ISSET_ID = 0;
@@ -5518,6 +5891,8 @@
new FieldValueMetaData(TType.STRUCT)));
put(UE, new FieldMetaData("ue", TFieldRequirementType.DEFAULT,
new FieldValueMetaData(TType.STRUCT)));
+ put(TE, new FieldMetaData("te", TFieldRequirementType.DEFAULT,
+ new FieldValueMetaData(TType.STRUCT)));
}});
static {
@@ -5530,13 +5905,15 @@
public get_count_result(
int success,
InvalidRequestException ire,
- UnavailableException ue)
+ UnavailableException ue,
+ TimedOutException te)
{
this();
this.success = success;
setSuccessIsSet(true);
this.ire = ire;
this.ue = ue;
+ this.te = te;
}
/**
@@ -5552,6 +5929,9 @@
if (other.isSetUe()) {
this.ue = new UnavailableException(other.ue);
}
+ if (other.isSetTe()) {
+ this.te = new TimedOutException(other.te);
+ }
}
public get_count_result deepCopy() {
@@ -5634,6 +6014,30 @@
}
}
+ public TimedOutException getTe() {
+ return this.te;
+ }
+
+ public get_count_result setTe(TimedOutException te) {
+ this.te = te;
+ return this;
+ }
+
+ public void unsetTe() {
+ this.te = null;
+ }
+
+ // Returns true if field te is set (has been asigned a value) and false otherwise
+ public boolean isSetTe() {
+ return this.te != null;
+ }
+
+ public void setTeIsSet(boolean value) {
+ if (!value) {
+ this.te = null;
+ }
+ }
+
public void setFieldValue(int fieldID, Object value) {
switch (fieldID) {
case SUCCESS:
@@ -5660,6 +6064,14 @@
}
break;
+ case TE:
+ if (value == null) {
+ unsetTe();
+ } else {
+ setTe((TimedOutException)value);
+ }
+ break;
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -5676,6 +6088,9 @@
case UE:
return getUe();
+ case TE:
+ return getTe();
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -5690,6 +6105,8 @@
return isSetIre();
case UE:
return isSetUe();
+ case TE:
+ return isSetTe();
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -5735,6 +6152,15 @@
return false;
}
+ boolean this_present_te = true && this.isSetTe();
+ boolean that_present_te = true && that.isSetTe();
+ if (this_present_te || that_present_te) {
+ if (!(this_present_te && that_present_te))
+ return false;
+ if (!this.te.equals(that.te))
+ return false;
+ }
+
return true;
}
@@ -5775,6 +6201,14 @@
if (lastComparison != 0) {
return lastComparison;
}
+ lastComparison = Boolean.valueOf(isSetTe()).compareTo(isSetTe());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ lastComparison = TBaseHelper.compareTo(te, typedOther.te);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
return 0;
}
@@ -5813,6 +6247,14 @@
TProtocolUtil.skip(iprot, field.type);
}
break;
+ case TE:
+ if (field.type == TType.STRUCT) {
+ this.te = new TimedOutException();
+ this.te.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
default:
TProtocolUtil.skip(iprot, field.type);
break;
@@ -5841,6 +6283,10 @@
oprot.writeFieldBegin(UE_FIELD_DESC);
this.ue.write(oprot);
oprot.writeFieldEnd();
+ } else if (this.isSetTe()) {
+ oprot.writeFieldBegin(TE_FIELD_DESC);
+ this.te.write(oprot);
+ oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
@@ -5870,6 +6316,14 @@
sb.append(this.ue);
}
first = false;
+ if (!first) sb.append(", ");
+ sb.append("te:");
+ if (this.te == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.te);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
@@ -6569,13 +7023,16 @@
private static final TField SUCCESS_FIELD_DESC = new TField("success", TType.LIST, (short)0);
private static final TField IRE_FIELD_DESC = new TField("ire", TType.STRUCT, (short)1);
private static final TField UE_FIELD_DESC = new TField("ue", TType.STRUCT, (short)2);
+ private static final TField TE_FIELD_DESC = new TField("te", TType.STRUCT, (short)3);
public List<String> success;
public InvalidRequestException ire;
public UnavailableException ue;
+ public TimedOutException te;
public static final int SUCCESS = 0;
public static final int IRE = 1;
public static final int UE = 2;
+ public static final int TE = 3;
// isset id assignments
@@ -6587,6 +7044,8 @@
new FieldValueMetaData(TType.STRUCT)));
put(UE, new FieldMetaData("ue", TFieldRequirementType.DEFAULT,
new FieldValueMetaData(TType.STRUCT)));
+ put(TE, new FieldMetaData("te", TFieldRequirementType.DEFAULT,
+ new FieldValueMetaData(TType.STRUCT)));
}});
static {
@@ -6599,12 +7058,14 @@
public get_key_range_result(
List<String> success,
InvalidRequestException ire,
- UnavailableException ue)
+ UnavailableException ue,
+ TimedOutException te)
{
this();
this.success = success;
this.ire = ire;
this.ue = ue;
+ this.te = te;
}
/**
@@ -6624,6 +7085,9 @@
if (other.isSetUe()) {
this.ue = new UnavailableException(other.ue);
}
+ if (other.isSetTe()) {
+ this.te = new TimedOutException(other.te);
+ }
}
public get_key_range_result deepCopy() {
@@ -6707,6 +7171,30 @@
}
}
+ public TimedOutException getTe() {
+ return this.te;
+ }
+
+ public get_key_range_result setTe(TimedOutException te) {
+ this.te = te;
+ return this;
+ }
+
+ public void unsetTe() {
+ this.te = null;
+ }
+
+ // Returns true if field te is set (has been asigned a value) and false otherwise
+ public boolean isSetTe() {
+ return this.te != null;
+ }
+
+ public void setTeIsSet(boolean value) {
+ if (!value) {
+ this.te = null;
+ }
+ }
+
public void setFieldValue(int fieldID, Object value) {
switch (fieldID) {
case SUCCESS:
@@ -6733,6 +7221,14 @@
}
break;
+ case TE:
+ if (value == null) {
+ unsetTe();
+ } else {
+ setTe((TimedOutException)value);
+ }
+ break;
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -6749,6 +7245,9 @@
case UE:
return getUe();
+ case TE:
+ return getTe();
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -6763,6 +7262,8 @@
return isSetIre();
case UE:
return isSetUe();
+ case TE:
+ return isSetTe();
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -6808,6 +7309,15 @@
return false;
}
+ boolean this_present_te = true && this.isSetTe();
+ boolean that_present_te = true && that.isSetTe();
+ if (this_present_te || that_present_te) {
+ if (!(this_present_te && that_present_te))
+ return false;
+ if (!this.te.equals(that.te))
+ return false;
+ }
+
return true;
}
@@ -6848,6 +7358,14 @@
if (lastComparison != 0) {
return lastComparison;
}
+ lastComparison = Boolean.valueOf(isSetTe()).compareTo(isSetTe());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ lastComparison = TBaseHelper.compareTo(te, typedOther.te);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
return 0;
}
@@ -6895,6 +7413,14 @@
TProtocolUtil.skip(iprot, field.type);
}
break;
+ case TE:
+ if (field.type == TType.STRUCT) {
+ this.te = new TimedOutException();
+ this.te.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
default:
TProtocolUtil.skip(iprot, field.type);
break;
@@ -6930,6 +7456,10 @@
oprot.writeFieldBegin(UE_FIELD_DESC);
this.ue.write(oprot);
oprot.writeFieldEnd();
+ } else if (this.isSetTe()) {
+ oprot.writeFieldBegin(TE_FIELD_DESC);
+ this.te.write(oprot);
+ oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
@@ -6963,6 +7493,14 @@
sb.append(this.ue);
}
first = false;
+ if (!first) sb.append(", ");
+ sb.append("te:");
+ if (this.te == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.te);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
@@ -7751,13 +8289,16 @@
private static final TField SUCCESS_FIELD_DESC = new TField("success", TType.LIST, (short)0);
private static final TField IRE_FIELD_DESC = new TField("ire", TType.STRUCT, (short)1);
private static final TField UE_FIELD_DESC = new TField("ue", TType.STRUCT, (short)2);
+ private static final TField TE_FIELD_DESC = new TField("te", TType.STRUCT, (short)3);
public List<KeySlice> success;
public InvalidRequestException ire;
public UnavailableException ue;
+ public TimedOutException te;
public static final int SUCCESS = 0;
public static final int IRE = 1;
public static final int UE = 2;
+ public static final int TE = 3;
// isset id assignments
@@ -7769,6 +8310,8 @@
new FieldValueMetaData(TType.STRUCT)));
put(UE, new FieldMetaData("ue", TFieldRequirementType.DEFAULT,
new FieldValueMetaData(TType.STRUCT)));
+ put(TE, new FieldMetaData("te", TFieldRequirementType.DEFAULT,
+ new FieldValueMetaData(TType.STRUCT)));
}});
static {
@@ -7781,12 +8324,14 @@
public get_range_slice_result(
List<KeySlice> success,
InvalidRequestException ire,
- UnavailableException ue)
+ UnavailableException ue,
+ TimedOutException te)
{
this();
this.success = success;
this.ire = ire;
this.ue = ue;
+ this.te = te;
}
/**
@@ -7806,6 +8351,9 @@
if (other.isSetUe()) {
this.ue = new UnavailableException(other.ue);
}
+ if (other.isSetTe()) {
+ this.te = new TimedOutException(other.te);
+ }
}
public get_range_slice_result deepCopy() {
@@ -7889,6 +8437,30 @@
}
}
+ public TimedOutException getTe() {
+ return this.te;
+ }
+
+ public get_range_slice_result setTe(TimedOutException te) {
+ this.te = te;
+ return this;
+ }
+
+ public void unsetTe() {
+ this.te = null;
+ }
+
+ // Returns true if field te is set (has been asigned a value) and false otherwise
+ public boolean isSetTe() {
+ return this.te != null;
+ }
+
+ public void setTeIsSet(boolean value) {
+ if (!value) {
+ this.te = null;
+ }
+ }
+
public void setFieldValue(int fieldID, Object value) {
switch (fieldID) {
case SUCCESS:
@@ -7915,6 +8487,14 @@
}
break;
+ case TE:
+ if (value == null) {
+ unsetTe();
+ } else {
+ setTe((TimedOutException)value);
+ }
+ break;
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -7931,6 +8511,9 @@
case UE:
return getUe();
+ case TE:
+ return getTe();
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -7945,6 +8528,8 @@
return isSetIre();
case UE:
return isSetUe();
+ case TE:
+ return isSetTe();
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -7990,6 +8575,15 @@
return false;
}
+ boolean this_present_te = true && this.isSetTe();
+ boolean that_present_te = true && that.isSetTe();
+ if (this_present_te || that_present_te) {
+ if (!(this_present_te && that_present_te))
+ return false;
+ if (!this.te.equals(that.te))
+ return false;
+ }
+
return true;
}
@@ -8030,6 +8624,14 @@
if (lastComparison != 0) {
return lastComparison;
}
+ lastComparison = Boolean.valueOf(isSetTe()).compareTo(isSetTe());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ lastComparison = TBaseHelper.compareTo(te, typedOther.te);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
return 0;
}
@@ -8078,6 +8680,14 @@
TProtocolUtil.skip(iprot, field.type);
}
break;
+ case TE:
+ if (field.type == TType.STRUCT) {
+ this.te = new TimedOutException();
+ this.te.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
default:
TProtocolUtil.skip(iprot, field.type);
break;
@@ -8113,6 +8723,10 @@
oprot.writeFieldBegin(UE_FIELD_DESC);
this.ue.write(oprot);
oprot.writeFieldEnd();
+ } else if (this.isSetTe()) {
+ oprot.writeFieldBegin(TE_FIELD_DESC);
+ this.te.write(oprot);
+ oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
@@ -8146,6 +8760,14 @@
sb.append(this.ue);
}
first = false;
+ if (!first) sb.append(", ");
+ sb.append("te:");
+ if (this.te == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.te);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
@@ -8845,11 +9467,14 @@
private static final TStruct STRUCT_DESC = new TStruct("insert_result");
private static final TField IRE_FIELD_DESC = new TField("ire", TType.STRUCT, (short)1);
private static final TField UE_FIELD_DESC = new TField("ue", TType.STRUCT, (short)2);
+ private static final TField TE_FIELD_DESC = new TField("te", TType.STRUCT, (short)3);
public InvalidRequestException ire;
public UnavailableException ue;
+ public TimedOutException te;
public static final int IRE = 1;
public static final int UE = 2;
+ public static final int TE = 3;
// isset id assignments
@@ -8858,6 +9483,8 @@
new FieldValueMetaData(TType.STRUCT)));
put(UE, new FieldMetaData("ue", TFieldRequirementType.DEFAULT,
new FieldValueMetaData(TType.STRUCT)));
+ put(TE, new FieldMetaData("te", TFieldRequirementType.DEFAULT,
+ new FieldValueMetaData(TType.STRUCT)));
}});
static {
@@ -8869,11 +9496,13 @@
public insert_result(
InvalidRequestException ire,
- UnavailableException ue)
+ UnavailableException ue,
+ TimedOutException te)
{
this();
this.ire = ire;
this.ue = ue;
+ this.te = te;
}
/**
@@ -8886,6 +9515,9 @@
if (other.isSetUe()) {
this.ue = new UnavailableException(other.ue);
}
+ if (other.isSetTe()) {
+ this.te = new TimedOutException(other.te);
+ }
}
public insert_result deepCopy() {
@@ -8945,6 +9577,30 @@
}
}
+ public TimedOutException getTe() {
+ return this.te;
+ }
+
+ public insert_result setTe(TimedOutException te) {
+ this.te = te;
+ return this;
+ }
+
+ public void unsetTe() {
+ this.te = null;
+ }
+
+ // Returns true if field te is set (has been asigned a value) and false otherwise
+ public boolean isSetTe() {
+ return this.te != null;
+ }
+
+ public void setTeIsSet(boolean value) {
+ if (!value) {
+ this.te = null;
+ }
+ }
+
public void setFieldValue(int fieldID, Object value) {
switch (fieldID) {
case IRE:
@@ -8963,6 +9619,14 @@
}
break;
+ case TE:
+ if (value == null) {
+ unsetTe();
+ } else {
+ setTe((TimedOutException)value);
+ }
+ break;
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -8976,6 +9640,9 @@
case UE:
return getUe();
+ case TE:
+ return getTe();
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -8988,6 +9655,8 @@
return isSetIre();
case UE:
return isSetUe();
+ case TE:
+ return isSetTe();
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -9024,6 +9693,15 @@
return false;
}
+ boolean this_present_te = true && this.isSetTe();
+ boolean that_present_te = true && that.isSetTe();
+ if (this_present_te || that_present_te) {
+ if (!(this_present_te && that_present_te))
+ return false;
+ if (!this.te.equals(that.te))
+ return false;
+ }
+
return true;
}
@@ -9056,6 +9734,14 @@
if (lastComparison != 0) {
return lastComparison;
}
+ lastComparison = Boolean.valueOf(isSetTe()).compareTo(isSetTe());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ lastComparison = TBaseHelper.compareTo(te, typedOther.te);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
return 0;
}
@@ -9086,6 +9772,14 @@
TProtocolUtil.skip(iprot, field.type);
}
break;
+ case TE:
+ if (field.type == TType.STRUCT) {
+ this.te = new TimedOutException();
+ this.te.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
default:
TProtocolUtil.skip(iprot, field.type);
break;
@@ -9110,6 +9804,10 @@
oprot.writeFieldBegin(UE_FIELD_DESC);
this.ue.write(oprot);
oprot.writeFieldEnd();
+ } else if (this.isSetTe()) {
+ oprot.writeFieldBegin(TE_FIELD_DESC);
+ this.te.write(oprot);
+ oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
@@ -9135,6 +9833,14 @@
sb.append(this.ue);
}
first = false;
+ if (!first) sb.append(", ");
+ sb.append("te:");
+ if (this.te == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.te);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
@@ -9671,11 +10377,14 @@
private static final TStruct STRUCT_DESC = new TStruct("batch_insert_result");
private static final TField IRE_FIELD_DESC = new TField("ire", TType.STRUCT, (short)1);
private static final TField UE_FIELD_DESC = new TField("ue", TType.STRUCT, (short)2);
+ private static final TField TE_FIELD_DESC = new TField("te", TType.STRUCT, (short)3);
public InvalidRequestException ire;
public UnavailableException ue;
+ public TimedOutException te;
public static final int IRE = 1;
public static final int UE = 2;
+ public static final int TE = 3;
// isset id assignments
@@ -9684,6 +10393,8 @@
new FieldValueMetaData(TType.STRUCT)));
put(UE, new FieldMetaData("ue", TFieldRequirementType.DEFAULT,
new FieldValueMetaData(TType.STRUCT)));
+ put(TE, new FieldMetaData("te", TFieldRequirementType.DEFAULT,
+ new FieldValueMetaData(TType.STRUCT)));
}});
static {
@@ -9695,11 +10406,13 @@
public batch_insert_result(
InvalidRequestException ire,
- UnavailableException ue)
+ UnavailableException ue,
+ TimedOutException te)
{
this();
this.ire = ire;
this.ue = ue;
+ this.te = te;
}
/**
@@ -9712,6 +10425,9 @@
if (other.isSetUe()) {
this.ue = new UnavailableException(other.ue);
}
+ if (other.isSetTe()) {
+ this.te = new TimedOutException(other.te);
+ }
}
public batch_insert_result deepCopy() {
@@ -9771,6 +10487,30 @@
}
}
+ public TimedOutException getTe() {
+ return this.te;
+ }
+
+ public batch_insert_result setTe(TimedOutException te) {
+ this.te = te;
+ return this;
+ }
+
+ public void unsetTe() {
+ this.te = null;
+ }
+
+ // Returns true if field te is set (has been asigned a value) and false otherwise
+ public boolean isSetTe() {
+ return this.te != null;
+ }
+
+ public void setTeIsSet(boolean value) {
+ if (!value) {
+ this.te = null;
+ }
+ }
+
public void setFieldValue(int fieldID, Object value) {
switch (fieldID) {
case IRE:
@@ -9789,6 +10529,14 @@
}
break;
+ case TE:
+ if (value == null) {
+ unsetTe();
+ } else {
+ setTe((TimedOutException)value);
+ }
+ break;
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -9802,6 +10550,9 @@
case UE:
return getUe();
+ case TE:
+ return getTe();
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -9814,6 +10565,8 @@
return isSetIre();
case UE:
return isSetUe();
+ case TE:
+ return isSetTe();
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -9850,6 +10603,15 @@
return false;
}
+ boolean this_present_te = true && this.isSetTe();
+ boolean that_present_te = true && that.isSetTe();
+ if (this_present_te || that_present_te) {
+ if (!(this_present_te && that_present_te))
+ return false;
+ if (!this.te.equals(that.te))
+ return false;
+ }
+
return true;
}
@@ -9882,6 +10644,14 @@
if (lastComparison != 0) {
return lastComparison;
}
+ lastComparison = Boolean.valueOf(isSetTe()).compareTo(isSetTe());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ lastComparison = TBaseHelper.compareTo(te, typedOther.te);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
return 0;
}
@@ -9912,6 +10682,14 @@
TProtocolUtil.skip(iprot, field.type);
}
break;
+ case TE:
+ if (field.type == TType.STRUCT) {
+ this.te = new TimedOutException();
+ this.te.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
default:
TProtocolUtil.skip(iprot, field.type);
break;
@@ -9936,6 +10714,10 @@
oprot.writeFieldBegin(UE_FIELD_DESC);
this.ue.write(oprot);
oprot.writeFieldEnd();
+ } else if (this.isSetTe()) {
+ oprot.writeFieldBegin(TE_FIELD_DESC);
+ this.te.write(oprot);
+ oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
@@ -9961,6 +10743,14 @@
sb.append(this.ue);
}
first = false;
+ if (!first) sb.append(", ");
+ sb.append("te:");
+ if (this.te == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.te);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
@@ -10563,11 +11353,14 @@
private static final TStruct STRUCT_DESC = new TStruct("remove_result");
private static final TField IRE_FIELD_DESC = new TField("ire", TType.STRUCT, (short)1);
private static final TField UE_FIELD_DESC = new TField("ue", TType.STRUCT, (short)2);
+ private static final TField TE_FIELD_DESC = new TField("te", TType.STRUCT, (short)3);
public InvalidRequestException ire;
public UnavailableException ue;
+ public TimedOutException te;
public static final int IRE = 1;
public static final int UE = 2;
+ public static final int TE = 3;
// isset id assignments
@@ -10576,6 +11369,8 @@
new FieldValueMetaData(TType.STRUCT)));
put(UE, new FieldMetaData("ue", TFieldRequirementType.DEFAULT,
new FieldValueMetaData(TType.STRUCT)));
+ put(TE, new FieldMetaData("te", TFieldRequirementType.DEFAULT,
+ new FieldValueMetaData(TType.STRUCT)));
}});
static {
@@ -10587,11 +11382,13 @@
public remove_result(
InvalidRequestException ire,
- UnavailableException ue)
+ UnavailableException ue,
+ TimedOutException te)
{
this();
this.ire = ire;
this.ue = ue;
+ this.te = te;
}
/**
@@ -10604,6 +11401,9 @@
if (other.isSetUe()) {
this.ue = new UnavailableException(other.ue);
}
+ if (other.isSetTe()) {
+ this.te = new TimedOutException(other.te);
+ }
}
public remove_result deepCopy() {
@@ -10663,6 +11463,30 @@
}
}
+ public TimedOutException getTe() {
+ return this.te;
+ }
+
+ public remove_result setTe(TimedOutException te) {
+ this.te = te;
+ return this;
+ }
+
+ public void unsetTe() {
+ this.te = null;
+ }
+
+ // Returns true if field te is set (has been asigned a value) and false otherwise
+ public boolean isSetTe() {
+ return this.te != null;
+ }
+
+ public void setTeIsSet(boolean value) {
+ if (!value) {
+ this.te = null;
+ }
+ }
+
public void setFieldValue(int fieldID, Object value) {
switch (fieldID) {
case IRE:
@@ -10681,6 +11505,14 @@
}
break;
+ case TE:
+ if (value == null) {
+ unsetTe();
+ } else {
+ setTe((TimedOutException)value);
+ }
+ break;
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -10694,6 +11526,9 @@
case UE:
return getUe();
+ case TE:
+ return getTe();
+
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -10706,6 +11541,8 @@
return isSetIre();
case UE:
return isSetUe();
+ case TE:
+ return isSetTe();
default:
throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
}
@@ -10742,6 +11579,15 @@
return false;
}
+ boolean this_present_te = true && this.isSetTe();
+ boolean that_present_te = true && that.isSetTe();
+ if (this_present_te || that_present_te) {
+ if (!(this_present_te && that_present_te))
+ return false;
+ if (!this.te.equals(that.te))
+ return false;
+ }
+
return true;
}
@@ -10774,6 +11620,14 @@
if (lastComparison != 0) {
return lastComparison;
}
+ lastComparison = Boolean.valueOf(isSetTe()).compareTo(isSetTe());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ lastComparison = TBaseHelper.compareTo(te, typedOther.te);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
return 0;
}
@@ -10804,6 +11658,14 @@
TProtocolUtil.skip(iprot, field.type);
}
break;
+ case TE:
+ if (field.type == TType.STRUCT) {
+ this.te = new TimedOutException();
+ this.te.read(iprot);
+ } else {
+ TProtocolUtil.skip(iprot, field.type);
+ }
+ break;
default:
TProtocolUtil.skip(iprot, field.type);
break;
@@ -10828,6 +11690,10 @@
oprot.writeFieldBegin(UE_FIELD_DESC);
this.ue.write(oprot);
oprot.writeFieldEnd();
+ } else if (this.isSetTe()) {
+ oprot.writeFieldBegin(TE_FIELD_DESC);
+ this.te.write(oprot);
+ oprot.writeFieldEnd();
}
oprot.writeFieldStop();
oprot.writeStructEnd();
@@ -10853,6 +11719,14 @@
sb.append(this.ue);
}
first = false;
+ if (!first) sb.append(", ");
+ sb.append("te:");
+ if (this.te == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.te);
+ }
+ first = false;
sb.append(")");
return sb.toString();
}
Added: incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/TimedOutException.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/TimedOutException.java?rev=882248&view=auto
==============================================================================
--- incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/TimedOutException.java (added)
+++ incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/TimedOutException.java Thu Nov 19 19:03:47 2009
@@ -0,0 +1,174 @@
+/**
+ * Autogenerated by Thrift
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ */
+package org.apache.cassandra.service;
+/*
+ *
+ * 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
+ * regarding copyright ownership. The ASF licenses this file
+ * 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.
+ *
+ */
+
+
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.util.Arrays;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import org.apache.thrift.*;
+import org.apache.thrift.meta_data.*;
+import org.apache.thrift.protocol.*;
+
+public class TimedOutException extends Exception implements TBase, java.io.Serializable, Cloneable, Comparable<TimedOutException> {
+ private static final TStruct STRUCT_DESC = new TStruct("TimedOutException");
+
+ public static final Map<Integer, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new HashMap<Integer, FieldMetaData>() {{
+ }});
+
+ static {
+ FieldMetaData.addStructMetaDataMap(TimedOutException.class, metaDataMap);
+ }
+
+ public TimedOutException() {
+ }
+
+ /**
+ * Performs a deep copy on <i>other</i>.
+ */
+ public TimedOutException(TimedOutException other) {
+ }
+
+ public TimedOutException deepCopy() {
+ return new TimedOutException(this);
+ }
+
+ @Deprecated
+ public TimedOutException clone() {
+ return new TimedOutException(this);
+ }
+
+ public void setFieldValue(int fieldID, Object value) {
+ switch (fieldID) {
+ default:
+ throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
+ }
+ }
+
+ public Object getFieldValue(int fieldID) {
+ switch (fieldID) {
+ default:
+ throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
+ }
+ }
+
+ // Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise
+ public boolean isSet(int fieldID) {
+ switch (fieldID) {
+ default:
+ throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
+ }
+ }
+
+ @Override
+ public boolean equals(Object that) {
+ if (that == null)
+ return false;
+ if (that instanceof TimedOutException)
+ return this.equals((TimedOutException)that);
+ return false;
+ }
+
+ public boolean equals(TimedOutException that) {
+ if (that == null)
+ return false;
+
+ return true;
+ }
+
+ @Override
+ public int hashCode() {
+ return 0;
+ }
+
+ public int compareTo(TimedOutException other) {
+ if (!getClass().equals(other.getClass())) {
+ return getClass().getName().compareTo(other.getClass().getName());
+ }
+
+ int lastComparison = 0;
+ TimedOutException typedOther = (TimedOutException)other;
+
+ return 0;
+ }
+
+ public void read(TProtocol iprot) throws TException {
+ TField field;
+ iprot.readStructBegin();
+ while (true)
+ {
+ field = iprot.readFieldBegin();
+ if (field.type == TType.STOP) {
+ break;
+ }
+ switch (field.id)
+ {
+ default:
+ TProtocolUtil.skip(iprot, field.type);
+ break;
+ }
+ iprot.readFieldEnd();
+ }
+ iprot.readStructEnd();
+
+
+ // check for required fields of primitive type, which can't be checked in the validate method
+ validate();
+ }
+
+ public void write(TProtocol oprot) throws TException {
+ validate();
+
+ oprot.writeStructBegin(STRUCT_DESC);
+ oprot.writeFieldStop();
+ oprot.writeStructEnd();
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder("TimedOutException(");
+ boolean first = true;
+
+ sb.append(")");
+ return sb.toString();
+ }
+
+ public void validate() throws TException {
+ // check for required fields
+ // check that fields of type enum have valid values
+ }
+
+}
+
Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/cli/CliClient.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/cli/CliClient.java?rev=882248&r1=882247&r2=882248&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/cli/CliClient.java (original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/cli/CliClient.java Thu Nov 19 19:03:47 2009
@@ -40,7 +40,7 @@
}
// Execute a CLI Statement
- public void executeCLIStmt(String stmt) throws TException, NotFoundException, InvalidRequestException, UnavailableException
+ public void executeCLIStmt(String stmt) throws TException, NotFoundException, InvalidRequestException, UnavailableException, TimedOutException
{
CommonTree ast = null;
@@ -111,7 +111,7 @@
}
// Execute GET statement
- private void executeGet(CommonTree ast) throws TException, NotFoundException, InvalidRequestException, UnavailableException
+ private void executeGet(CommonTree ast) throws TException, NotFoundException, InvalidRequestException, UnavailableException, TimedOutException
{
if (!CliMain.isConnected())
return;
@@ -174,7 +174,7 @@
}
// Execute SET statement
- private void executeSet(CommonTree ast) throws TException, InvalidRequestException, UnavailableException
+ private void executeSet(CommonTree ast) throws TException, InvalidRequestException, UnavailableException, TimedOutException
{
if (!CliMain.isConnected())
return;
@@ -203,7 +203,7 @@
try
{
thriftClient_.insert(tableName, key, new ColumnPath(columnFamily, null, columnName.getBytes("UTF-8")),
- value.getBytes(), System.currentTimeMillis(), ConsistencyLevel.ONE);
+ value.getBytes(), System.currentTimeMillis(), ConsistencyLevel.ONE);
}
catch (UnsupportedEncodingException e)
{