Package | Description |
---|---|
org.apache.cassandra.db | |
org.apache.cassandra.locator | |
org.apache.cassandra.service.reads | |
org.apache.cassandra.service.reads.repair |
Modifier and Type | Method and Description |
---|---|
int |
ConsistencyLevel.blockForWrite(Keyspace keyspace,
Endpoints<?> pending) |
static com.carrotsearch.hppc.ObjectIntHashMap<java.lang.String> |
ConsistencyLevel.eachQuorumForWrite(Keyspace keyspace,
Endpoints<?> pendingWithDown) |
Modifier and Type | Class and Description |
---|---|
class |
Endpoints<E extends Endpoints<E>>
A collection of Endpoints for a given ring position.
|
class |
ReplicaLayout<E extends Endpoints<E>>
The relevant replicas for an operation over a given range or token.
|
static class |
ReplicaLayout.ForWrite<E extends Endpoints<E>> |
class |
ReplicaPlan<E extends Endpoints<E>> |
static class |
ReplicaPlan.ForRead<E extends Endpoints<E>> |
static class |
ReplicaPlan.ForWrite<E extends Endpoints<E>> |
static interface |
ReplicaPlan.Shared<E extends Endpoints<E>,P extends ReplicaPlan<E>>
Used by AbstractReadExecutor, {Data,Digest}Resolver and ReadRepair to share a ReplicaPlan whose 'contacts' replicas
we progressively modify via various forms of speculation (initial speculation, rr-read and rr-write)
The internal reference is not volatile, despite being shared between threads.
|
Modifier and Type | Class and Description |
---|---|
class |
EndpointsForRange
A ReplicaCollection where all Replica are required to cover a range that fully contains the range() defined in the builder().
|
static class |
EndpointsForRange.Builder |
class |
EndpointsForToken
A ReplicaCollection where all Replica are required to cover a range that fully contains the token() defined in the builder().
|
static class |
EndpointsForToken.Builder |
Modifier and Type | Method and Description |
---|---|
static <E extends Endpoints<E>> |
Endpoints.append(E replicas,
Replica extraReplica) |
static <E extends Endpoints<E>> |
Endpoints.concat(E natural,
E pending)
Care must be taken to ensure no conflicting ranges occur in pending and natural.
|
<E extends Endpoints<E>,L extends ReplicaLayout.ForWrite<E>> |
ReplicaPlans.Selector.select(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
L liveAndDown,
L live) |
Modifier and Type | Method and Description |
---|---|
static boolean |
ReplicaPlans.isSufficientLiveReplicasForRead(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
Endpoints<?> liveReplicas) |
Modifier and Type | Class and Description |
---|---|
class |
DataResolver<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>> |
class |
DigestResolver<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>> |
class |
ReadCallback<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>> |
class |
ResponseResolver<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>> |
Modifier and Type | Class and Description |
---|---|
class |
AbstractReadRepair<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>> |
class |
BlockingReadRepair<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
'Classic' read repair.
|
class |
NoopReadRepair<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
Bypasses the read repair path for short read protection and testing
|
class |
PartitionIteratorMergeListener<E extends Endpoints<E>> |
class |
ReadOnlyReadRepair<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
Only performs the collection of data responses and reconciliation of them, doesn't send repair mutations
to replicas.
|
interface |
ReadRepair<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>> |
class |
RowIteratorMergeListener<E extends Endpoints<E>> |
Modifier and Type | Method and Description |
---|---|
static <E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>> |
ReadRepair.create(ReadCommand command,
ReplicaPlan.Shared<E,P> replicaPlan,
long queryStartNanoTime) |
<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>> |
ReadRepair.Factory.create(ReadCommand command,
ReplicaPlan.Shared<E,P> replicaPlan,
long queryStartNanoTime) |
Copyright © 2009-2020 The Apache Software Foundation