import org.apache.cassandra.db.RangeSliceReply; //导入依赖的package包/类
public Iterable<Row> resolve()
{
    ArrayList<RowIterator> iters = new ArrayList<RowIterator>(responses.size());
    int n = 0;
    for (MessageIn<RangeSliceReply> response : responses)
    {
        RangeSliceReply reply = response.payload;
        n = Math.max(n, reply.rows.size());
        iters.add(new RowIterator(reply.rows.iterator(), response.from));
    }
    // for each row, compute the combination of all different versions seen, and repair incomplete versions
    // TODO do we need to call close?
    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;
}
 

import org.apache.cassandra.db.RangeSliceReply; //导入依赖的package包/类
public void doVerb(MessageIn<AbstractRangeCommand> message, int id)
{
    try
    {
        if (StorageService.instance.isBootstrapMode())
        {
            /* Don't service reads! */
            throw new RuntimeException("Cannot service reads while bootstrapping!");
        }
        RangeSliceReply reply = new RangeSliceReply(message.payload.executeLocally());
        Tracing.trace("Enqueuing response to {}", message.from);
        MessagingService.instance().sendReply(reply.createMessage(), id, message.from);
    }
    catch (TombstoneOverwhelmingException e)
    {
        // error already logged.  Drop the request
    }
    catch (Exception ex)
    {
        throw new RuntimeException(ex);
    }
}
 

import org.apache.cassandra.db.RangeSliceReply; //导入依赖的package包/类
public void doVerb(MessageIn<RangeSliceCommand> message, String id)
{
    try
    {
        if (StorageService.instance.isBootstrapMode())
        {
            /* Don't service reads! */
            throw new RuntimeException("Cannot service reads while bootstrapping!");
        }
        RangeSliceReply reply = new RangeSliceReply(executeLocally(message.payload));
        Tracing.trace("Enqueuing response to {}", message.from);
        MessagingService.instance().sendReply(reply.createMessage(), id, message.from);
    }
    catch (Exception ex)
    {
        throw new RuntimeException(ex);
    }
}
 

import org.apache.cassandra.db.RangeSliceReply; //导入依赖的package包/类
public void doVerb(Message message, String id)
{
    try
    {
        if (StorageService.instance.isBootstrapMode())
        {
            /* Don't service reads! */
            throw new RuntimeException("Cannot service reads while bootstrapping!");
        }
        RangeSliceCommand command = RangeSliceCommand.read(message);
        ColumnFamilyStore cfs = Table.open(command.keyspace).getColumnFamilyStore(command.column_family);
        RangeSliceReply reply = new RangeSliceReply(cfs.getRangeSlice(command.super_column,
                                                                      command.range,
                                                                      command.max_keys,
                                                                      QueryFilter.getFilter(command.predicate, cfs.getComparator())));
        Message response = reply.getReply(message);
        if (logger.isDebugEnabled())
            logger.debug("Sending " + reply+ " to " + id + "@" + message.getFrom());
        MessagingService.instance().sendReply(response, id, message.getFrom());
    }
    catch (Exception ex)
    {
        throw new RuntimeException(ex);
    }
}
 

import org.apache.cassandra.db.RangeSliceReply; //导入依赖的package包/类
public List<Row> getData()
{
    MessageIn<RangeSliceReply> response = responses.iterator().next();
    return response.payload.rows;
}
 

import org.apache.cassandra.db.RangeSliceReply; //导入依赖的package包/类
public Iterable<MessageIn<RangeSliceReply>> getMessages()
{
    return responses;
}
 

import org.apache.cassandra.db.RangeSliceReply; //导入依赖的package包/类
public List<Row> getData() throws IOException
{
    Message response = responses.iterator().next();
    RangeSliceReply reply = RangeSliceReply.read(response.getMessageBody(), response.getVersion());
    return reply.rows;
}