Merge branch 'cassandra-2.1' into trunk

Conflicts:
        interface/cassandra.thrift
        src/java/org/apache/cassandra/thrift/CassandraServer.java
        test/unit/org/apache/cassandra/thrift/MultiSliceTest.java


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/235bae7b
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/235bae7b
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/235bae7b

Branch: refs/heads/trunk
Commit: 235bae7b30154ad442510d448c8d826cdc287cb1
Parents: d151b40 e9e91d7
Author: Jake Luciani <j...@apache.org>
Authored: Wed May 28 13:55:32 2014 -0400
Committer: Jake Luciani <j...@apache.org>
Committed: Wed May 28 13:55:32 2014 -0400

----------------------------------------------------------------------
 CHANGES.txt                                     |   2 +
 .../org/apache/cassandra/thrift/CfDef.java      | 298 ++++++++++---------
 .../org/apache/cassandra/thrift/CqlRow.java     |   7 +-
 .../cql3/statements/CQL3CasConditions.java      |   1 +
 .../cql3/statements/SelectStatement.java        |   1 +
 .../cassandra/db/composites/AbstractCType.java  |   5 +
 .../apache/cassandra/db/filter/ColumnSlice.java |  97 ++++++
 .../cassandra/thrift/CassandraServer.java       |   5 +-
 .../cassandra/db/filter/ColumnSliceTest.java    | 137 ++++++++-
 .../apache/cassandra/thrift/MultiSliceTest.java |  20 +-
 10 files changed, 413 insertions(+), 160 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/235bae7b/CHANGES.txt
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/cassandra/blob/235bae7b/src/java/org/apache/cassandra/cql3/statements/CQL3CasConditions.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/cassandra/blob/235bae7b/src/java/org/apache/cassandra/thrift/CassandraServer.java
----------------------------------------------------------------------
diff --cc src/java/org/apache/cassandra/thrift/CassandraServer.java
index 4f54242,1a77ffa..868c701
--- a/src/java/org/apache/cassandra/thrift/CassandraServer.java
+++ b/src/java/org/apache/cassandra/thrift/CassandraServer.java
@@@ -2044,7 -2078,9 +2044,8 @@@ public class CassandraServer implement
                      throw new InvalidRequestException(String.format("Reversed 
column slice at index %d had start less than finish", i));
                  slices[i] = new ColumnSlice(start, finish);
              }
-             SliceQueryFilter filter = new SliceQueryFilter(slices, 
request.reversed, request.count);
 -
+             ColumnSlice[] deoverlapped = ColumnSlice.deoverlapSlices(slices, 
request.reversed ? metadata.comparator.reverseComparator() : 
metadata.comparator);
+             SliceQueryFilter filter = new SliceQueryFilter(deoverlapped, 
request.reversed, request.count);
              ThriftValidation.validateKey(metadata, request.key);
              commands.add(ReadCommand.create(keyspace, request.key, 
request.column_parent.getColumn_family(), System.currentTimeMillis(), filter));
              return getSlice(commands, 
request.column_parent.isSetSuper_column(), 
consistencyLevel).entrySet().iterator().next().getValue();

Reply via email to