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.ForFullRangeRead, 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 class	ReplicaPlan.AbstractForRead<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>>
static class	ReplicaPlan.AbstractReplicaPlan<E extends Endpoints<E>,P extends ReplicaPlan<E,P>>
static class	ReplicaPlan.ForFullRangeRead
static class	ReplicaPlan.ForPaxosWrite
static class	ReplicaPlan.ForRangeRead
static interface	ReplicaPlan.ForRead<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>>
static class	ReplicaPlan.ForTokenRead
static class	ReplicaPlan.ForWrite
static interface	ReplicaPlan.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 class	ReplicaPlan.SharedForRangeRead
static class	ReplicaPlan.SharedForTokenRead

Method Summary

Modifier and Type	Method	Description
ConsistencyLevel	consistencyLevel()
E	contacts()
Keyspace	keyspace()
Replica	lookup(InetAddressAndPort endpoint)
AbstractReplicationStrategy	replicationStrategy()
static ReplicaPlan.SharedForRangeRead	shared(ReplicaPlan.ForRangeRead replicaPlan)
static ReplicaPlan.SharedForTokenRead	shared(ReplicaPlan.ForTokenRead replicaPlan)
P	withContacts(E contacts)

Method Details

keyspace

Keyspace keyspace()

replicationStrategy

AbstractReplicationStrategy replicationStrategy()

consistencyLevel

ConsistencyLevel consistencyLevel()

contacts

E contacts()

lookup

Replica lookup(InetAddressAndPort endpoint)

withContacts

P withContacts(E contacts)

shared

static ReplicaPlan.SharedForTokenRead shared(ReplicaPlan.ForTokenRead replicaPlan)

shared

static ReplicaPlan.SharedForRangeRead shared(ReplicaPlan.ForRangeRead replicaPlan)