Class DigestResolver<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
- 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>> 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, queryStartNanoTime, replicaPlan, responses
-
-
Constructor Summary
Constructors Constructor Description DigestResolver(ReadCommand command, ReplicaPlan.Shared<E,P> replicaPlan, long queryStartNanoTime)
-
Method Summary
All Methods Instance Methods Concrete Methods 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
-
-
-
-
Constructor Detail
-
DigestResolver
public DigestResolver(ReadCommand command, ReplicaPlan.Shared<E,P> replicaPlan, long queryStartNanoTime)
-
-
Method Detail
-
preprocess
public void preprocess(Message<ReadResponse> message)
- Overrides:
preprocess
in classResponseResolver<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
-
hasTransientResponse
public boolean hasTransientResponse()
-
getData
public PartitionIterator getData()
-
responsesMatch
public boolean responsesMatch()
-
isDataPresent
public boolean isDataPresent()
- Specified by:
isDataPresent
in classResponseResolver<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
-
getDigestsByEndpoint
public DigestResolver.DigestResolverDebugResult[] getDigestsByEndpoint()
-
-