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(java.lang.String keyspaceName, ReplicaCollection<?> replicas)
Add ranges to be streamed for given keyspace.static EndpointsByReplica
RangeStreamer. calculateRangesToFetchWithPreferredEndpoints(java.util.function.BiFunction<InetAddressAndPort,EndpointsForRange,EndpointsForRange> snitchGetSortedListByProximity, AbstractReplicationStrategy strat, ReplicaCollection<?> fetchRanges, boolean useStrictConsistency, TokenMetadata tmdBefore, TokenMetadata tmdAfter, java.lang.String keyspace, java.util.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>>
java.util.stream.Collector<Replica,B,C>AbstractReplicaCollection. collector(java.util.Set<java.util.stream.Collector.Characteristics> characteristics, java.util.function.Supplier<B> supplier)
<C extends ReplicaCollection<? extends C>>
CAbstractEndpointSnitch. sortedByProximity(InetAddressAndPort address, C unsortedAddress)
Sorts the Collection of node addresses by proximity to the given address<C extends ReplicaCollection<? extends C>>
CDynamicEndpointSnitch. sortedByProximity(InetAddressAndPort address, C unsortedAddresses)
<C extends ReplicaCollection<? extends C>>
CIEndpointSnitch. sortedByProximity(InetAddressAndPort address, C addresses)
returns a new List sorted by proximity to the given endpoint<C extends ReplicaCollection<? extends C>>
CSimpleSnitch. 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 java.util.List<java.lang.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)
-