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 EndpointsByReplicaRangeStreamer. 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 EndpointsByReplicaRangeStreamer. 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 classEndpointsForRange.BuilderMethods in org.apache.cassandra.locator that return EndpointsForRange Modifier and Type Method Description EndpointsForRangeEndpointsForRange.Builder. build()abstract EndpointsForRangeAbstractReplicationStrategy. calculateNaturalReplicas(Token searchToken, TokenMetadata tokenMetadata)Calculate the natural endpoints for the given token.EndpointsForRangeLocalStrategy. calculateNaturalReplicas(Token token, TokenMetadata metadata)EndpointsForRangeNetworkTopologyStrategy. calculateNaturalReplicas(Token searchToken, TokenMetadata tokenMetadata)calculate endpoints in one pass through the tokens by tracking our progress in each DC.EndpointsForRangeSimpleStrategy. calculateNaturalReplicas(Token token, TokenMetadata metadata)static EndpointsForRangeEndpointsForRange. copyOf(java.util.Collection<Replica> replicas)static EndpointsForRangeEndpointsForRange. empty(Range<Token> range)EndpointsForRangeEndpointsByRange. get(Range<Token> range)EndpointsForRangeEndpointsByReplica. get(Replica range)EndpointsForRangeAbstractReplicationStrategy. getCachedReplicas(long ringVersion, Token t)EndpointsForRangeAbstractReplicationStrategy. getNaturalReplicas(RingPosition<?> searchPosition)EndpointsForRangeLocalStrategy. 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 EndpointsForRangeSystemReplicas. getSystemReplicas(java.util.Collection<InetAddressAndPort> endpoints)static EndpointsForRangeEndpointsForRange. of(Replica replica)static EndpointsForRangeEndpointsForRange. of(Replica... replicas)EndpointsForRangeEndpointsForRange.Builder. snapshot()EndpointsForRangeEndpointsForRange. snapshot()Methods in org.apache.cassandra.locator with parameters of type EndpointsForRange Modifier and Type Method Description voidEndpointsByRange.Builder. putAll(Range<Token> range, EndpointsForRange replicas, ReplicaCollection.Builder.Conflict ignoreConflicts)voidEndpointsByReplica.Builder. putAll(Replica range, EndpointsForRange replicas, ReplicaCollection.Builder.Conflict ignoreConflicts)ReplicaPlan.ForRangeReadReplicaPlan.ForRangeRead. withContacts(EndpointsForRange newContact)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 EndpointsForRangeActiveRepairService. 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.
-