Package | Description |
---|---|
org.apache.cassandra.service.reads | |
org.apache.cassandra.service.reads.repair |
Modifier and Type | Field and Description |
---|---|
protected DigestResolver<EndpointsForToken,ReplicaPlan.ForTokenRead> |
AbstractReadExecutor.digestResolver |
Modifier and Type | Method and Description |
---|---|
void |
AbstractReadRepair.startRepair(DigestResolver<E,P> digestResolver,
java.util.function.Consumer<PartitionIterator> resultConsumer) |
void |
NoopReadRepair.startRepair(DigestResolver<E,P> digestResolver,
java.util.function.Consumer<PartitionIterator> resultConsumer) |
void |
ReadRepair.startRepair(DigestResolver<E,P> digestResolver,
java.util.function.Consumer<PartitionIterator> resultConsumer)
Called when the digests from the initial read don't match.
|
Copyright © 2009-2020 The Apache Software Foundation