Package org.apache.cassandra.locator
Class ReplicaPlan.ForRead<E extends Endpoints<E>>
- java.lang.Object
-
- org.apache.cassandra.locator.ReplicaPlan<E>
-
- org.apache.cassandra.locator.ReplicaPlan.ForRead<E>
-
- Direct Known Subclasses:
ReplicaPlan.ForRangeRead
,ReplicaPlan.ForTokenRead
- Enclosing class:
- ReplicaPlan<E extends Endpoints<E>>
public abstract static class ReplicaPlan.ForRead<E extends Endpoints<E>> extends ReplicaPlan<E>
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.cassandra.locator.ReplicaPlan
ReplicaPlan.ForPaxosWrite, ReplicaPlan.ForRangeRead, ReplicaPlan.ForRead<E extends Endpoints<E>>, ReplicaPlan.ForTokenRead, ReplicaPlan.ForTokenWrite, ReplicaPlan.ForWrite<E extends Endpoints<E>>, ReplicaPlan.Shared<E extends Endpoints<E>,P extends ReplicaPlan<E>>, ReplicaPlan.SharedForRangeRead, ReplicaPlan.SharedForTokenRead
-
-
Field Summary
-
Fields inherited from class org.apache.cassandra.locator.ReplicaPlan
consistencyLevel, keyspace, replicationStrategy
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
blockFor()
E
candidates()
Replica
firstUncontactedCandidate(java.util.function.Predicate<Replica> extraPredicate)
Replica
lookup(InetAddressAndPort endpoint)
java.lang.String
toString()
-
Methods inherited from class org.apache.cassandra.locator.ReplicaPlan
consistencyLevel, contacts, contacts, keyspace, replicationStrategy, shared, shared
-
-
-
-
Method Detail
-
blockFor
public int blockFor()
- Specified by:
blockFor
in classReplicaPlan<E extends Endpoints<E>>
-
candidates
public E candidates()
-
firstUncontactedCandidate
public Replica firstUncontactedCandidate(java.util.function.Predicate<Replica> extraPredicate)
-
lookup
public Replica lookup(InetAddressAndPort endpoint)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-