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 java.lang.Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
ResponseResolver(ReadCommand command, java.util.function.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 Detail

logger

protected static final org.slf4j.Logger logger

command

protected final ReadCommand command

replicaPlan

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

responses

protected final Accumulator<Message<ReadResponse>> responses

requestTime

protected final Dispatcher.RequestTime requestTime

Constructor Detail

ResponseResolver

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

Method Detail

replicaPlan

protected P replicaPlan()

isDataPresent

public abstract boolean isDataPresent()

preprocess

public void preprocess(Message<ReadResponse> message)

getMessages

public Accumulator<Message<ReadResponse>> getMessages()