Package org.apache.cassandra.locator
Interface ReplicaPlan<E extends Endpoints<E>,P extends ReplicaPlan<E,P>>
-
- All Known Subinterfaces:
ReplicaPlan.ForRead<E,P>
- All Known Implementing Classes:
ReplicaPlan.AbstractForRead,ReplicaPlan.AbstractReplicaPlan,ReplicaPlan.ForPaxosWrite,ReplicaPlan.ForRangeRead,ReplicaPlan.ForTokenRead,ReplicaPlan.ForWrite
public interface ReplicaPlan<E extends Endpoints<E>,P extends ReplicaPlan<E,P>>
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static classReplicaPlan.AbstractForRead<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>>static classReplicaPlan.AbstractReplicaPlan<E extends Endpoints<E>,P extends ReplicaPlan<E,P>>static classReplicaPlan.ForPaxosWritestatic classReplicaPlan.ForRangeReadstatic interfaceReplicaPlan.ForRead<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>>static classReplicaPlan.ForTokenReadstatic classReplicaPlan.ForWritestatic interfaceReplicaPlan.Shared<E extends Endpoints<E>,P extends ReplicaPlan<E,P>>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.static classReplicaPlan.SharedForRangeReadstatic classReplicaPlan.SharedForTokenRead
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description ConsistencyLevelconsistencyLevel()Econtacts()Keyspacekeyspace()Replicalookup(InetAddressAndPort endpoint)AbstractReplicationStrategyreplicationStrategy()static ReplicaPlan.SharedForRangeReadshared(ReplicaPlan.ForRangeRead replicaPlan)static ReplicaPlan.SharedForTokenReadshared(ReplicaPlan.ForTokenRead replicaPlan)PwithContacts(E contacts)
-
-
-
Method Detail
-
keyspace
Keyspace keyspace()
-
replicationStrategy
AbstractReplicationStrategy replicationStrategy()
-
consistencyLevel
ConsistencyLevel consistencyLevel()
-
contacts
E contacts()
-
lookup
Replica lookup(InetAddressAndPort endpoint)
-
shared
static ReplicaPlan.SharedForTokenRead shared(ReplicaPlan.ForTokenRead replicaPlan)
-
shared
static ReplicaPlan.SharedForRangeRead shared(ReplicaPlan.ForRangeRead replicaPlan)
-
-