You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jo...@apache.org on 2010/06/01 15:27:58 UTC
svn commit: r950070 - /cassandra/trunk/contrib/py_stress/stress.py
Author: johan
Date: Tue Jun 1 13:27:58 2010
New Revision: 950070
URL: http://svn.apache.org/viewvc?rev=950070&view=rev
Log:
Adapt stress.py to the thrift clock api changes. Patch by johan, review by jbellis. CASSANDRA-1148
Modified:
cassandra/trunk/contrib/py_stress/stress.py
Modified: cassandra/trunk/contrib/py_stress/stress.py
URL: http://svn.apache.org/viewvc/cassandra/trunk/contrib/py_stress/stress.py?rev=950070&r1=950069&r2=950070&view=diff
==============================================================================
--- cassandra/trunk/contrib/py_stress/stress.py (original)
+++ cassandra/trunk/contrib/py_stress/stress.py Tue Jun 1 13:27:58 2010
@@ -177,7 +177,7 @@ class Operation(Thread):
class Inserter(Operation):
def run(self):
data = md5(str(get_ident())).hexdigest()
- columns = [Column('C' + str(j), data, 0) for j in xrange(columns_per_key)]
+ columns = [Column('C' + str(j), data, Clock(0)) for j in xrange(columns_per_key)]
fmt = '%0' + str(len(str(total_keys))) + 'd'
if 'super' == options.cftype:
supers = [SuperColumn('S' + str(j), columns) for j in xrange(supers_per_key)]