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());
