Package org.apache.cassandra.service.reads

Class DigestResolver<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>>

java.lang.Object

org.apache.cassandra.service.reads.ResponseResolver<E,P>

org.apache.cassandra.service.reads.DigestResolver<E,P>

public class DigestResolver<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>>
extends ResponseResolver<E,P>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DigestResolver.DigestResolverDebugResult

Field Summary

Fields inherited from class org.apache.cassandra.service.reads.ResponseResolver

command, logger, replicaPlan, requestTime, responses

Constructor Summary

Constructors

Constructor	Description
DigestResolver(ReadCommand command, ReplicaPlan.Shared<E,P> replicaPlan, Dispatcher.RequestTime requestTime)

Method Summary

Modifier and Type	Method	Description
PartitionIterator	getData()
DigestResolver.DigestResolverDebugResult[]	getDigestsByEndpoint()
boolean	hasTransientResponse()
boolean	isDataPresent()
void	preprocess(Message<ReadResponse> message)
boolean	responsesMatch()

Methods inherited from class org.apache.cassandra.service.reads.ResponseResolver

getMessages, replicaPlan

Methods inherited from class java.lang.Object

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

Constructor Detail

DigestResolver

public DigestResolver(ReadCommand command,
                      ReplicaPlan.Shared<E,P> replicaPlan,
                      Dispatcher.RequestTime requestTime)

Method Detail

preprocess

public void preprocess(Message<ReadResponse> message)

Overrides:

preprocess in class ResponseResolver<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>>

hasTransientResponse

public boolean hasTransientResponse()

getData

public PartitionIterator getData()

responsesMatch

public boolean responsesMatch()

isDataPresent

public boolean isDataPresent()

Specified by:

isDataPresent in class ResponseResolver<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>>

getDigestsByEndpoint

public DigestResolver.DigestResolverDebugResult[] getDigestsByEndpoint()