fix merge from 1.1
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/66001665 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/66001665 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/66001665 Branch: refs/heads/cassandra-1.2 Commit: 660016658f033875f4a442b5f9fdd5875f610cb9 Parents: 3e77082 Author: Jonathan Ellis <jbel...@apache.org> Authored: Mon Nov 12 16:14:44 2012 -0600 Committer: Jonathan Ellis <jbel...@apache.org> Committed: Mon Nov 12 16:14:44 2012 -0600 ---------------------------------------------------------------------- .../org/apache/cassandra/service/StorageProxy.java | 18 ++++++++++----- 1 files changed, 12 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/66001665/src/java/org/apache/cassandra/service/StorageProxy.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/service/StorageProxy.java b/src/java/org/apache/cassandra/service/StorageProxy.java index 33266c7..b747075 100644 --- a/src/java/org/apache/cassandra/service/StorageProxy.java +++ b/src/java/org/apache/cassandra/service/StorageProxy.java @@ -41,7 +41,9 @@ import org.apache.cassandra.config.DatabaseDescriptor; import org.apache.cassandra.config.Schema; import org.apache.cassandra.db.*; import org.apache.cassandra.db.Table; +import org.apache.cassandra.db.filter.IDiskAtomFilter; import org.apache.cassandra.db.filter.QueryPath; +import org.apache.cassandra.db.filter.SliceQueryFilter; import org.apache.cassandra.db.marshal.UUIDType; import org.apache.cassandra.dht.AbstractBounds; import org.apache.cassandra.dht.Bounds; @@ -1091,8 +1093,11 @@ public class StorageProxy implements StorageProxyMBean // now scan until we have enough results try { - final SlicePredicate emptyPredicate = getEmptySlicePredicate(); - SlicePredicate commandPredicate = command.predicate; + final IDiskAtomFilter emptyPredicate = new SliceQueryFilter(ByteBufferUtil.EMPTY_BYTE_BUFFER, + ByteBufferUtil.EMPTY_BYTE_BUFFER, + false, + -1); + IDiskAtomFilter commandPredicate = command.predicate; int columnsCount = 0; rows = new ArrayList<Row>(); @@ -1174,11 +1179,12 @@ public class StorageProxy implements StorageProxyMBean return trim(command, rows); } - private static SlicePredicate getEmptySlicePredicate() + private static IDiskAtomFilter getEmptySlicePredicate() { - final SliceRange emptySliceRange = - new SliceRange(ByteBufferUtil.EMPTY_BYTE_BUFFER, ByteBufferUtil.EMPTY_BYTE_BUFFER, false, -1); - return new SlicePredicate().setSlice_range(emptySliceRange); + return new SliceQueryFilter(ByteBufferUtil.EMPTY_BYTE_BUFFER, + ByteBufferUtil.EMPTY_BYTE_BUFFER, + false, + -1); } private static List<Row> trim(RangeSliceCommand command, List<Row> rows)
