Uses of Interface
org.apache.cassandra.locator.ReplicaCollection

Packages that use ReplicaCollection

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

Uses of ReplicaCollection in org.apache.cassandra.dht

Methods in org.apache.cassandra.dht with parameters of type ReplicaCollection

Modifier and Type	Method	Description
void	RangeStreamer.addRanges(String keyspaceName, ReplicaCollection<?> replicas)	Add ranges to be streamed for given keyspace.
static EndpointsByReplica	RangeStreamer.calculateRangesToFetchWithPreferredEndpoints(BiFunction<InetAddressAndPort,EndpointsForRange,EndpointsForRange> snitchGetSortedListByProximity, AbstractReplicationStrategy strat, ReplicaCollection<?> fetchRanges, boolean useStrictConsistency, TokenMetadata tmdBefore, TokenMetadata tmdAfter, String keyspace, Collection<RangeStreamer.SourceFilter> sourceFilters)	Get a map of all ranges and the source that will be cleaned up once this bootstrapped node is added for the given ranges.

Uses of ReplicaCollection in org.apache.cassandra.locator

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

Modifier and Type	Interface	Description
interface	ReplicaCollection<C extends ReplicaCollection<C>>	A collection like class for Replica objects.
static interface	ReplicaCollection.Builder<C extends ReplicaCollection<C>>	A mutable (append-only) extension of a ReplicaCollection.
class	ReplicaMultimap<K,C extends ReplicaCollection<?>>

Subinterfaces of ReplicaCollection in org.apache.cassandra.locator

Modifier and Type	Interface	Description
static interface	ReplicaCollection.Builder<C extends ReplicaCollection<C>>	A mutable (append-only) extension of a ReplicaCollection.

Classes in org.apache.cassandra.locator that implement ReplicaCollection

Modifier and Type	Class	Description
class	AbstractReplicaCollection<C extends AbstractReplicaCollection<C>>	A collection like class for Replica objects.
class	Endpoints<E extends Endpoints<E>>	A collection of Endpoints for a given ring position.
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
class	RangesAtEndpoint	A ReplicaCollection for Ranges occurring at an endpoint.
static class	RangesAtEndpoint.Builder

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

Modifier and Type	Method	Description
static <C extends ReplicaCollection<C>, B extends ReplicaCollection.Builder<C>> Collector<Replica,B,C>	AbstractReplicaCollection.collector(Set<Collector.Characteristics> characteristics, Supplier<B> supplier)
<C extends ReplicaCollection<? extends C>> C	AbstractEndpointSnitch.sortedByProximity(InetAddressAndPort address, C unsortedAddress)	Sorts the Collection of node addresses by proximity to the given address
<C extends ReplicaCollection<? extends C>> C	DynamicEndpointSnitch.sortedByProximity(InetAddressAndPort address, C unsortedAddresses)
<C extends ReplicaCollection<? extends C>> C	IEndpointSnitch.sortedByProximity(InetAddressAndPort address, C addresses)	returns a new List sorted by proximity to the given endpoint
<C extends ReplicaCollection<? extends C>> C	SimpleSnitch.sortedByProximity(InetAddressAndPort address, C unsortedAddress)

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

Modifier and Type	Method	Description
static int	Replicas.countFull(ReplicaCollection<?> replicas)
static Replicas.ReplicaCount	Replicas.countInOurDc(ReplicaCollection<?> replicas)
boolean	AbstractEndpointSnitch.isWorthMergingForRangeQuery(ReplicaCollection<?> merged, ReplicaCollection<?> l1, ReplicaCollection<?> l2)
boolean	DynamicEndpointSnitch.isWorthMergingForRangeQuery(ReplicaCollection<?> merged, ReplicaCollection<?> l1, ReplicaCollection<?> l2)
boolean	IEndpointSnitch.isWorthMergingForRangeQuery(ReplicaCollection<?> merged, ReplicaCollection<?> l1, ReplicaCollection<?> l2)	Returns whether for a range query doing a query against merged is likely to be faster than 2 sequential queries, one against l1 followed by one against l2.
static List<String>	Replicas.stringify(ReplicaCollection<?> replicas, boolean withPort)

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

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

Modifier and Type	Method	Description
protected void	AbstractReadExecutor.makeFullDataRequests(ReplicaCollection<?> replicas)