src/java/org/apache/cassandra/service/RangeSliceResponseResolver.java
// (this is not currently an issue since we don't do read repair for range queries.)
(this is not currently an issue since we don't do read repair for range queries.)
( this is not currently an issue since we don ' t do read repair for range queries . )
public Iterable<Row> resolve() throws IOException
    {
        ArrayList<RowIterator> iters = new ArrayList<RowIterator>(responses.size());
        int n = 0;
        for (Message response : responses)
        {
            RangeSliceReply reply = RangeSliceReply.read(response.getMessageBody(), response.getVersion());
            n = Math.max(n, reply.rows.size());
            iters.add(new RowIterator(reply.rows.iterator(), response.getFrom()));
        }
        CloseableIterator<Row> iter = MergeIterator.get(iters, pairComparator, new Reducer());
        List<Row> resolvedRows = new ArrayList<Row>(n);
        while (iter.hasNext())
            resolvedRows.add(iter.next());
        return resolvedRows;
    }
public Iterable < Row > resolve ( ) throws IOException { ArrayList < RowIterator > iters = new ArrayList < RowIterator > ( responses . size ( ) ) ; int n = 0 ; for ( Message response : responses ) { RangeSliceReply reply = RangeSliceReply . read ( response . getMessageBody ( ) , response . getVersion ( ) ) ; n = Math . max ( n , reply . rows . size ( ) ) ; iters . add ( new RowIterator ( reply . rows . iterator ( ) , response . getFrom ( ) ) ) ; } CloseableIterator < Row > iter = MergeIterator . get ( iters , pairComparator , new Reducer ( ) ) ; List < Row > resolvedRows = new ArrayList < Row > ( n ) ; while ( iter . hasNext ( ) ) resolvedRows . add ( iter . next ( ) ) ; return resolvedRows ; }
(this is not currently an issue since we don't do read repair for range queries.)
( this is not currently an issue since we don ' t do read repair for range queries . )
// for each row, compute the combination of all different versions seen, and repair incomplete versions // TODO do we need to call close?