Uses of Class
org.apache.cassandra.locator.EndpointsForRange
Packages that use EndpointsForRange
Package
Description
-
Uses of EndpointsForRange in org.apache.cassandra.dht
Method parameters in org.apache.cassandra.dht with type arguments of type EndpointsForRangeModifier and TypeMethodDescriptionstatic EndpointsByReplicaRangeStreamer.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.static EndpointsByReplicaRangeStreamer.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 EndpointsForRange in org.apache.cassandra.locator
Subclasses of EndpointsForRange in org.apache.cassandra.locatorMethods in org.apache.cassandra.locator that return EndpointsForRangeModifier and TypeMethodDescriptionEndpointsForRange.Builder.build()abstract EndpointsForRangeAbstractReplicationStrategy.calculateNaturalReplicas(Token searchToken, TokenMetadata tokenMetadata) Calculate the natural endpoints for the given token.LocalStrategy.calculateNaturalReplicas(Token token, TokenMetadata metadata) NetworkTopologyStrategy.calculateNaturalReplicas(Token searchToken, TokenMetadata tokenMetadata) calculate endpoints in one pass through the tokens by tracking our progress in each DC.SimpleStrategy.calculateNaturalReplicas(Token token, TokenMetadata metadata) static EndpointsForRangeEndpointsForRange.copyOf(Collection<Replica> replicas) static EndpointsForRangeAbstractReplicationStrategy.getCachedReplicas(long ringVersion, Token t) AbstractReplicationStrategy.getNaturalReplicas(RingPosition<?> searchPosition) 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 EndpointsForRangeSystemReplicas.getSystemReplicas(Collection<InetAddressAndPort> endpoints) static EndpointsForRangestatic EndpointsForRangeEndpointsForRange.Builder.snapshot()EndpointsForRange.snapshot()Methods in org.apache.cassandra.locator with parameters of type EndpointsForRangeModifier and TypeMethodDescriptionvoidEndpointsByRange.Builder.putAll(Range<Token> range, EndpointsForRange replicas, ReplicaCollection.Builder.Conflict ignoreConflicts) voidEndpointsByReplica.Builder.putAll(Replica range, EndpointsForRange replicas, ReplicaCollection.Builder.Conflict ignoreConflicts) ReplicaPlan.ForRangeRead.withContacts(EndpointsForRange newContact) Constructors in org.apache.cassandra.locator with parameters of type EndpointsForRangeModifierConstructorDescriptionForFullRangeRead(Keyspace keyspace, AbstractReplicationStrategy replicationStrategy, ConsistencyLevel consistencyLevel, AbstractBounds<PartitionPosition> range, EndpointsForRange candidates, EndpointsForRange contact, int vnodeCount) 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 EndpointsForRangeModifierConstructorDescription -
Uses of EndpointsForRange in org.apache.cassandra.service
Methods in org.apache.cassandra.service that return EndpointsForRangeModifier and TypeMethodDescriptionActiveRepairService.getNeighbors(String keyspaceName, Iterable<Range<Token>> keyspaceLocalRanges, Range<Token> toRepair, Collection<String> dataCenters, Collection<String> hosts) Return all of the neighbors with whom we share the provided range.