Package org.apache.cassandra.service.reads

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

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,P>>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final ReadCommand	command
protected static final org.slf4j.Logger	logger
protected final Supplier<? extends P>	replicaPlan
protected final Dispatcher.RequestTime	requestTime
protected final Accumulator<Message<ReadResponse>>	responses

Constructor Summary

Constructors

Constructor	Description
ResponseResolver(ReadCommand command, Supplier<? extends P> replicaPlan, Dispatcher.RequestTime requestTime)

Method Summary

Modifier and Type	Method	Description
Accumulator<Message<ReadResponse>>	getMessages()
abstract boolean	isDataPresent()
void	preprocess(Message<ReadResponse> message)
protected P	replicaPlan()

Methods inherited from class java.lang.Object

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

Field Details

logger

protected static final org.slf4j.Logger logger

command

protected final ReadCommand command

replicaPlan

protected final Supplier<? extends P extends ReplicaPlan.ForRead<E,P>> replicaPlan

responses

protected final Accumulator<Message<ReadResponse>> responses

requestTime

protected final Dispatcher.RequestTime requestTime

Constructor Details

ResponseResolver

public ResponseResolver(ReadCommand command,
 Supplier<? extends P> replicaPlan,
 Dispatcher.RequestTime requestTime)

Method Details

replicaPlan

protected P replicaPlan()

isDataPresent

public abstract boolean isDataPresent()

preprocess

public void preprocess(Message<ReadResponse> message)

getMessages

public Accumulator<Message<ReadResponse>> getMessages()