public class BlockingReadRepair<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>> extends AbstractReadRepair<E,P>
ReadRepair.Factory
Modifier and Type | Field and Description |
---|---|
protected java.util.Queue<BlockingPartitionRepair> |
repairs |
cfs, command, queryStartNanoTime, replicaPlan
Modifier and Type | Method and Description |
---|---|
void |
awaitWrites()
Block on any mutations (or timeout) we sent out to repair replicas in
ReadRepair.repairPartition(org.apache.cassandra.db.DecoratedKey, java.util.Map<org.apache.cassandra.locator.Replica, org.apache.cassandra.db.Mutation>, org.apache.cassandra.locator.ReplicaPlan.ForTokenWrite) |
UnfilteredPartitionIterators.MergeListener |
getMergeListener(P replicaPlan)
Used by DataResolver to generate corrections as the partition iterator is consumed
|
void |
maybeSendAdditionalWrites()
If it looks like we might not receive acks for all the repair mutations we sent out, combine all
the unacked mutations and send them to the minority of nodes not involved in the read repair data
read / write cycle.
|
void |
repairPartition(DecoratedKey partitionKey,
java.util.Map<Replica,Mutation> mutations,
ReplicaPlan.ForTokenWrite writePlan)
Repairs a partition _after_ receiving data responses.
|
awaitReads, maybeSendAdditionalReads, replicaPlan, startRepair
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
create
protected final java.util.Queue<BlockingPartitionRepair> repairs
public UnfilteredPartitionIterators.MergeListener getMergeListener(P replicaPlan)
ReadRepair
public void maybeSendAdditionalWrites()
ReadRepair
public void awaitWrites()
ReadRepair
ReadRepair.repairPartition(org.apache.cassandra.db.DecoratedKey, java.util.Map<org.apache.cassandra.locator.Replica, org.apache.cassandra.db.Mutation>, org.apache.cassandra.locator.ReplicaPlan.ForTokenWrite)
public void repairPartition(DecoratedKey partitionKey, java.util.Map<Replica,Mutation> mutations, ReplicaPlan.ForTokenWrite writePlan)
ReadRepair
Copyright © 2009-2020 The Apache Software Foundation