Package org.apache.cassandra.service.reads

Class AbstractReadExecutor.NeverSpeculatingReadExecutor

java.lang.Object

org.apache.cassandra.service.reads.AbstractReadExecutor

org.apache.cassandra.service.reads.AbstractReadExecutor.NeverSpeculatingReadExecutor

Enclosing class:

AbstractReadExecutor

public static class AbstractReadExecutor.NeverSpeculatingReadExecutor
extends AbstractReadExecutor

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.cassandra.service.reads.AbstractReadExecutor

AbstractReadExecutor.NeverSpeculatingReadExecutor

Field Summary

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

cfs, command, digestResolver, handler, readRepair, requestTime, result, traceState

Constructor Summary

Constructors

Constructor	Description
NeverSpeculatingReadExecutor(ColumnFamilyStore cfs, ReadCommand command, ReplicaPlan.ForTokenRead replicaPlan, Dispatcher.RequestTime requestTime, boolean logFailedSpeculation)

Method Summary

Modifier and Type	Method	Description
void	maybeTryAdditionalReplicas()	Perform additional requests if it looks like the original will time out.

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

awaitReadRepair, awaitResponses, awaitResponses, executeAsync, getKey, getReadExecutor, getReadRepair, getResult, hasLocalRead, makeDigestRequests, makeFullDataRequests, makeTransientDataRequests, maybeSendAdditionalDataRequests, setResult

Methods inherited from class java.lang.Object

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

Constructor Details

NeverSpeculatingReadExecutor

public NeverSpeculatingReadExecutor(ColumnFamilyStore cfs,
 ReadCommand command,
 ReplicaPlan.ForTokenRead replicaPlan,
 Dispatcher.RequestTime requestTime,
 boolean logFailedSpeculation)

Method Details

maybeTryAdditionalReplicas

public void maybeTryAdditionalReplicas()

Description copied from class: AbstractReadExecutor

Perform additional requests if it looks like the original will time out. May block while it waits to see if the original requests are answered first.

Specified by:

maybeTryAdditionalReplicas in class AbstractReadExecutor