Package org.apache.cassandra.locator
Class ReplicaPlan<E extends Endpoints<E>>
- java.lang.Object
-
- org.apache.cassandra.locator.ReplicaPlan<E>
-
- Direct Known Subclasses:
ReplicaPlan.ForRead
,ReplicaPlan.ForWrite
public abstract class ReplicaPlan<E extends Endpoints<E>> extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ReplicaPlan.ForPaxosWrite
static class
ReplicaPlan.ForRangeRead
static class
ReplicaPlan.ForRead<E extends Endpoints<E>>
static class
ReplicaPlan.ForTokenRead
static class
ReplicaPlan.ForTokenWrite
static class
ReplicaPlan.ForWrite<E extends Endpoints<E>>
static interface
ReplicaPlan.Shared<E extends Endpoints<E>,P extends ReplicaPlan<E>>
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 class
ReplicaPlan.SharedForRangeRead
static class
ReplicaPlan.SharedForTokenRead
-
Field Summary
Fields Modifier and Type Field Description protected ConsistencyLevel
consistencyLevel
protected Keyspace
keyspace
protected AbstractReplicationStrategy
replicationStrategy
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description abstract int
blockFor()
ConsistencyLevel
consistencyLevel()
E
contacts()
boolean
contacts(Replica replica)
Keyspace
keyspace()
AbstractReplicationStrategy
replicationStrategy()
static ReplicaPlan.SharedForRangeRead
shared(ReplicaPlan.ForRangeRead replicaPlan)
static ReplicaPlan.SharedForTokenRead
shared(ReplicaPlan.ForTokenRead replicaPlan)
-
-
-
Field Detail
-
keyspace
protected final Keyspace keyspace
-
consistencyLevel
protected final ConsistencyLevel consistencyLevel
-
replicationStrategy
protected final AbstractReplicationStrategy replicationStrategy
-
-
Method Detail
-
blockFor
public abstract int blockFor()
-
contacts
public E contacts()
-
contacts
public boolean contacts(Replica replica)
-
keyspace
public Keyspace keyspace()
-
replicationStrategy
public AbstractReplicationStrategy replicationStrategy()
-
consistencyLevel
public ConsistencyLevel consistencyLevel()
-
shared
public static ReplicaPlan.SharedForTokenRead shared(ReplicaPlan.ForTokenRead replicaPlan)
-
shared
public static ReplicaPlan.SharedForRangeRead shared(ReplicaPlan.ForRangeRead replicaPlan)
-
-