Class ResponseResolver<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
- java.lang.Object
-
- org.apache.cassandra.service.reads.ResponseResolver<E,P>
-
- Direct Known Subclasses:
DataResolver
,DigestResolver
public abstract class ResponseResolver<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>> extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description protected ReadCommand
command
protected static org.slf4j.Logger
logger
protected long
queryStartNanoTime
protected ReplicaPlan.Shared<E,P>
replicaPlan
protected Accumulator<Message<ReadResponse>>
responses
-
Constructor Summary
Constructors Constructor Description ResponseResolver(ReadCommand command, ReplicaPlan.Shared<E,P> replicaPlan, long queryStartNanoTime)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description Accumulator<Message<ReadResponse>>
getMessages()
abstract boolean
isDataPresent()
void
preprocess(Message<ReadResponse> message)
protected P
replicaPlan()
-
-
-
Field Detail
-
logger
protected static final org.slf4j.Logger logger
-
command
protected final ReadCommand command
-
replicaPlan
protected final ReplicaPlan.Shared<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>> replicaPlan
-
responses
protected final Accumulator<Message<ReadResponse>> responses
-
queryStartNanoTime
protected final long queryStartNanoTime
-
-
Constructor Detail
-
ResponseResolver
public ResponseResolver(ReadCommand command, ReplicaPlan.Shared<E,P> replicaPlan, long queryStartNanoTime)
-
-
Method Detail
-
replicaPlan
protected P replicaPlan()
-
isDataPresent
public abstract boolean isDataPresent()
-
preprocess
public void preprocess(Message<ReadResponse> message)
-
getMessages
public Accumulator<Message<ReadResponse>> getMessages()
-
-