Package | Description |
---|---|
org.apache.cassandra.dht | |
org.apache.cassandra.locator | |
org.apache.cassandra.service |
Modifier and Type | Method and 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.
|
Modifier and Type | Class and Description |
---|---|
static class |
EndpointsForRange.Builder |
Modifier and Type | Method and 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... replicas) |
static EndpointsForRange |
EndpointsForRange.of(Replica replica) |
EndpointsForRange |
EndpointsForRange.snapshot() |
EndpointsForRange |
EndpointsForRange.Builder.snapshot() |
Modifier and Type | Method and 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) |
Constructor and 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 and Description |
---|
EndpointsByRange(java.util.Map<Range<Token>,EndpointsForRange> map) |
EndpointsByReplica(java.util.Map<Replica,EndpointsForRange> map) |
Modifier and Type | Method and 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.
|
Copyright © 2009-2022 The Apache Software Foundation