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

Packages that use EndpointsForToken

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

Uses of EndpointsForToken in org.apache.cassandra.locator

Subclasses of EndpointsForToken in org.apache.cassandra.locator

Modifier and Type	Class	Description
static class	EndpointsForToken.Builder

Methods in org.apache.cassandra.locator that return EndpointsForToken

Modifier and Type	Method	Description
EndpointsForToken	EndpointsForToken.Builder.build()
static EndpointsForToken	EndpointsForToken.copyOf(Token token, java.lang.Iterable<Replica> replicas)
static EndpointsForToken	EndpointsForToken.copyOf(Token token, java.util.Collection<Replica> replicas)
static EndpointsForToken	EndpointsForToken.empty(Token token)
EndpointsForToken	EndpointsForRange.forToken(Token token)
EndpointsForToken	AbstractReplicationStrategy.getNaturalReplicasForToken(RingPosition<?> searchPosition)	get the (possibly cached) endpoints that should store the given Token.
EndpointsForToken	TokenMetadata.getWriteEndpoints(Token token, java.lang.String keyspaceName, EndpointsForToken natural)	Deprecated. retained for benefit of old tests
EndpointsForToken	ReplicaPlan.ForWrite.live()	The live replicas present in liveAndDown, usually derived from FailureDetector.isReplicaAlive
EndpointsForToken	ReplicaPlan.ForWrite.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)
EndpointsForToken	ReplicaPlan.ForWrite.liveUncontacted()	Calculate which live endpoints we could have contacted, but chose not to
static EndpointsForToken	EndpointsForToken.natural(Keyspace keyspace, Token token)
static EndpointsForToken	EndpointsForToken.natural(AbstractReplicationStrategy replicationStrategy, Token token)
static EndpointsForToken	EndpointsForToken.natural(TableMetadata table, Token token)
static EndpointsForToken	EndpointsForToken.of(Token token, Replica replica)
static EndpointsForToken	EndpointsForToken.of(Token token, Replica... replicas)
static EndpointsForToken	EndpointsForToken.pending(java.lang.String keyspace, Token token)
static EndpointsForToken	EndpointsForToken.pending(Keyspace keyspace, Token token)
static EndpointsForToken	EndpointsForToken.pending(TableMetadata table, Token token)
EndpointsForToken	ReplicaPlan.ForWrite.pending()	Replicas that a region of the ring is moving to; not yet ready to serve reads, but should receive writes
EndpointsForToken	PendingRangeMaps.pendingEndpointsFor(Token token)
EndpointsForToken	TokenMetadata.pendingEndpointsForToken(Token token, java.lang.String keyspaceName)
EndpointsForToken	EndpointsForToken.Builder.snapshot()
EndpointsForToken	EndpointsForToken.snapshot()
protected EndpointsForToken	EndpointsForToken.snapshot(AbstractReplicaCollection.ReplicaList newList)

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

Modifier and Type	Method	Description
static ReplicaLayout.ForTokenWrite	ReplicaLayout.forTokenWrite(AbstractReplicationStrategy replicationStrategy, EndpointsForToken natural, EndpointsForToken pending)
static ReplicaPlan.ForWrite	ReplicaPlans.forWrite(Keyspace keyspace, ConsistencyLevel consistencyLevel, EndpointsForToken natural, EndpointsForToken pending, java.util.function.Predicate<Replica> isAlive, ReplicaPlans.Selector selector)
EndpointsForToken	TokenMetadata.getWriteEndpoints(Token token, java.lang.String keyspaceName, EndpointsForToken natural)	Deprecated. retained for benefit of old tests
ReplicaPlan.ForTokenRead	ReplicaPlan.ForTokenRead.withContacts(EndpointsForToken newContact)
ReplicaPlan.ForWrite	ReplicaPlan.ForWrite.withContacts(EndpointsForToken newContact)

Constructors in org.apache.cassandra.locator with parameters of type EndpointsForToken

Constructor	Description
ForTokenRead(AbstractReplicationStrategy replicationStrategy, EndpointsForToken natural)
ForTokenRead(Keyspace keyspace, AbstractReplicationStrategy replicationStrategy, ConsistencyLevel consistencyLevel, EndpointsForToken candidates, EndpointsForToken contacts)
ForTokenWrite(AbstractReplicationStrategy replicationStrategy, EndpointsForToken natural, EndpointsForToken pending)
ForTokenWrite(AbstractReplicationStrategy replicationStrategy, EndpointsForToken natural, EndpointsForToken pending, EndpointsForToken all)
ForWrite(Keyspace keyspace, AbstractReplicationStrategy replicationStrategy, ConsistencyLevel consistencyLevel, EndpointsForToken pending, EndpointsForToken liveAndDown, EndpointsForToken live, EndpointsForToken contact)

Uses of EndpointsForToken in org.apache.cassandra.service

Methods in org.apache.cassandra.service that return EndpointsForToken

Modifier and Type	Method	Description
EndpointsForToken	StorageService.getNaturalReplicasForToken(java.lang.String keyspaceName, java.lang.String cf, java.lang.String key)
EndpointsForToken	StorageService.getNaturalReplicasForToken(java.lang.String keyspaceName, java.nio.ByteBuffer key)

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

Fields in org.apache.cassandra.service.reads with type parameters of type EndpointsForToken

Modifier and Type	Field	Description
protected DigestResolver<EndpointsForToken,ReplicaPlan.ForTokenRead>	AbstractReadExecutor.digestResolver
protected ReadCallback<EndpointsForToken,ReplicaPlan.ForTokenRead>	AbstractReadExecutor.handler
protected ReadRepair<EndpointsForToken,ReplicaPlan.ForTokenRead>	AbstractReadExecutor.readRepair

Methods in org.apache.cassandra.service.reads that return types with arguments of type EndpointsForToken

Modifier and Type	Method	Description
ReadRepair<EndpointsForToken,ReplicaPlan.ForTokenRead>	AbstractReadExecutor.getReadRepair()