org.apache.cassandra.service
Class RangeSliceResponseResolver

java.lang.Object
  org.apache.cassandra.service.RangeSliceResponseResolver

All Implemented Interfaces:

IResponseResolver<java.util.List<Row>>

public class RangeSliceResponseResolver
extends java.lang.Object
implements IResponseResolver<java.util.List<Row>>

Turns RangeSliceReply objects into row (string -> CF) maps, resolving to the most recent ColumnFamily and setting up read repairs as necessary.

Field Summary

protected java.util.Collection<Message>

responses

Constructor Summary

RangeSliceResponseResolver(java.lang.String table, java.util.List<java.net.InetAddress> sources)

Method Summary

int	getMessageCount()
java.lang.Iterable<Message>	getMessages()
boolean	isDataPresent()
void	preprocess(Message message)
java.util.List<Row>	resolve()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

responses

protected final java.util.Collection<Message> responses

Constructor Detail

RangeSliceResponseResolver

public RangeSliceResponseResolver(java.lang.String table,
                                  java.util.List<java.net.InetAddress> sources)

Method Detail

resolve

public java.util.List<Row> resolve()
                            throws DigestMismatchException,
                                   java.io.IOException

Specified by:

resolve in interface IResponseResolver<java.util.List<Row>>

Throws:

DigestMismatchException

java.io.IOException

preprocess

public void preprocess(Message message)

Specified by:

preprocess in interface IResponseResolver<java.util.List<Row>>

isDataPresent

public boolean isDataPresent()

Specified by:

isDataPresent in interface IResponseResolver<java.util.List<Row>>

getMessages

public java.lang.Iterable<Message> getMessages()

Specified by:

getMessages in interface IResponseResolver<java.util.List<Row>>

getMessageCount

public int getMessageCount()

Specified by:

getMessageCount in interface IResponseResolver<java.util.List<Row>>