Uses of Class
org.apache.cassandra.locator.Endpoints

Packages that use Endpoints

Package	Description
org.apache.cassandra.db
org.apache.cassandra.locator
org.apache.cassandra.service.reads
org.apache.cassandra.service.reads.repair

Uses of Endpoints in org.apache.cassandra.db

Methods in org.apache.cassandra.db with parameters of type Endpoints

Modifier and Type	Method	Description
int	ConsistencyLevel.blockForWrite(AbstractReplicationStrategy replicationStrategy, Endpoints<?> pending)
static com.carrotsearch.hppc.ObjectIntHashMap<java.lang.String>	ConsistencyLevel.eachQuorumForWrite(AbstractReplicationStrategy replicationStrategy, Endpoints<?> pendingWithDown)

Uses of Endpoints in org.apache.cassandra.locator

Classes in org.apache.cassandra.locator with type parameters of type Endpoints

Modifier and Type	Class	Description
class	Endpoints<E extends Endpoints<E>>	A collection of Endpoints for a given ring position.
class	ReplicaLayout<E extends Endpoints<E>>	The relevant replicas for an operation over a given range or token.
static class	ReplicaLayout.ForWrite<E extends Endpoints<E>>
interface	ReplicaPlan<E extends Endpoints<E>,P extends ReplicaPlan<E,P>>
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 interface	ReplicaPlan.ForRead<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>>
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.

Subclasses of Endpoints in org.apache.cassandra.locator

Modifier and Type	Class	Description
class	EndpointsForRange	A ReplicaCollection where all Replica are required to cover a range that fully contains the range() defined in the builder().
static class	EndpointsForRange.Builder
class	EndpointsForToken	A ReplicaCollection where all Replica are required to cover a range that fully contains the token() defined in the builder().
static class	EndpointsForToken.Builder

Methods in org.apache.cassandra.locator with type parameters of type Endpoints

Modifier and Type	Method	Description
static <E extends Endpoints<E>> E	Endpoints.append(E replicas, Replica extraReplica)
static <E extends Endpoints<E>> E	Endpoints.concat(E natural, E pending)	Care must be taken to ensure no conflicting ranges occur in pending and natural.
<E extends Endpoints<E>,L extends ReplicaLayout.ForWrite<E>> E	ReplicaPlans.Selector.select(ConsistencyLevel consistencyLevel, L liveAndDown, L live)	Select the Endpoints from {@param liveAndDown} and {@param live} to contact according to the consistency level.

Methods in org.apache.cassandra.locator with parameters of type Endpoints

Modifier and Type	Method	Description
static boolean	ReplicaPlans.isSufficientLiveReplicasForRead(AbstractReplicationStrategy replicationStrategy, ConsistencyLevel consistencyLevel, Endpoints<?> liveReplicas)

Uses of Endpoints in org.apache.cassandra.service.reads

Classes in org.apache.cassandra.service.reads with type parameters of type Endpoints

Modifier and Type	Class	Description
class	DataResolver<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>>
class	DigestResolver<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>>
class	ReadCallback<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>>
class	ReplicaFilteringProtection<E extends Endpoints<E>>	Helper in charge of collecting additional queries to be done on the coordinator to protect against invalid results being included due to replica-side filtering (secondary indexes or ALLOW * FILTERING).
class	ResponseResolver<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>>

Uses of Endpoints in org.apache.cassandra.service.reads.repair

Classes in org.apache.cassandra.service.reads.repair with type parameters of type Endpoints

Modifier and Type	Class	Description
class	AbstractReadRepair<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>>
class	BlockingReadRepair<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>>	'Classic' read repair.
class	NoopReadRepair<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>>	Bypasses the read repair path for short read protection and testing
class	PartitionIteratorMergeListener<E extends Endpoints<E>>
class	ReadOnlyReadRepair<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>>	Only performs the collection of data responses and reconciliation of them, doesn't send repair mutations to replicas.
interface	ReadRepair<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>>
class	RowIteratorMergeListener<E extends Endpoints<E>>

Methods in org.apache.cassandra.service.reads.repair with type parameters of type Endpoints

Modifier and Type	Method	Description
static <E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>> ReadRepair<E,P>	ReadRepair.create(ReadCommand command, ReplicaPlan.Shared<E,P> replicaPlan, Dispatcher.RequestTime requestTime)
<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E,P>> ReadRepair<E,P>	ReadRepair.Factory.create(ReadCommand command, ReplicaPlan.Shared<E,P> replicaPlan, Dispatcher.RequestTime requestTime)