From 09bc045e2674e91f57d3244b1aaeae0c1cd2c6f5 Mon Sep 17 00:00:00 2001 From: Jonathan Ellis Date: Fri, 27 Mar 2009 02:45:02 +0000 Subject: [PATCH] add check for OPP git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@759002 13f79535-47bb-0310-9956-ffa450edef68 --- src/org/apache/cassandra/service/CassandraServer.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/org/apache/cassandra/service/CassandraServer.java b/src/org/apache/cassandra/service/CassandraServer.java index c2d5f66258..5fe97ba2e4 100644 --- a/src/org/apache/cassandra/service/CassandraServer.java +++ b/src/org/apache/cassandra/service/CassandraServer.java @@ -57,6 +57,7 @@ import org.apache.cassandra.net.IAsyncResult; import org.apache.cassandra.utils.LogUtil; import org.apache.cassandra.io.DataInputBuffer; import org.apache.cassandra.io.DataOutputBuffer; +import org.apache.cassandra.dht.OrderPreservingPartitioner; /** * Author : Avinash Lakshman ( alakshman@facebook.com) & Prashant Malik ( pmalik@facebook.com ) @@ -819,6 +820,10 @@ public class CassandraServer extends FacebookBase implements public List get_range(String tablename, final String startkey) throws CassandraException { + if (!(StorageService.getPartitioner() instanceof OrderPreservingPartitioner)) { + throw new CassandraException("range queries may only be performed against an order-preserving partitioner"); + } + logger_.debug("get_range"); // send request