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/09/03 17:33:47 UTC
svn commit: r810997 - in /incubator/cassandra/trunk: ./ contrib/
contrib/bmt_example/ interface/
interface/gen-java/org/apache/cassandra/service/ src/java/org/
src/java/org/apache/cassandra/db/ test/unit/org/
Author: jbellis
Date: Thu Sep 3 15:33:46 2009
New Revision: 810997
URL: http://svn.apache.org/viewvc?rev=810997&view=rev
Log:
merge from 0.4 branch
Added:
incubator/cassandra/trunk/contrib/
- copied from r810993, incubator/cassandra/branches/cassandra-0.4/contrib/
incubator/cassandra/trunk/contrib/bmt_example/
- copied from r810993, incubator/cassandra/branches/cassandra-0.4/contrib/bmt_example/
incubator/cassandra/trunk/contrib/bmt_example/CassandraBulkLoader.java
- copied unchanged from r810993, incubator/cassandra/branches/cassandra-0.4/contrib/bmt_example/CassandraBulkLoader.java
Modified:
incubator/cassandra/trunk/ (props changed)
incubator/cassandra/trunk/CHANGES.txt
incubator/cassandra/trunk/build.xml
incubator/cassandra/trunk/interface/cassandra.thrift
incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/Cassandra.java (contents, props changed)
incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/Column.java (contents, props changed)
incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/ColumnOrSuperColumn.java
incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/ColumnParent.java
incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/ColumnPath.java
incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/InvalidRequestException.java (contents, props changed)
incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/NotFoundException.java (contents, props changed)
incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/SlicePredicate.java
incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/SliceRange.java
incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/SuperColumn.java (contents, props changed)
incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/UnavailableException.java
incubator/cassandra/trunk/src/java/org/ (props changed)
incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
incubator/cassandra/trunk/src/java/org/apache/cassandra/db/CommitLog.java
incubator/cassandra/trunk/src/java/org/apache/cassandra/db/CommitLogExecutorService.java
incubator/cassandra/trunk/test/unit/org/ (props changed)
Propchange: incubator/cassandra/trunk/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Sep 3 15:33:46 2009
@@ -1,2 +1,2 @@
/incubator/cassandra/branches/cassandra-0.3:774578-796573
-/incubator/cassandra/branches/cassandra-0.4:810145-810334
+/incubator/cassandra/branches/cassandra-0.4:810145-810993
Modified: incubator/cassandra/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/CHANGES.txt?rev=810997&r1=810996&r2=810997&view=diff
==============================================================================
--- incubator/cassandra/trunk/CHANGES.txt (original)
+++ incubator/cassandra/trunk/CHANGES.txt Thu Sep 3 15:33:46 2009
@@ -8,7 +8,7 @@
disagree on what data was present
* Snapshot support via JMX
* BinaryMemtable support for bulk load via hadoop; see
- https://github.com/lenn0x/Cassandra-Hadoop-BMT/tree
+ contrib/bmt_example for an example of using it.
* Thrift API has changed a _lot_:
- removed time-sorted CFs; instead, user-defined comparators
may be defined on the column names, which are now byte arrays.
Modified: incubator/cassandra/trunk/build.xml
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/build.xml?rev=810997&r1=810996&r2=810997&view=diff
==============================================================================
--- incubator/cassandra/trunk/build.xml (original)
+++ incubator/cassandra/trunk/build.xml Thu Sep 3 15:33:46 2009
@@ -37,7 +37,7 @@
<property name="test.name" value="*Test"/>
<property name="test.unit.src" value="${test.dir}/unit"/>
<property name="dist.dir" value="${build.dir}/dist"/>
- <property name="version" value="0.4.0-dev"/>
+ <property name="version" value="0.4.0-rc1"/>
<property name="final.name" value="${ant.project.name}-${version}"/>
<!-- http://cobertura.sourceforge.net/ -->
Modified: incubator/cassandra/trunk/interface/cassandra.thrift
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/interface/cassandra.thrift?rev=810997&r1=810996&r2=810997&view=diff
==============================================================================
--- incubator/cassandra/trunk/interface/cassandra.thrift (original)
+++ incubator/cassandra/trunk/interface/cassandra.thrift Thu Sep 3 15:33:46 2009
@@ -110,47 +110,81 @@
service Cassandra {
# retrieval methods
- ColumnOrSuperColumn get(1:string keyspace, 2:string key, 3:ColumnPath column_path, 4:ConsistencyLevel consistency_level=1)
- throws (1: InvalidRequestException ire, 2: NotFoundException nfe),
-
- list<ColumnOrSuperColumn> get_slice(1:string keyspace, 2:string key, 3:ColumnParent column_parent, 4:SlicePredicate predicate, 5:ConsistencyLevel consistency_level=1)
- throws (1: InvalidRequestException ire, 2: NotFoundException nfe),
-
- map<string,ColumnOrSuperColumn> multiget(1:string keyspace, 2:list<string> keys, 3:ColumnPath column_path, 4:ConsistencyLevel consistency_level=1)
- throws (1: InvalidRequestException ire),
-
- map<string,list<ColumnOrSuperColumn>> multiget_slice(1:string keyspace, 2:list<string> keys, 3:ColumnParent column_parent, 4:SlicePredicate predicate, 5:ConsistencyLevel consistency_level=1)
- throws (1: InvalidRequestException ire),
-
- i32 get_count(1:string keyspace, 2:string key, 3:ColumnParent column_parent, 5:ConsistencyLevel consistency_level=1)
- throws (1: InvalidRequestException ire),
+ ColumnOrSuperColumn get(1:required string keyspace,
+ 2:required string key,
+ 3:required ColumnPath column_path,
+ 4:required ConsistencyLevel consistency_level=1)
+ throws (1: InvalidRequestException ire, 2: NotFoundException nfe),
+
+ 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, 2: NotFoundException nfe),
+
+ 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),
+
+ 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),
+
+ 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),
# range query: returns matching keys
- list<string> get_key_range(1:string keyspace, 2:string column_family, 3:string start="", 4:string finish="", 5:i32 count=100, 6:ConsistencyLevel consistency_level=1)
- throws (1: InvalidRequestException ire),
+ list<string> get_key_range(1:required string keyspace,
+ 2:required string column_family,
+ 3:required string start="",
+ 4:required string finish="",
+ 5:required i32 count=100,
+ 6:required ConsistencyLevel consistency_level=1)
+ throws (1: InvalidRequestException ire),
# modification methods
- void insert(1:string keyspace, 2:string key, 3:ColumnPath column_path, 4:binary value, 5:i64 timestamp, 6:ConsistencyLevel consistency_level=0)
- throws (1: InvalidRequestException ire, 2: UnavailableException ue),
-
- void batch_insert(1:string keyspace, 2:string key, 3:map<string, list<ColumnOrSuperColumn>> cfmap, 4:ConsistencyLevel consistency_level=0)
- throws (1: InvalidRequestException ire, 2: UnavailableException ue),
-
- void remove(1:string keyspace, 2:string key, 3:ColumnPath column_path, 4:i64 timestamp, 5:ConsistencyLevel consistency_level=0)
- throws (1: InvalidRequestException ire, 2: UnavailableException ue),
+ void insert(1:required string keyspace,
+ 2:required string key,
+ 3:required ColumnPath column_path,
+ 4:required binary value,
+ 5:required i64 timestamp,
+ 6:required ConsistencyLevel consistency_level=0)
+ throws (1: InvalidRequestException ire, 2: UnavailableException ue),
+
+ 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),
+
+ 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),
// Meta-APIs -- APIs to get information about the node or cluster,
// rather than user data. The nodeprobe program provides usage examples.
// get property whose value is of type "string"
- string get_string_property(1:string property),
+ string get_string_property(1:required string property),
// get property whose value is list of "strings"
- list<string> get_string_list_property(1:string property),
+ list<string> get_string_list_property(1:required string property),
// describe specified keyspace
- map<string, map<string, string>> describe_keyspace(1:string keyspace)
- throws (1: NotFoundException nfe),
+ map<string, map<string, string>> describe_keyspace(1:required string keyspace)
+ 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=810997&r1=810996&r2=810997&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 Sep 3 15:33:46 2009
@@ -34,6 +34,7 @@
import java.util.HashSet;
import java.util.Collections;
import java.util.BitSet;
+import java.util.Arrays;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -942,16 +943,16 @@
private static final TField CONSISTENCY_LEVEL_FIELD_DESC = new TField("consistency_level", TType.I32, (short)4);
public String keyspace;
- public static final int KEYSPACE = 1;
public String key;
- public static final int KEY = 2;
public ColumnPath column_path;
- public static final int COLUMN_PATH = 3;
/**
*
* @see ConsistencyLevel
*/
public int consistency_level;
+ public static final int KEYSPACE = 1;
+ public static final int KEY = 2;
+ public static final int COLUMN_PATH = 3;
public static final int CONSISTENCY_LEVEL = 4;
// isset id assignments
@@ -959,13 +960,13 @@
private BitSet __isset_bit_vector = new BitSet(1);
public static final Map<Integer, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new HashMap<Integer, FieldMetaData>() {{
- put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.DEFAULT,
+ put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
- put(KEY, new FieldMetaData("key", TFieldRequirementType.DEFAULT,
+ put(KEY, new FieldMetaData("key", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
- put(COLUMN_PATH, new FieldMetaData("column_path", TFieldRequirementType.DEFAULT,
+ put(COLUMN_PATH, new FieldMetaData("column_path", TFieldRequirementType.REQUIRED,
new StructMetaData(TType.STRUCT, ColumnPath.class)));
- put(CONSISTENCY_LEVEL, new FieldMetaData("consistency_level", TFieldRequirementType.DEFAULT,
+ put(CONSISTENCY_LEVEL, new FieldMetaData("consistency_level", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.I32)));
}});
@@ -1010,7 +1011,11 @@
this.consistency_level = other.consistency_level;
}
- @Override
+ public get_args deepCopy() {
+ return new get_args(this);
+ }
+
+ @Deprecated
public get_args clone() {
return new get_args(this);
}
@@ -1343,6 +1348,9 @@
// check for required fields of primitive type, which can't be checked in the validate method
+ if (!isSetConsistency_level()) {
+ throw new TProtocolException("Required field 'consistency_level' was not found in serialized data! Struct: " + toString());
+ }
validate();
}
@@ -1418,6 +1426,16 @@
public void validate() throws TException {
// check for required fields
+ if (keyspace == null) {
+ throw new TProtocolException("Required field 'keyspace' was not present! Struct: " + toString());
+ }
+ if (key == null) {
+ throw new TProtocolException("Required field 'key' was not present! Struct: " + toString());
+ }
+ if (column_path == null) {
+ throw new TProtocolException("Required field 'column_path' was not present! Struct: " + toString());
+ }
+ // alas, we cannot check 'consistency_level' because it's a primitive and you chose the non-beans generator.
// check that fields of type enum have valid values
if (isSetConsistency_level() && !ConsistencyLevel.VALID_VALUES.contains(consistency_level)){
throw new TProtocolException("The field 'consistency_level' has been assigned the invalid value " + consistency_level);
@@ -1433,10 +1451,10 @@
private static final TField NFE_FIELD_DESC = new TField("nfe", TType.STRUCT, (short)2);
public ColumnOrSuperColumn success;
- public static final int SUCCESS = 0;
public InvalidRequestException ire;
- public static final int IRE = 1;
public NotFoundException nfe;
+ public static final int SUCCESS = 0;
+ public static final int IRE = 1;
public static final int NFE = 2;
// isset id assignments
@@ -1483,7 +1501,11 @@
}
}
- @Override
+ public get_result deepCopy() {
+ return new get_result(this);
+ }
+
+ @Deprecated
public get_result clone() {
return new get_result(this);
}
@@ -1820,18 +1842,18 @@
private static final TField CONSISTENCY_LEVEL_FIELD_DESC = new TField("consistency_level", TType.I32, (short)5);
public String keyspace;
- public static final int KEYSPACE = 1;
public String key;
- public static final int KEY = 2;
public ColumnParent column_parent;
- public static final int COLUMN_PARENT = 3;
public SlicePredicate predicate;
- public static final int PREDICATE = 4;
/**
*
* @see ConsistencyLevel
*/
public int consistency_level;
+ public static final int KEYSPACE = 1;
+ public static final int KEY = 2;
+ public static final int COLUMN_PARENT = 3;
+ public static final int PREDICATE = 4;
public static final int CONSISTENCY_LEVEL = 5;
// isset id assignments
@@ -1839,15 +1861,15 @@
private BitSet __isset_bit_vector = new BitSet(1);
public static final Map<Integer, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new HashMap<Integer, FieldMetaData>() {{
- put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.DEFAULT,
+ put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
- put(KEY, new FieldMetaData("key", TFieldRequirementType.DEFAULT,
+ put(KEY, new FieldMetaData("key", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
- put(COLUMN_PARENT, new FieldMetaData("column_parent", TFieldRequirementType.DEFAULT,
+ put(COLUMN_PARENT, new FieldMetaData("column_parent", TFieldRequirementType.REQUIRED,
new StructMetaData(TType.STRUCT, ColumnParent.class)));
- put(PREDICATE, new FieldMetaData("predicate", TFieldRequirementType.DEFAULT,
+ put(PREDICATE, new FieldMetaData("predicate", TFieldRequirementType.REQUIRED,
new StructMetaData(TType.STRUCT, SlicePredicate.class)));
- put(CONSISTENCY_LEVEL, new FieldMetaData("consistency_level", TFieldRequirementType.DEFAULT,
+ put(CONSISTENCY_LEVEL, new FieldMetaData("consistency_level", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.I32)));
}});
@@ -1897,7 +1919,11 @@
this.consistency_level = other.consistency_level;
}
- @Override
+ public get_slice_args deepCopy() {
+ return new get_slice_args(this);
+ }
+
+ @Deprecated
public get_slice_args clone() {
return new get_slice_args(this);
}
@@ -2292,6 +2318,9 @@
// check for required fields of primitive type, which can't be checked in the validate method
+ if (!isSetConsistency_level()) {
+ throw new TProtocolException("Required field 'consistency_level' was not found in serialized data! Struct: " + toString());
+ }
validate();
}
@@ -2380,6 +2409,19 @@
public void validate() throws TException {
// check for required fields
+ if (keyspace == null) {
+ throw new TProtocolException("Required field 'keyspace' was not present! Struct: " + toString());
+ }
+ if (key == null) {
+ throw new TProtocolException("Required field 'key' was not present! Struct: " + toString());
+ }
+ if (column_parent == null) {
+ throw new TProtocolException("Required field 'column_parent' was not present! Struct: " + toString());
+ }
+ if (predicate == null) {
+ throw new TProtocolException("Required field 'predicate' was not present! Struct: " + toString());
+ }
+ // alas, we cannot check 'consistency_level' because it's a primitive and you chose the non-beans generator.
// check that fields of type enum have valid values
if (isSetConsistency_level() && !ConsistencyLevel.VALID_VALUES.contains(consistency_level)){
throw new TProtocolException("The field 'consistency_level' has been assigned the invalid value " + consistency_level);
@@ -2395,10 +2437,10 @@
private static final TField NFE_FIELD_DESC = new TField("nfe", TType.STRUCT, (short)2);
public List<ColumnOrSuperColumn> success;
- public static final int SUCCESS = 0;
public InvalidRequestException ire;
- public static final int IRE = 1;
public NotFoundException nfe;
+ public static final int SUCCESS = 0;
+ public static final int IRE = 1;
public static final int NFE = 2;
// isset id assignments
@@ -2450,7 +2492,11 @@
}
}
- @Override
+ public get_slice_result deepCopy() {
+ return new get_slice_result(this);
+ }
+
+ @Deprecated
public get_slice_result clone() {
return new get_slice_result(this);
}
@@ -2736,7 +2782,8 @@
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new TList(TType.STRUCT, this.success.size()));
- for (ColumnOrSuperColumn _iter11 : this.success) {
+ for (ColumnOrSuperColumn _iter11 : this.success)
+ {
_iter11.write(oprot);
}
oprot.writeListEnd();
@@ -2802,16 +2849,16 @@
private static final TField CONSISTENCY_LEVEL_FIELD_DESC = new TField("consistency_level", TType.I32, (short)4);
public String keyspace;
- public static final int KEYSPACE = 1;
public List<String> keys;
- public static final int KEYS = 2;
public ColumnPath column_path;
- public static final int COLUMN_PATH = 3;
/**
*
* @see ConsistencyLevel
*/
public int consistency_level;
+ public static final int KEYSPACE = 1;
+ public static final int KEYS = 2;
+ public static final int COLUMN_PATH = 3;
public static final int CONSISTENCY_LEVEL = 4;
// isset id assignments
@@ -2819,14 +2866,14 @@
private BitSet __isset_bit_vector = new BitSet(1);
public static final Map<Integer, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new HashMap<Integer, FieldMetaData>() {{
- put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.DEFAULT,
+ put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
- put(KEYS, new FieldMetaData("keys", TFieldRequirementType.DEFAULT,
+ put(KEYS, new FieldMetaData("keys", TFieldRequirementType.REQUIRED,
new ListMetaData(TType.LIST,
new FieldValueMetaData(TType.STRING))));
- put(COLUMN_PATH, new FieldMetaData("column_path", TFieldRequirementType.DEFAULT,
+ put(COLUMN_PATH, new FieldMetaData("column_path", TFieldRequirementType.REQUIRED,
new StructMetaData(TType.STRUCT, ColumnPath.class)));
- put(CONSISTENCY_LEVEL, new FieldMetaData("consistency_level", TFieldRequirementType.DEFAULT,
+ put(CONSISTENCY_LEVEL, new FieldMetaData("consistency_level", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.I32)));
}});
@@ -2875,7 +2922,11 @@
this.consistency_level = other.consistency_level;
}
- @Override
+ public multiget_args deepCopy() {
+ return new multiget_args(this);
+ }
+
+ @Deprecated
public multiget_args clone() {
return new multiget_args(this);
}
@@ -3218,6 +3269,9 @@
// check for required fields of primitive type, which can't be checked in the validate method
+ if (!isSetConsistency_level()) {
+ throw new TProtocolException("Required field 'consistency_level' was not found in serialized data! Struct: " + toString());
+ }
validate();
}
@@ -3234,7 +3288,8 @@
oprot.writeFieldBegin(KEYS_FIELD_DESC);
{
oprot.writeListBegin(new TList(TType.STRING, this.keys.size()));
- for (String _iter15 : this.keys) {
+ for (String _iter15 : this.keys)
+ {
oprot.writeString(_iter15);
}
oprot.writeListEnd();
@@ -3299,6 +3354,16 @@
public void validate() throws TException {
// check for required fields
+ if (keyspace == null) {
+ throw new TProtocolException("Required field 'keyspace' was not present! Struct: " + toString());
+ }
+ if (keys == null) {
+ throw new TProtocolException("Required field 'keys' was not present! Struct: " + toString());
+ }
+ if (column_path == null) {
+ throw new TProtocolException("Required field 'column_path' was not present! Struct: " + toString());
+ }
+ // alas, we cannot check 'consistency_level' because it's a primitive and you chose the non-beans generator.
// check that fields of type enum have valid values
if (isSetConsistency_level() && !ConsistencyLevel.VALID_VALUES.contains(consistency_level)){
throw new TProtocolException("The field 'consistency_level' has been assigned the invalid value " + consistency_level);
@@ -3313,8 +3378,8 @@
private static final TField IRE_FIELD_DESC = new TField("ire", TType.STRUCT, (short)1);
public Map<String,ColumnOrSuperColumn> success;
- public static final int SUCCESS = 0;
public InvalidRequestException ire;
+ public static final int SUCCESS = 0;
public static final int IRE = 1;
// isset id assignments
@@ -3368,7 +3433,11 @@
}
}
- @Override
+ public multiget_result deepCopy() {
+ return new multiget_result(this);
+ }
+
+ @Deprecated
public multiget_result clone() {
return new multiget_result(this);
}
@@ -3567,7 +3636,8 @@
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeMapBegin(new TMap(TType.STRING, TType.STRUCT, this.success.size()));
- for (Map.Entry<String, ColumnOrSuperColumn> _iter20 : this.success.entrySet()) {
+ for (Map.Entry<String, ColumnOrSuperColumn> _iter20 : this.success.entrySet())
+ {
oprot.writeString(_iter20.getKey());
_iter20.getValue().write(oprot);
}
@@ -3623,18 +3693,18 @@
private static final TField CONSISTENCY_LEVEL_FIELD_DESC = new TField("consistency_level", TType.I32, (short)5);
public String keyspace;
- public static final int KEYSPACE = 1;
public List<String> keys;
- public static final int KEYS = 2;
public ColumnParent column_parent;
- public static final int COLUMN_PARENT = 3;
public SlicePredicate predicate;
- public static final int PREDICATE = 4;
/**
*
* @see ConsistencyLevel
*/
public int consistency_level;
+ public static final int KEYSPACE = 1;
+ public static final int KEYS = 2;
+ public static final int COLUMN_PARENT = 3;
+ public static final int PREDICATE = 4;
public static final int CONSISTENCY_LEVEL = 5;
// isset id assignments
@@ -3642,16 +3712,16 @@
private BitSet __isset_bit_vector = new BitSet(1);
public static final Map<Integer, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new HashMap<Integer, FieldMetaData>() {{
- put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.DEFAULT,
+ put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
- put(KEYS, new FieldMetaData("keys", TFieldRequirementType.DEFAULT,
+ put(KEYS, new FieldMetaData("keys", TFieldRequirementType.REQUIRED,
new ListMetaData(TType.LIST,
new FieldValueMetaData(TType.STRING))));
- put(COLUMN_PARENT, new FieldMetaData("column_parent", TFieldRequirementType.DEFAULT,
+ put(COLUMN_PARENT, new FieldMetaData("column_parent", TFieldRequirementType.REQUIRED,
new StructMetaData(TType.STRUCT, ColumnParent.class)));
- put(PREDICATE, new FieldMetaData("predicate", TFieldRequirementType.DEFAULT,
+ put(PREDICATE, new FieldMetaData("predicate", TFieldRequirementType.REQUIRED,
new StructMetaData(TType.STRUCT, SlicePredicate.class)));
- put(CONSISTENCY_LEVEL, new FieldMetaData("consistency_level", TFieldRequirementType.DEFAULT,
+ put(CONSISTENCY_LEVEL, new FieldMetaData("consistency_level", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.I32)));
}});
@@ -3705,7 +3775,11 @@
this.consistency_level = other.consistency_level;
}
- @Override
+ public multiget_slice_args deepCopy() {
+ return new multiget_slice_args(this);
+ }
+
+ @Deprecated
public multiget_slice_args clone() {
return new multiget_slice_args(this);
}
@@ -4110,6 +4184,9 @@
// check for required fields of primitive type, which can't be checked in the validate method
+ if (!isSetConsistency_level()) {
+ throw new TProtocolException("Required field 'consistency_level' was not found in serialized data! Struct: " + toString());
+ }
validate();
}
@@ -4126,7 +4203,8 @@
oprot.writeFieldBegin(KEYS_FIELD_DESC);
{
oprot.writeListBegin(new TList(TType.STRING, this.keys.size()));
- for (String _iter24 : this.keys) {
+ for (String _iter24 : this.keys)
+ {
oprot.writeString(_iter24);
}
oprot.writeListEnd();
@@ -4204,6 +4282,19 @@
public void validate() throws TException {
// check for required fields
+ if (keyspace == null) {
+ throw new TProtocolException("Required field 'keyspace' was not present! Struct: " + toString());
+ }
+ if (keys == null) {
+ throw new TProtocolException("Required field 'keys' was not present! Struct: " + toString());
+ }
+ if (column_parent == null) {
+ throw new TProtocolException("Required field 'column_parent' was not present! Struct: " + toString());
+ }
+ if (predicate == null) {
+ throw new TProtocolException("Required field 'predicate' was not present! Struct: " + toString());
+ }
+ // alas, we cannot check 'consistency_level' because it's a primitive and you chose the non-beans generator.
// check that fields of type enum have valid values
if (isSetConsistency_level() && !ConsistencyLevel.VALID_VALUES.contains(consistency_level)){
throw new TProtocolException("The field 'consistency_level' has been assigned the invalid value " + consistency_level);
@@ -4218,8 +4309,8 @@
private static final TField IRE_FIELD_DESC = new TField("ire", TType.STRUCT, (short)1);
public Map<String,List<ColumnOrSuperColumn>> success;
- public static final int SUCCESS = 0;
public InvalidRequestException ire;
+ public static final int SUCCESS = 0;
public static final int IRE = 1;
// isset id assignments
@@ -4277,7 +4368,11 @@
}
}
- @Override
+ public multiget_slice_result deepCopy() {
+ return new multiget_slice_result(this);
+ }
+
+ @Deprecated
public multiget_slice_result clone() {
return new multiget_slice_result(this);
}
@@ -4486,11 +4581,13 @@
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeMapBegin(new TMap(TType.STRING, TType.LIST, this.success.size()));
- for (Map.Entry<String, List<ColumnOrSuperColumn>> _iter32 : this.success.entrySet()) {
+ for (Map.Entry<String, List<ColumnOrSuperColumn>> _iter32 : this.success.entrySet())
+ {
oprot.writeString(_iter32.getKey());
{
oprot.writeListBegin(new TList(TType.STRUCT, _iter32.getValue().size()));
- for (ColumnOrSuperColumn _iter33 : _iter32.getValue()) {
+ for (ColumnOrSuperColumn _iter33 : _iter32.getValue())
+ {
_iter33.write(oprot);
}
oprot.writeListEnd();
@@ -4544,33 +4641,33 @@
private static final TField KEYSPACE_FIELD_DESC = new TField("keyspace", TType.STRING, (short)1);
private static final TField KEY_FIELD_DESC = new TField("key", TType.STRING, (short)2);
private static final TField COLUMN_PARENT_FIELD_DESC = new TField("column_parent", TType.STRUCT, (short)3);
- private static final TField CONSISTENCY_LEVEL_FIELD_DESC = new TField("consistency_level", TType.I32, (short)5);
+ private static final TField CONSISTENCY_LEVEL_FIELD_DESC = new TField("consistency_level", TType.I32, (short)4);
public String keyspace;
- public static final int KEYSPACE = 1;
public String key;
- public static final int KEY = 2;
public ColumnParent column_parent;
- public static final int COLUMN_PARENT = 3;
/**
*
* @see ConsistencyLevel
*/
public int consistency_level;
- public static final int CONSISTENCY_LEVEL = 5;
+ public static final int KEYSPACE = 1;
+ public static final int KEY = 2;
+ public static final int COLUMN_PARENT = 3;
+ public static final int CONSISTENCY_LEVEL = 4;
// isset id assignments
private static final int __CONSISTENCY_LEVEL_ISSET_ID = 0;
private BitSet __isset_bit_vector = new BitSet(1);
public static final Map<Integer, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new HashMap<Integer, FieldMetaData>() {{
- put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.DEFAULT,
+ put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
- put(KEY, new FieldMetaData("key", TFieldRequirementType.DEFAULT,
+ put(KEY, new FieldMetaData("key", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
- put(COLUMN_PARENT, new FieldMetaData("column_parent", TFieldRequirementType.DEFAULT,
+ put(COLUMN_PARENT, new FieldMetaData("column_parent", TFieldRequirementType.REQUIRED,
new StructMetaData(TType.STRUCT, ColumnParent.class)));
- put(CONSISTENCY_LEVEL, new FieldMetaData("consistency_level", TFieldRequirementType.DEFAULT,
+ put(CONSISTENCY_LEVEL, new FieldMetaData("consistency_level", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.I32)));
}});
@@ -4615,7 +4712,11 @@
this.consistency_level = other.consistency_level;
}
- @Override
+ public get_count_args deepCopy() {
+ return new get_count_args(this);
+ }
+
+ @Deprecated
public get_count_args clone() {
return new get_count_args(this);
}
@@ -4948,6 +5049,9 @@
// check for required fields of primitive type, which can't be checked in the validate method
+ if (!isSetConsistency_level()) {
+ throw new TProtocolException("Required field 'consistency_level' was not found in serialized data! Struct: " + toString());
+ }
validate();
}
@@ -5023,6 +5127,16 @@
public void validate() throws TException {
// check for required fields
+ if (keyspace == null) {
+ throw new TProtocolException("Required field 'keyspace' was not present! Struct: " + toString());
+ }
+ if (key == null) {
+ throw new TProtocolException("Required field 'key' was not present! Struct: " + toString());
+ }
+ if (column_parent == null) {
+ throw new TProtocolException("Required field 'column_parent' was not present! Struct: " + toString());
+ }
+ // alas, we cannot check 'consistency_level' because it's a primitive and you chose the non-beans generator.
// check that fields of type enum have valid values
if (isSetConsistency_level() && !ConsistencyLevel.VALID_VALUES.contains(consistency_level)){
throw new TProtocolException("The field 'consistency_level' has been assigned the invalid value " + consistency_level);
@@ -5037,8 +5151,8 @@
private static final TField IRE_FIELD_DESC = new TField("ire", TType.STRUCT, (short)1);
public int success;
- public static final int SUCCESS = 0;
public InvalidRequestException ire;
+ public static final int SUCCESS = 0;
public static final int IRE = 1;
// isset id assignments
@@ -5081,7 +5195,11 @@
}
}
- @Override
+ public get_count_result deepCopy() {
+ return new get_count_result(this);
+ }
+
+ @Deprecated
public get_count_result clone() {
return new get_count_result(this);
}
@@ -5340,20 +5458,20 @@
private static final TField CONSISTENCY_LEVEL_FIELD_DESC = new TField("consistency_level", TType.I32, (short)6);
public String keyspace;
- public static final int KEYSPACE = 1;
public String column_family;
- public static final int COLUMN_FAMILY = 2;
public String start;
- public static final int START = 3;
public String finish;
- public static final int FINISH = 4;
public int count;
- public static final int COUNT = 5;
/**
*
* @see ConsistencyLevel
*/
public int consistency_level;
+ public static final int KEYSPACE = 1;
+ public static final int COLUMN_FAMILY = 2;
+ public static final int START = 3;
+ public static final int FINISH = 4;
+ public static final int COUNT = 5;
public static final int CONSISTENCY_LEVEL = 6;
// isset id assignments
@@ -5362,17 +5480,17 @@
private BitSet __isset_bit_vector = new BitSet(2);
public static final Map<Integer, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new HashMap<Integer, FieldMetaData>() {{
- put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.DEFAULT,
+ put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
- put(COLUMN_FAMILY, new FieldMetaData("column_family", TFieldRequirementType.DEFAULT,
+ put(COLUMN_FAMILY, new FieldMetaData("column_family", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
- put(START, new FieldMetaData("start", TFieldRequirementType.DEFAULT,
+ put(START, new FieldMetaData("start", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
- put(FINISH, new FieldMetaData("finish", TFieldRequirementType.DEFAULT,
+ put(FINISH, new FieldMetaData("finish", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
- put(COUNT, new FieldMetaData("count", TFieldRequirementType.DEFAULT,
+ put(COUNT, new FieldMetaData("count", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.I32)));
- put(CONSISTENCY_LEVEL, new FieldMetaData("consistency_level", TFieldRequirementType.DEFAULT,
+ put(CONSISTENCY_LEVEL, new FieldMetaData("consistency_level", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.I32)));
}});
@@ -5432,7 +5550,11 @@
this.consistency_level = other.consistency_level;
}
- @Override
+ public get_key_range_args deepCopy() {
+ return new get_key_range_args(this);
+ }
+
+ @Deprecated
public get_key_range_args clone() {
return new get_key_range_args(this);
}
@@ -5886,6 +6008,12 @@
// check for required fields of primitive type, which can't be checked in the validate method
+ if (!isSetCount()) {
+ throw new TProtocolException("Required field 'count' was not found in serialized data! Struct: " + toString());
+ }
+ if (!isSetConsistency_level()) {
+ throw new TProtocolException("Required field 'consistency_level' was not found in serialized data! Struct: " + toString());
+ }
validate();
}
@@ -5981,6 +6109,20 @@
public void validate() throws TException {
// check for required fields
+ if (keyspace == null) {
+ throw new TProtocolException("Required field 'keyspace' was not present! Struct: " + toString());
+ }
+ if (column_family == null) {
+ throw new TProtocolException("Required field 'column_family' was not present! Struct: " + toString());
+ }
+ if (start == null) {
+ throw new TProtocolException("Required field 'start' was not present! Struct: " + toString());
+ }
+ if (finish == null) {
+ throw new TProtocolException("Required field 'finish' was not present! Struct: " + toString());
+ }
+ // alas, we cannot check 'count' because it's a primitive and you chose the non-beans generator.
+ // alas, we cannot check 'consistency_level' because it's a primitive and you chose the non-beans generator.
// check that fields of type enum have valid values
if (isSetConsistency_level() && !ConsistencyLevel.VALID_VALUES.contains(consistency_level)){
throw new TProtocolException("The field 'consistency_level' has been assigned the invalid value " + consistency_level);
@@ -5995,8 +6137,8 @@
private static final TField IRE_FIELD_DESC = new TField("ire", TType.STRUCT, (short)1);
public List<String> success;
- public static final int SUCCESS = 0;
public InvalidRequestException ire;
+ public static final int SUCCESS = 0;
public static final int IRE = 1;
// isset id assignments
@@ -6041,7 +6183,11 @@
}
}
- @Override
+ public get_key_range_result deepCopy() {
+ return new get_key_range_result(this);
+ }
+
+ @Deprecated
public get_key_range_result clone() {
return new get_key_range_result(this);
}
@@ -6264,7 +6410,8 @@
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new TList(TType.STRING, this.success.size()));
- for (String _iter37 : this.success) {
+ for (String _iter37 : this.success)
+ {
oprot.writeString(_iter37);
}
oprot.writeListEnd();
@@ -6320,20 +6467,20 @@
private static final TField CONSISTENCY_LEVEL_FIELD_DESC = new TField("consistency_level", TType.I32, (short)6);
public String keyspace;
- public static final int KEYSPACE = 1;
public String key;
- public static final int KEY = 2;
public ColumnPath column_path;
- public static final int COLUMN_PATH = 3;
public byte[] value;
- public static final int VALUE = 4;
public long timestamp;
- public static final int TIMESTAMP = 5;
/**
*
* @see ConsistencyLevel
*/
public int consistency_level;
+ public static final int KEYSPACE = 1;
+ public static final int KEY = 2;
+ public static final int COLUMN_PATH = 3;
+ public static final int VALUE = 4;
+ public static final int TIMESTAMP = 5;
public static final int CONSISTENCY_LEVEL = 6;
// isset id assignments
@@ -6342,17 +6489,17 @@
private BitSet __isset_bit_vector = new BitSet(2);
public static final Map<Integer, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new HashMap<Integer, FieldMetaData>() {{
- put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.DEFAULT,
+ put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
- put(KEY, new FieldMetaData("key", TFieldRequirementType.DEFAULT,
+ put(KEY, new FieldMetaData("key", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
- put(COLUMN_PATH, new FieldMetaData("column_path", TFieldRequirementType.DEFAULT,
+ put(COLUMN_PATH, new FieldMetaData("column_path", TFieldRequirementType.REQUIRED,
new StructMetaData(TType.STRUCT, ColumnPath.class)));
- put(VALUE, new FieldMetaData("value", TFieldRequirementType.DEFAULT,
+ put(VALUE, new FieldMetaData("value", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
- put(TIMESTAMP, new FieldMetaData("timestamp", TFieldRequirementType.DEFAULT,
+ put(TIMESTAMP, new FieldMetaData("timestamp", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.I64)));
- put(CONSISTENCY_LEVEL, new FieldMetaData("consistency_level", TFieldRequirementType.DEFAULT,
+ put(CONSISTENCY_LEVEL, new FieldMetaData("consistency_level", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.I32)));
}});
@@ -6407,7 +6554,11 @@
this.consistency_level = other.consistency_level;
}
- @Override
+ public insert_args deepCopy() {
+ return new insert_args(this);
+ }
+
+ @Deprecated
public insert_args clone() {
return new insert_args(this);
}
@@ -6862,6 +7013,12 @@
// check for required fields of primitive type, which can't be checked in the validate method
+ if (!isSetTimestamp()) {
+ throw new TProtocolException("Required field 'timestamp' was not found in serialized data! Struct: " + toString());
+ }
+ if (!isSetConsistency_level()) {
+ throw new TProtocolException("Required field 'consistency_level' was not found in serialized data! Struct: " + toString());
+ }
validate();
}
@@ -6962,6 +7119,20 @@
public void validate() throws TException {
// check for required fields
+ if (keyspace == null) {
+ throw new TProtocolException("Required field 'keyspace' was not present! Struct: " + toString());
+ }
+ if (key == null) {
+ throw new TProtocolException("Required field 'key' was not present! Struct: " + toString());
+ }
+ if (column_path == null) {
+ throw new TProtocolException("Required field 'column_path' was not present! Struct: " + toString());
+ }
+ if (value == null) {
+ throw new TProtocolException("Required field 'value' was not present! Struct: " + toString());
+ }
+ // alas, we cannot check 'timestamp' because it's a primitive and you chose the non-beans generator.
+ // alas, we cannot check 'consistency_level' because it's a primitive and you chose the non-beans generator.
// check that fields of type enum have valid values
if (isSetConsistency_level() && !ConsistencyLevel.VALID_VALUES.contains(consistency_level)){
throw new TProtocolException("The field 'consistency_level' has been assigned the invalid value " + consistency_level);
@@ -6976,8 +7147,8 @@
private static final TField UE_FIELD_DESC = new TField("ue", TType.STRUCT, (short)2);
public InvalidRequestException ire;
- public static final int IRE = 1;
public UnavailableException ue;
+ public static final int IRE = 1;
public static final int UE = 2;
// isset id assignments
@@ -7017,7 +7188,11 @@
}
}
- @Override
+ public insert_result deepCopy() {
+ return new insert_result(this);
+ }
+
+ @Deprecated
public insert_result clone() {
return new insert_result(this);
}
@@ -7279,16 +7454,16 @@
private static final TField CONSISTENCY_LEVEL_FIELD_DESC = new TField("consistency_level", TType.I32, (short)4);
public String keyspace;
- public static final int KEYSPACE = 1;
public String key;
- public static final int KEY = 2;
public Map<String,List<ColumnOrSuperColumn>> cfmap;
- public static final int CFMAP = 3;
/**
*
* @see ConsistencyLevel
*/
public int consistency_level;
+ public static final int KEYSPACE = 1;
+ public static final int KEY = 2;
+ public static final int CFMAP = 3;
public static final int CONSISTENCY_LEVEL = 4;
// isset id assignments
@@ -7296,16 +7471,16 @@
private BitSet __isset_bit_vector = new BitSet(1);
public static final Map<Integer, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new HashMap<Integer, FieldMetaData>() {{
- put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.DEFAULT,
+ put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
- put(KEY, new FieldMetaData("key", TFieldRequirementType.DEFAULT,
+ put(KEY, new FieldMetaData("key", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
- put(CFMAP, new FieldMetaData("cfmap", TFieldRequirementType.DEFAULT,
+ put(CFMAP, new FieldMetaData("cfmap", TFieldRequirementType.REQUIRED,
new MapMetaData(TType.MAP,
new FieldValueMetaData(TType.STRING),
new ListMetaData(TType.LIST,
new StructMetaData(TType.STRUCT, ColumnOrSuperColumn.class)))));
- put(CONSISTENCY_LEVEL, new FieldMetaData("consistency_level", TFieldRequirementType.DEFAULT,
+ put(CONSISTENCY_LEVEL, new FieldMetaData("consistency_level", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.I32)));
}});
@@ -7365,7 +7540,11 @@
this.consistency_level = other.consistency_level;
}
- @Override
+ public batch_insert_args deepCopy() {
+ return new batch_insert_args(this);
+ }
+
+ @Deprecated
public batch_insert_args clone() {
return new batch_insert_args(this);
}
@@ -7677,6 +7856,9 @@
// check for required fields of primitive type, which can't be checked in the validate method
+ if (!isSetConsistency_level()) {
+ throw new TProtocolException("Required field 'consistency_level' was not found in serialized data! Struct: " + toString());
+ }
validate();
}
@@ -7698,11 +7880,13 @@
oprot.writeFieldBegin(CFMAP_FIELD_DESC);
{
oprot.writeMapBegin(new TMap(TType.STRING, TType.LIST, this.cfmap.size()));
- for (Map.Entry<String, List<ColumnOrSuperColumn>> _iter45 : this.cfmap.entrySet()) {
+ for (Map.Entry<String, List<ColumnOrSuperColumn>> _iter45 : this.cfmap.entrySet())
+ {
oprot.writeString(_iter45.getKey());
{
oprot.writeListBegin(new TList(TType.STRUCT, _iter45.getValue().size()));
- for (ColumnOrSuperColumn _iter46 : _iter45.getValue()) {
+ for (ColumnOrSuperColumn _iter46 : _iter45.getValue())
+ {
_iter46.write(oprot);
}
oprot.writeListEnd();
@@ -7765,6 +7949,16 @@
public void validate() throws TException {
// check for required fields
+ if (keyspace == null) {
+ throw new TProtocolException("Required field 'keyspace' was not present! Struct: " + toString());
+ }
+ if (key == null) {
+ throw new TProtocolException("Required field 'key' was not present! Struct: " + toString());
+ }
+ if (cfmap == null) {
+ throw new TProtocolException("Required field 'cfmap' was not present! Struct: " + toString());
+ }
+ // alas, we cannot check 'consistency_level' because it's a primitive and you chose the non-beans generator.
// check that fields of type enum have valid values
if (isSetConsistency_level() && !ConsistencyLevel.VALID_VALUES.contains(consistency_level)){
throw new TProtocolException("The field 'consistency_level' has been assigned the invalid value " + consistency_level);
@@ -7779,8 +7973,8 @@
private static final TField UE_FIELD_DESC = new TField("ue", TType.STRUCT, (short)2);
public InvalidRequestException ire;
- public static final int IRE = 1;
public UnavailableException ue;
+ public static final int IRE = 1;
public static final int UE = 2;
// isset id assignments
@@ -7820,7 +8014,11 @@
}
}
- @Override
+ public batch_insert_result deepCopy() {
+ return new batch_insert_result(this);
+ }
+
+ @Deprecated
public batch_insert_result clone() {
return new batch_insert_result(this);
}
@@ -8083,18 +8281,18 @@
private static final TField CONSISTENCY_LEVEL_FIELD_DESC = new TField("consistency_level", TType.I32, (short)5);
public String keyspace;
- public static final int KEYSPACE = 1;
public String key;
- public static final int KEY = 2;
public ColumnPath column_path;
- public static final int COLUMN_PATH = 3;
public long timestamp;
- public static final int TIMESTAMP = 4;
/**
*
* @see ConsistencyLevel
*/
public int consistency_level;
+ public static final int KEYSPACE = 1;
+ public static final int KEY = 2;
+ public static final int COLUMN_PATH = 3;
+ public static final int TIMESTAMP = 4;
public static final int CONSISTENCY_LEVEL = 5;
// isset id assignments
@@ -8103,13 +8301,13 @@
private BitSet __isset_bit_vector = new BitSet(2);
public static final Map<Integer, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new HashMap<Integer, FieldMetaData>() {{
- put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.DEFAULT,
+ put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
- put(KEY, new FieldMetaData("key", TFieldRequirementType.DEFAULT,
+ put(KEY, new FieldMetaData("key", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
- put(COLUMN_PATH, new FieldMetaData("column_path", TFieldRequirementType.DEFAULT,
+ put(COLUMN_PATH, new FieldMetaData("column_path", TFieldRequirementType.REQUIRED,
new StructMetaData(TType.STRUCT, ColumnPath.class)));
- put(TIMESTAMP, new FieldMetaData("timestamp", TFieldRequirementType.DEFAULT,
+ put(TIMESTAMP, new FieldMetaData("timestamp", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.I64)));
put(CONSISTENCY_LEVEL, new FieldMetaData("consistency_level", TFieldRequirementType.DEFAULT,
new FieldValueMetaData(TType.I32)));
@@ -8160,7 +8358,11 @@
this.consistency_level = other.consistency_level;
}
- @Override
+ public remove_args deepCopy() {
+ return new remove_args(this);
+ }
+
+ @Deprecated
public remove_args clone() {
return new remove_args(this);
}
@@ -8554,6 +8756,9 @@
// check for required fields of primitive type, which can't be checked in the validate method
+ if (!isSetTimestamp()) {
+ throw new TProtocolException("Required field 'timestamp' was not found in serialized data! Struct: " + toString());
+ }
validate();
}
@@ -8636,6 +8841,16 @@
public void validate() throws TException {
// check for required fields
+ if (keyspace == null) {
+ throw new TProtocolException("Required field 'keyspace' was not present! Struct: " + toString());
+ }
+ if (key == null) {
+ throw new TProtocolException("Required field 'key' was not present! Struct: " + toString());
+ }
+ if (column_path == null) {
+ throw new TProtocolException("Required field 'column_path' was not present! Struct: " + toString());
+ }
+ // alas, we cannot check 'timestamp' because it's a primitive and you chose the non-beans generator.
// check that fields of type enum have valid values
if (isSetConsistency_level() && !ConsistencyLevel.VALID_VALUES.contains(consistency_level)){
throw new TProtocolException("The field 'consistency_level' has been assigned the invalid value " + consistency_level);
@@ -8650,8 +8865,8 @@
private static final TField UE_FIELD_DESC = new TField("ue", TType.STRUCT, (short)2);
public InvalidRequestException ire;
- public static final int IRE = 1;
public UnavailableException ue;
+ public static final int IRE = 1;
public static final int UE = 2;
// isset id assignments
@@ -8691,7 +8906,11 @@
}
}
- @Override
+ public remove_result deepCopy() {
+ return new remove_result(this);
+ }
+
+ @Deprecated
public remove_result clone() {
return new remove_result(this);
}
@@ -8955,7 +9174,7 @@
// isset id assignments
public static final Map<Integer, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new HashMap<Integer, FieldMetaData>() {{
- put(PROPERTY, new FieldMetaData("property", TFieldRequirementType.DEFAULT,
+ put(PROPERTY, new FieldMetaData("property", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
}});
@@ -8982,7 +9201,11 @@
}
}
- @Override
+ public get_string_property_args deepCopy() {
+ return new get_string_property_args(this);
+ }
+
+ @Deprecated
public get_string_property_args clone() {
return new get_string_property_args(this);
}
@@ -9157,6 +9380,9 @@
public void validate() throws TException {
// check for required fields
+ if (property == null) {
+ throw new TProtocolException("Required field 'property' was not present! Struct: " + toString());
+ }
// check that fields of type enum have valid values
}
@@ -9199,7 +9425,11 @@
}
}
- @Override
+ public get_string_property_result deepCopy() {
+ return new get_string_property_result(this);
+ }
+
+ @Deprecated
public get_string_property_result clone() {
return new get_string_property_result(this);
}
@@ -9388,7 +9618,7 @@
// isset id assignments
public static final Map<Integer, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new HashMap<Integer, FieldMetaData>() {{
- put(PROPERTY, new FieldMetaData("property", TFieldRequirementType.DEFAULT,
+ put(PROPERTY, new FieldMetaData("property", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
}});
@@ -9415,7 +9645,11 @@
}
}
- @Override
+ public get_string_list_property_args deepCopy() {
+ return new get_string_list_property_args(this);
+ }
+
+ @Deprecated
public get_string_list_property_args clone() {
return new get_string_list_property_args(this);
}
@@ -9590,6 +9824,9 @@
public void validate() throws TException {
// check for required fields
+ if (property == null) {
+ throw new TProtocolException("Required field 'property' was not present! Struct: " + toString());
+ }
// check that fields of type enum have valid values
}
@@ -9637,7 +9874,11 @@
}
}
- @Override
+ public get_string_list_property_result deepCopy() {
+ return new get_string_list_property_result(this);
+ }
+
+ @Deprecated
public get_string_list_property_result clone() {
return new get_string_list_property_result(this);
}
@@ -9798,7 +10039,8 @@
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeListBegin(new TList(TType.STRING, this.success.size()));
- for (String _iter50 : this.success) {
+ for (String _iter50 : this.success)
+ {
oprot.writeString(_iter50);
}
oprot.writeListEnd();
@@ -9842,7 +10084,7 @@
// isset id assignments
public static final Map<Integer, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new HashMap<Integer, FieldMetaData>() {{
- put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.DEFAULT,
+ put(KEYSPACE, new FieldMetaData("keyspace", TFieldRequirementType.REQUIRED,
new FieldValueMetaData(TType.STRING)));
}});
@@ -9869,7 +10111,11 @@
}
}
- @Override
+ public describe_keyspace_args deepCopy() {
+ return new describe_keyspace_args(this);
+ }
+
+ @Deprecated
public describe_keyspace_args clone() {
return new describe_keyspace_args(this);
}
@@ -10044,6 +10290,9 @@
public void validate() throws TException {
// check for required fields
+ if (keyspace == null) {
+ throw new TProtocolException("Required field 'keyspace' was not present! Struct: " + toString());
+ }
// check that fields of type enum have valid values
}
@@ -10055,8 +10304,8 @@
private static final TField NFE_FIELD_DESC = new TField("nfe", TType.STRUCT, (short)1);
public Map<String,Map<String,String>> success;
- public static final int SUCCESS = 0;
public NotFoundException nfe;
+ public static final int SUCCESS = 0;
public static final int NFE = 1;
// isset id assignments
@@ -10123,7 +10372,11 @@
}
}
- @Override
+ public describe_keyspace_result deepCopy() {
+ return new describe_keyspace_result(this);
+ }
+
+ @Deprecated
public describe_keyspace_result clone() {
return new describe_keyspace_result(this);
}
@@ -10333,11 +10586,13 @@
oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
{
oprot.writeMapBegin(new TMap(TType.STRING, TType.MAP, this.success.size()));
- for (Map.Entry<String, Map<String,String>> _iter59 : this.success.entrySet()) {
+ for (Map.Entry<String, Map<String,String>> _iter59 : this.success.entrySet())
+ {
oprot.writeString(_iter59.getKey());
{
oprot.writeMapBegin(new TMap(TType.STRING, TType.STRING, _iter59.getValue().size()));
- for (Map.Entry<String, String> _iter60 : _iter59.getValue().entrySet()) {
+ for (Map.Entry<String, String> _iter60 : _iter59.getValue().entrySet())
+ {
oprot.writeString(_iter60.getKey());
oprot.writeString(_iter60.getValue());
}
Propchange: incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/Cassandra.java
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Sep 3 15:33:46 2009
@@ -1,3 +1,3 @@
/incubator/cassandra/branches/cassandra-0.3/interface/gen-java/org/apache/cassandra/service/Cassandra.java:774578-796573
-/incubator/cassandra/branches/cassandra-0.4/interface/gen-java/org/apache/cassandra/service/Cassandra.java:810145-810334
+/incubator/cassandra/branches/cassandra-0.4/interface/gen-java/org/apache/cassandra/service/Cassandra.java:810145-810993
/incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/Cassandra.java:749219-768588
Modified: incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/Column.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/Column.java?rev=810997&r1=810996&r2=810997&view=diff
==============================================================================
--- incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/Column.java (original)
+++ incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/Column.java Thu Sep 3 15:33:46 2009
@@ -34,6 +34,7 @@
import java.util.HashSet;
import java.util.Collections;
import java.util.BitSet;
+import java.util.Arrays;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -48,10 +49,10 @@
private static final TField TIMESTAMP_FIELD_DESC = new TField("timestamp", TType.I64, (short)3);
public byte[] name;
- public static final int NAME = 1;
public byte[] value;
- public static final int VALUE = 2;
public long timestamp;
+ public static final int NAME = 1;
+ public static final int VALUE = 2;
public static final int TIMESTAMP = 3;
// isset id assignments
@@ -103,7 +104,11 @@
this.timestamp = other.timestamp;
}
- @Override
+ public Column deepCopy() {
+ return new Column(this);
+ }
+
+ @Deprecated
public Column clone() {
return new Column(this);
}
Propchange: incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/Column.java
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Sep 3 15:33:46 2009
@@ -1,3 +1,4 @@
/incubator/cassandra/branches/cassandra-0.3/interface/gen-java/org/apache/cassandra/service/column_t.java:774578-792198
-/incubator/cassandra/branches/cassandra-0.4/interface/gen-java/org/apache/cassandra/service/Column.java:810145-810334
+/incubator/cassandra/branches/cassandra-0.4/interface/gen-java/org/apache/cassandra/service/Column.java:810145-810993
+/incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/Column.java:749219-794428
/incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/column_t.java:749219-768588
Modified: incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/ColumnOrSuperColumn.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/ColumnOrSuperColumn.java?rev=810997&r1=810996&r2=810997&view=diff
==============================================================================
--- incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/ColumnOrSuperColumn.java (original)
+++ incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/ColumnOrSuperColumn.java Thu Sep 3 15:33:46 2009
@@ -34,6 +34,7 @@
import java.util.HashSet;
import java.util.Collections;
import java.util.BitSet;
+import java.util.Arrays;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -47,8 +48,8 @@
private static final TField SUPER_COLUMN_FIELD_DESC = new TField("super_column", TType.STRUCT, (short)2);
public Column column;
- public static final int COLUMN = 1;
public SuperColumn super_column;
+ public static final int COLUMN = 1;
public static final int SUPER_COLUMN = 2;
// isset id assignments
@@ -88,7 +89,11 @@
}
}
- @Override
+ public ColumnOrSuperColumn deepCopy() {
+ return new ColumnOrSuperColumn(this);
+ }
+
+ @Deprecated
public ColumnOrSuperColumn clone() {
return new ColumnOrSuperColumn(this);
}
Modified: incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/ColumnParent.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/ColumnParent.java?rev=810997&r1=810996&r2=810997&view=diff
==============================================================================
--- incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/ColumnParent.java (original)
+++ incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/ColumnParent.java Thu Sep 3 15:33:46 2009
@@ -34,6 +34,7 @@
import java.util.HashSet;
import java.util.Collections;
import java.util.BitSet;
+import java.util.Arrays;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -47,8 +48,8 @@
private static final TField SUPER_COLUMN_FIELD_DESC = new TField("super_column", TType.STRING, (short)4);
public String column_family;
- public static final int COLUMN_FAMILY = 3;
public byte[] super_column;
+ public static final int COLUMN_FAMILY = 3;
public static final int SUPER_COLUMN = 4;
// isset id assignments
@@ -89,7 +90,11 @@
}
}
- @Override
+ public ColumnParent deepCopy() {
+ return new ColumnParent(this);
+ }
+
+ @Deprecated
public ColumnParent clone() {
return new ColumnParent(this);
}
Modified: incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/ColumnPath.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/ColumnPath.java?rev=810997&r1=810996&r2=810997&view=diff
==============================================================================
--- incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/ColumnPath.java (original)
+++ incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/ColumnPath.java Thu Sep 3 15:33:46 2009
@@ -34,6 +34,7 @@
import java.util.HashSet;
import java.util.Collections;
import java.util.BitSet;
+import java.util.Arrays;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -48,10 +49,10 @@
private static final TField COLUMN_FIELD_DESC = new TField("column", TType.STRING, (short)5);
public String column_family;
- public static final int COLUMN_FAMILY = 3;
public byte[] super_column;
- public static final int SUPER_COLUMN = 4;
public byte[] column;
+ public static final int COLUMN_FAMILY = 3;
+ public static final int SUPER_COLUMN = 4;
public static final int COLUMN = 5;
// isset id assignments
@@ -100,7 +101,11 @@
}
}
- @Override
+ public ColumnPath deepCopy() {
+ return new ColumnPath(this);
+ }
+
+ @Deprecated
public ColumnPath clone() {
return new ColumnPath(this);
}
Modified: incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/InvalidRequestException.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/InvalidRequestException.java?rev=810997&r1=810996&r2=810997&view=diff
==============================================================================
--- incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/InvalidRequestException.java (original)
+++ incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/InvalidRequestException.java Thu Sep 3 15:33:46 2009
@@ -34,6 +34,7 @@
import java.util.HashSet;
import java.util.Collections;
import java.util.BitSet;
+import java.util.Arrays;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -78,7 +79,11 @@
}
}
- @Override
+ public InvalidRequestException deepCopy() {
+ return new InvalidRequestException(this);
+ }
+
+ @Deprecated
public InvalidRequestException clone() {
return new InvalidRequestException(this);
}
Propchange: incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/InvalidRequestException.java
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Sep 3 15:33:46 2009
@@ -1,3 +1,3 @@
/incubator/cassandra/branches/cassandra-0.3/interface/gen-java/org/apache/cassandra/service/InvalidRequestException.java:774578-796573
-/incubator/cassandra/branches/cassandra-0.4/interface/gen-java/org/apache/cassandra/service/InvalidRequestException.java:810145-810334
+/incubator/cassandra/branches/cassandra-0.4/interface/gen-java/org/apache/cassandra/service/InvalidRequestException.java:810145-810993
/incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/InvalidRequestException.java:749219-768588
Modified: incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/NotFoundException.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/NotFoundException.java?rev=810997&r1=810996&r2=810997&view=diff
==============================================================================
--- incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/NotFoundException.java (original)
+++ incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/NotFoundException.java Thu Sep 3 15:33:46 2009
@@ -34,6 +34,7 @@
import java.util.HashSet;
import java.util.Collections;
import java.util.BitSet;
+import java.util.Arrays;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -60,7 +61,11 @@
public NotFoundException(NotFoundException other) {
}
- @Override
+ public NotFoundException deepCopy() {
+ return new NotFoundException(this);
+ }
+
+ @Deprecated
public NotFoundException clone() {
return new NotFoundException(this);
}
Propchange: incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/NotFoundException.java
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Sep 3 15:33:46 2009
@@ -1,3 +1,3 @@
/incubator/cassandra/branches/cassandra-0.3/interface/gen-java/org/apache/cassandra/service/NotFoundException.java:774578-796573
-/incubator/cassandra/branches/cassandra-0.4/interface/gen-java/org/apache/cassandra/service/NotFoundException.java:810145-810334
+/incubator/cassandra/branches/cassandra-0.4/interface/gen-java/org/apache/cassandra/service/NotFoundException.java:810145-810993
/incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/NotFoundException.java:749219-768588
Modified: incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/SlicePredicate.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/SlicePredicate.java?rev=810997&r1=810996&r2=810997&view=diff
==============================================================================
--- incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/SlicePredicate.java (original)
+++ incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/SlicePredicate.java Thu Sep 3 15:33:46 2009
@@ -34,6 +34,7 @@
import java.util.HashSet;
import java.util.Collections;
import java.util.BitSet;
+import java.util.Arrays;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -47,8 +48,8 @@
private static final TField SLICE_RANGE_FIELD_DESC = new TField("slice_range", TType.STRUCT, (short)2);
public List<byte[]> column_names;
- public static final int COLUMN_NAMES = 1;
public SliceRange slice_range;
+ public static final int COLUMN_NAMES = 1;
public static final int SLICE_RANGE = 2;
// isset id assignments
@@ -95,7 +96,11 @@
}
}
- @Override
+ public SlicePredicate deepCopy() {
+ return new SlicePredicate(this);
+ }
+
+ @Deprecated
public SlicePredicate clone() {
return new SlicePredicate(this);
}
@@ -320,7 +325,8 @@
oprot.writeFieldBegin(COLUMN_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new TList(TType.STRING, this.column_names.size()));
- for (byte[] _iter7 : this.column_names) {
+ for (byte[] _iter7 : this.column_names)
+ {
oprot.writeBinary(_iter7);
}
oprot.writeListEnd();
Modified: incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/SliceRange.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/SliceRange.java?rev=810997&r1=810996&r2=810997&view=diff
==============================================================================
--- incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/SliceRange.java (original)
+++ incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/SliceRange.java Thu Sep 3 15:33:46 2009
@@ -34,6 +34,7 @@
import java.util.HashSet;
import java.util.Collections;
import java.util.BitSet;
+import java.util.Arrays;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -49,12 +50,12 @@
private static final TField COUNT_FIELD_DESC = new TField("count", TType.I32, (short)4);
public byte[] start;
- public static final int START = 1;
public byte[] finish;
- public static final int FINISH = 2;
public boolean reversed;
- public static final int REVERSED = 3;
public int count;
+ public static final int START = 1;
+ public static final int FINISH = 2;
+ public static final int REVERSED = 3;
public static final int COUNT = 4;
// isset id assignments
@@ -117,7 +118,11 @@
this.count = other.count;
}
- @Override
+ public SliceRange deepCopy() {
+ return new SliceRange(this);
+ }
+
+ @Deprecated
public SliceRange clone() {
return new SliceRange(this);
}
Modified: incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/SuperColumn.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/SuperColumn.java?rev=810997&r1=810996&r2=810997&view=diff
==============================================================================
--- incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/SuperColumn.java (original)
+++ incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/SuperColumn.java Thu Sep 3 15:33:46 2009
@@ -34,6 +34,7 @@
import java.util.HashSet;
import java.util.Collections;
import java.util.BitSet;
+import java.util.Arrays;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -47,8 +48,8 @@
private static final TField COLUMNS_FIELD_DESC = new TField("columns", TType.LIST, (short)2);
public byte[] name;
- public static final int NAME = 1;
public List<Column> columns;
+ public static final int NAME = 1;
public static final int COLUMNS = 2;
// isset id assignments
@@ -94,7 +95,11 @@
}
}
- @Override
+ public SuperColumn deepCopy() {
+ return new SuperColumn(this);
+ }
+
+ @Deprecated
public SuperColumn clone() {
return new SuperColumn(this);
}
@@ -323,7 +328,8 @@
oprot.writeFieldBegin(COLUMNS_FIELD_DESC);
{
oprot.writeListBegin(new TList(TType.STRUCT, this.columns.size()));
- for (Column _iter3 : this.columns) {
+ for (Column _iter3 : this.columns)
+ {
_iter3.write(oprot);
}
oprot.writeListEnd();
Propchange: incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/SuperColumn.java
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Sep 3 15:33:46 2009
@@ -1,3 +1,4 @@
/incubator/cassandra/branches/cassandra-0.3/interface/gen-java/org/apache/cassandra/service/superColumn_t.java:774578-792198
-/incubator/cassandra/branches/cassandra-0.4/interface/gen-java/org/apache/cassandra/service/SuperColumn.java:810145-810334
+/incubator/cassandra/branches/cassandra-0.4/interface/gen-java/org/apache/cassandra/service/SuperColumn.java:810145-810993
+/incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/SuperColumn.java:749219-794428
/incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/superColumn_t.java:749219-768588
Modified: incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/UnavailableException.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/UnavailableException.java?rev=810997&r1=810996&r2=810997&view=diff
==============================================================================
--- incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/UnavailableException.java (original)
+++ incubator/cassandra/trunk/interface/gen-java/org/apache/cassandra/service/UnavailableException.java Thu Sep 3 15:33:46 2009
@@ -34,6 +34,7 @@
import java.util.HashSet;
import java.util.Collections;
import java.util.BitSet;
+import java.util.Arrays;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -60,7 +61,11 @@
public UnavailableException(UnavailableException other) {
}
- @Override
+ public UnavailableException deepCopy() {
+ return new UnavailableException(this);
+ }
+
+ @Deprecated
public UnavailableException clone() {
return new UnavailableException(this);
}
Propchange: incubator/cassandra/trunk/src/java/org/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Sep 3 15:33:46 2009
@@ -1,3 +1,3 @@
/incubator/cassandra/branches/cassandra-0.3/src/java/org:774578-796573
-/incubator/cassandra/branches/cassandra-0.4/src/java/org:810145-810334
+/incubator/cassandra/branches/cassandra-0.4/src/java/org:810145-810993
/incubator/cassandra/trunk/src/java/org:749219-769885
Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java?rev=810997&r1=810996&r2=810997&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java (original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/db/ColumnFamilyStore.java Thu Sep 3 15:33:46 2009
@@ -340,8 +340,6 @@
String getNextFileName()
{
- // increment twice so that we do not generate consecutive numbers
- fileIndexGenerator_.incrementAndGet();
return String.format("%s-%s-Data.db", columnFamily_, fileIndexGenerator_.incrementAndGet());
}
@@ -365,31 +363,6 @@
columnFamily_, SSTable.TEMPFILE_MARKER, fileIndexGenerator_.incrementAndGet());
}
- /*
- * Return a temporary file name. Based on the list of files input
- * This fn sorts the list and generates a number between he 2 lowest filenames
- * ensuring uniqueness.
- * Since we do not generate consecutive numbers hence the lowest file number
- * can just be incremented to generate the next file.
- */
- String getTempFileName(List<String> files)
- {
- int lowestIndex;
- int index;
- Collections.sort(files, new FileNameComparator(FileNameComparator.Ascending));
-
- if (files.size() <= 1)
- {
- return null;
- }
- lowestIndex = getIndexFromFileName(files.get(0));
-
- index = lowestIndex + 1;
-
- return String.format("%s-%s-%s-Data.db",
- columnFamily_, SSTable.TEMPFILE_MARKER, index);
- }
-
void switchMemtable(Memtable oldMemtable, CommitLog.CommitLogContext ctx)
{
memtableLock_.writeLock().lock();
@@ -1072,7 +1045,7 @@
return 0;
}
- String mergedFileName = getTempFileName(files);
+ String mergedFileName = getTempSSTableFileName();
SSTableWriter writer = null;
SSTableReader ssTable = null;
String lastkey = null;
Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/db/CommitLog.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/db/CommitLog.java?rev=810997&r1=810996&r2=810997&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/db/CommitLog.java (original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/db/CommitLog.java Thu Sep 3 15:33:46 2009
@@ -214,7 +214,7 @@
}
}
}
- }).start();
+ }, "PERIODIC-COMMIT-LOG-SYNCER").start();
}
}
}
Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/db/CommitLogExecutorService.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/db/CommitLogExecutorService.java?rev=810997&r1=810996&r2=810997&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/db/CommitLogExecutorService.java (original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/db/CommitLogExecutorService.java Thu Sep 3 15:33:46 2009
@@ -65,7 +65,7 @@
}
}
};
- new Thread(runnable).start();
+ new Thread(runnable, "COMMIT-LOG-WRITER").start();
MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
try
Propchange: incubator/cassandra/trunk/test/unit/org/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu Sep 3 15:33:46 2009
@@ -1,3 +1,3 @@
/incubator/cassandra/branches/cassandra-0.3/test/unit/org:774578-796573
-/incubator/cassandra/branches/cassandra-0.4/test/unit/org:810145-810334
+/incubator/cassandra/branches/cassandra-0.4/test/unit/org:810145-810993
/incubator/cassandra/trunk/test/unit/org:749219-768583