Author: jbellis Date: Sat May 21 02:16:42 2011 New Revision: 1125613 URL: http://svn.apache.org/viewvc?rev=1125613&view=rev Log: minor comment clarification
Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/RangeSliceResponseResolver.java Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/RangeSliceResponseResolver.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/RangeSliceResponseResolver.java?rev=1125613&r1=1125612&r2=1125613&view=diff ============================================================================== --- cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/RangeSliceResponseResolver.java (original) +++ cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/RangeSliceResponseResolver.java Sat May 21 02:16:42 2011 @@ -62,7 +62,7 @@ public class RangeSliceResponseResolver return reply.rows; } - // Note: this deserializes the response a 2nd time if getData was called first + // Note: this would deserialize the response a 2nd time if getData was called first. // (this is not currently an issue since we don't do read repair for range queries.) public Iterable<Row> resolve() throws IOException { @@ -73,7 +73,7 @@ public class RangeSliceResponseResolver return o1.left.key.compareTo(o2.left.key); } }); - + int n = 0; for (Message response : responses) { @@ -83,7 +83,6 @@ public class RangeSliceResponseResolver } // for each row, compute the combination of all different versions seen, and repair incomplete versions - return new ReducingIterator<Pair<Row,InetAddress>, Row>(collator) { List<ColumnFamily> versions = new ArrayList<ColumnFamily>(sources.size());