Package | Description |
---|---|
org.apache.cassandra.locator | |
org.apache.cassandra.service.reads | |
org.apache.cassandra.service.reads.repair |
Modifier and Type | Class and Description |
---|---|
static class |
ReplicaPlan.ForRangeRead |
static class |
ReplicaPlan.ForTokenRead |
Modifier and Type | Method and Description |
---|---|
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forReadRepair(Token token,
ReplicaPlan.ForRead<?> readPlan) |
static ReplicaPlans.Selector |
ReplicaPlans.writeReadRepair(ReplicaPlan.ForRead<?> readPlan)
TODO: Transient Replication C-14404/C-14665
TODO: We employ this even when there is no monotonicity to guarantee,
e.g.
|
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 |
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>> |
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) |
Constructor and Description |
---|
PartitionIteratorMergeListener(ReplicaPlan.ForRead<E> replicaPlan,
ReadCommand command,
ReadRepair readRepair) |
RowIteratorMergeListener(DecoratedKey partitionKey,
RegularAndStaticColumns columns,
boolean isReversed,
ReplicaPlan.ForRead<E> readPlan,
ReadCommand command,
ReadRepair readRepair) |
Copyright © 2009-2022 The Apache Software Foundation