Author: brandonwilliams
Date: Thu Sep  2 16:22:34 2010
New Revision: 992006

URL: http://svn.apache.org/viewvc?rev=992006&view=rev
Log:
Update avro_stress get_range_slices params.  patch by brandonwilliams

Modified:
    cassandra/trunk/contrib/py_stress/avro_stress.py

Modified: cassandra/trunk/contrib/py_stress/avro_stress.py
URL: 
http://svn.apache.org/viewvc/cassandra/trunk/contrib/py_stress/avro_stress.py?rev=992006&r1=992005&r2=992006&view=diff
==============================================================================
--- cassandra/trunk/contrib/py_stress/avro_stress.py (original)
+++ cassandra/trunk/contrib/py_stress/avro_stress.py Thu Sep  2 16:22:34 2010
@@ -251,13 +251,13 @@ class RangeSlicer(Operation):
         p = {'slice_range': {'start': '', 'finish': '', 'reversed': False, 
'count': columns_per_key}}
         if 'super' == options.cftype:
             while current < end:
-                keyrange = {'start': fmt % current, 'finish': fmt % last, 
'count': options.rangecount}
+                keyrange = {'start_key': fmt % current, 'end_key': fmt % last, 
'count': options.rangecount}
                 res = []
                 for j in xrange(supers_per_key):
                     parent = {'column_family': 'Super1', 'super_column': 'S' + 
str(j)} 
                     begin = time.time()
                     try:
-                        res = self.cclient.request('get_range_slices', 
{'column_parent': parent, 'slice_predicate': p, 'range': keyrange, 
'consistency_level': consistency})
+                        res = self.cclient.request('get_range_slices', 
{'column_parent': parent, 'predicate': p, 'range': keyrange, 
'consistency_level': consistency})
                         if not res: raise RuntimeError("Key %s not found" % 
key)
                     except KeyboardInterrupt:
                         raise
@@ -276,10 +276,10 @@ class RangeSlicer(Operation):
             while current < end:
                 start = fmt % current 
                 finish = fmt % last
-                keyrange = {'start': start, 'finish': finish, 'count': 
options.rangecount}
+                keyrange = {'start_key': start, 'end_key': finish, 'count': 
options.rangecount}
                 begin = time.time()
                 try:
-                    r = self.cclient.request('get_range_slices', 
{'column_parent': parent, 'slice_predicate': p, 'range': keyrange, 
'consistency_level': consistency})
+                    r = self.cclient.request('get_range_slices', 
{'column_parent': parent, 'predicate': p, 'range': keyrange, 
'consistency_level': consistency})
                     if not r: raise RuntimeError("Range not found:", start, 
finish)
                 except KeyboardInterrupt:
                     raise


Reply via email to