Package | Description |
---|---|
org.apache.cassandra.locator | |
org.apache.cassandra.service.reads |
Modifier and Type | Method and Description |
---|---|
static ReplicaPlan.ForTokenRead |
ReplicaPlans.forRead(Keyspace keyspace,
Token token,
ConsistencyLevel consistencyLevel,
SpeculativeRetryPolicy retry)
Construct a plan for reading the provided token at the provided consistency level.
|
static ReplicaPlan.ForTokenRead |
ReplicaPlans.forSingleReplicaRead(Keyspace keyspace,
Token token,
Replica replica)
Construct a plan for reading from a single node - this permits no speculation or read-repair
|
ReplicaPlan.ForTokenRead |
ReplicaPlan.SharedForTokenRead.get() |
ReplicaPlan.ForTokenRead |
ReplicaPlan.SharedForTokenRead.getWithContacts(EndpointsForToken newContact) |
Modifier and Type | Method and Description |
---|---|
static ReplicaPlan.SharedForTokenRead |
ReplicaPlan.shared(ReplicaPlan.ForTokenRead replicaPlan) |
Modifier and Type | Field and Description |
---|---|
protected DigestResolver<EndpointsForToken,ReplicaPlan.ForTokenRead> |
AbstractReadExecutor.digestResolver |
protected ReadCallback<EndpointsForToken,ReplicaPlan.ForTokenRead> |
AbstractReadExecutor.handler |
protected ReadRepair<EndpointsForToken,ReplicaPlan.ForTokenRead> |
AbstractReadExecutor.readRepair |
Constructor and Description |
---|
NeverSpeculatingReadExecutor(ColumnFamilyStore cfs,
ReadCommand command,
ReplicaPlan.ForTokenRead replicaPlan,
long queryStartNanoTime,
boolean logFailedSpeculation) |
Copyright © 2009-2020 The Apache Software Foundation