Package | Description |
---|---|
org.apache.cassandra.service.reads | |
org.apache.cassandra.service.reads.repair |
Modifier and Type | Field and Description |
---|---|
protected ReadRepair<EndpointsForToken,ReplicaPlan.ForTokenRead> |
AbstractReadExecutor.readRepair |
Modifier and Type | Method and Description |
---|---|
ReadRepair |
AbstractReadExecutor.getReadRepair() |
Constructor and Description |
---|
DataResolver(ReadCommand command,
ReplicaPlan.Shared<E,P> replicaPlan,
ReadRepair<E,P> readRepair,
long queryStartNanoTime) |
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.
|
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-2020 The Apache Software Foundation