Package org.apache.cassandra.locator
Class ReplicaPlan.ForWrite<E extends Endpoints<E>>
- java.lang.Object
-
- org.apache.cassandra.locator.ReplicaPlan<E>
-
- org.apache.cassandra.locator.ReplicaPlan.ForWrite<E>
-
- Direct Known Subclasses:
ReplicaPlan.ForPaxosWrite
,ReplicaPlan.ForTokenWrite
- Enclosing class:
- ReplicaPlan<E extends Endpoints<E>>
public abstract static class ReplicaPlan.ForWrite<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()
boolean
isAlive(Replica replica)
Test liveness, consistent with the upfront analysis done for this operation (i.e.E
live()
The live replicas present in liveAndDown, usually derived from FailureDetector.isReplicaAliveE
liveAndDown()
Replicas that can participate in the write - this always includes all nodes (pending and natural) in all DCs, except for paxos LOCAL_QUORUM (which is local DC only)E
liveUncontacted()
Calculate which live endpoints we could have contacted, but chose not toReplica
lookup(InetAddressAndPort endpoint)
E
pending()
Replicas that a region of the ring is moving to; not yet ready to serve reads, but should receive writesjava.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>>
-
pending
public E pending()
Replicas that a region of the ring is moving to; not yet ready to serve reads, but should receive writes
-
liveAndDown
public E liveAndDown()
Replicas that can participate in the write - this always includes all nodes (pending and natural) in all DCs, except for paxos LOCAL_QUORUM (which is local DC only)
-
live
public E live()
The live replicas present in liveAndDown, usually derived from FailureDetector.isReplicaAlive
-
liveUncontacted
public E liveUncontacted()
Calculate which live endpoints we could have contacted, but chose not to
-
isAlive
public boolean isAlive(Replica replica)
Test liveness, consistent with the upfront analysis done for this operation (i.e. test membership of live())
-
lookup
public Replica lookup(InetAddressAndPort endpoint)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-