Uses of Class
org.apache.cassandra.locator.EndpointsForRange
-
Packages that use EndpointsForRange Package Description org.apache.cassandra.dht org.apache.cassandra.locator org.apache.cassandra.service -
-
Uses of EndpointsForRange in org.apache.cassandra.dht
Method parameters in org.apache.cassandra.dht with type arguments of type EndpointsForRange Modifier and Type Method Description 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.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 EndpointsForRange in org.apache.cassandra.locator
Subclasses of EndpointsForRange in org.apache.cassandra.locator Modifier and Type Class Description static class
EndpointsForRange.Builder
Methods in org.apache.cassandra.locator that return EndpointsForRange Modifier and Type Method Description EndpointsForRange
EndpointsForRange.Builder. build()
abstract EndpointsForRange
AbstractReplicationStrategy. calculateNaturalReplicas(Token searchToken, TokenMetadata tokenMetadata)
Calculate the natural endpoints for the given token.EndpointsForRange
LocalStrategy. calculateNaturalReplicas(Token token, TokenMetadata metadata)
EndpointsForRange
NetworkTopologyStrategy. calculateNaturalReplicas(Token searchToken, TokenMetadata tokenMetadata)
calculate endpoints in one pass through the tokens by tracking our progress in each DC.EndpointsForRange
SimpleStrategy. calculateNaturalReplicas(Token token, TokenMetadata metadata)
static EndpointsForRange
EndpointsForRange. copyOf(java.util.Collection<Replica> replicas)
static EndpointsForRange
EndpointsForRange. empty(Range<Token> range)
EndpointsForRange
EndpointsByRange. get(Range<Token> range)
EndpointsForRange
EndpointsByReplica. get(Replica range)
EndpointsForRange
AbstractReplicationStrategy. getCachedReplicas(long ringVersion, Token t)
EndpointsForRange
AbstractReplicationStrategy. getNaturalReplicas(RingPosition<?> searchPosition)
EndpointsForRange
LocalStrategy. getNaturalReplicas(RingPosition<?> searchPosition)
We need to override this even if we override calculateNaturalReplicas, because the default implementation depends on token calculations but LocalStrategy may be used before tokens are set up.static EndpointsForRange
SystemReplicas. getSystemReplicas(java.util.Collection<InetAddressAndPort> endpoints)
static EndpointsForRange
EndpointsForRange. of(Replica replica)
static EndpointsForRange
EndpointsForRange. of(Replica... replicas)
EndpointsForRange
EndpointsForRange.Builder. snapshot()
EndpointsForRange
EndpointsForRange. snapshot()
Methods in org.apache.cassandra.locator with parameters of type EndpointsForRange Modifier and Type Method Description ReplicaPlan.ForRangeRead
ReplicaPlan.SharedForRangeRead. getWithContacts(EndpointsForRange newContact)
void
EndpointsByRange.Builder. putAll(Range<Token> range, EndpointsForRange replicas, ReplicaCollection.Builder.Conflict ignoreConflicts)
void
EndpointsByReplica.Builder. putAll(Replica range, EndpointsForRange replicas, ReplicaCollection.Builder.Conflict ignoreConflicts)
Constructors in org.apache.cassandra.locator with parameters of type EndpointsForRange Constructor Description ForRangeRead(AbstractReplicationStrategy replicationStrategy, AbstractBounds<PartitionPosition> range, EndpointsForRange natural)
ForRangeRead(Keyspace keyspace, AbstractReplicationStrategy replicationStrategy, ConsistencyLevel consistencyLevel, AbstractBounds<PartitionPosition> range, EndpointsForRange candidates, EndpointsForRange contact, int vnodeCount)
Constructor parameters in org.apache.cassandra.locator with type arguments of type EndpointsForRange Constructor Description EndpointsByRange(java.util.Map<Range<Token>,EndpointsForRange> map)
EndpointsByReplica(java.util.Map<Replica,EndpointsForRange> map)
-
Uses of EndpointsForRange in org.apache.cassandra.service
Methods in org.apache.cassandra.service that return EndpointsForRange Modifier and Type Method Description static EndpointsForRange
ActiveRepairService. getNeighbors(java.lang.String keyspaceName, java.lang.Iterable<Range<Token>> keyspaceLocalRanges, Range<Token> toRepair, java.util.Collection<java.lang.String> dataCenters, java.util.Collection<java.lang.String> hosts)
Return all of the neighbors with whom we share the provided range.
-