Package org.apache.cassandra.service.reads

Interface SpeculativeRetryPolicy

All Known Implementing Classes:

AlwaysSpeculativeRetryPolicy, FixedSpeculativeRetryPolicy, HybridSpeculativeRetryPolicy, NeverSpeculativeRetryPolicy, PercentileSpeculativeRetryPolicy

public interface SpeculativeRetryPolicy

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	SpeculativeRetryPolicy.Kind

Method Summary

Modifier and Type	Method	Description
long	calculateThreshold(SnapshottingTimer latency, long existingValue)	Calculate the delay in microseconds after which speculation takes place
static SpeculativeRetryPolicy	fromString(String str)
SpeculativeRetryPolicy.Kind	kind()

Method Details

calculateThreshold

long calculateThreshold(SnapshottingTimer latency,
 long existingValue)

Calculate the delay in microseconds after which speculation takes place

Parameters:

latency - snapshot of coordinator latencies (in microseconds)

existingValue - existing speculation threshold (in microseconds)

Returns:

speculation delay (in microseconds).

kind

SpeculativeRetryPolicy.Kind kind()

fromString

static SpeculativeRetryPolicy fromString(String str)