Modifier and Type | Method and Description |
---|---|
AbstractReplicationStrategy |
Keyspace.getReplicationStrategy() |
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.
|
Modifier and Type | Method and Description |
---|---|
static java.util.Collection<Token> |
TokenAllocation.allocateTokens(TokenMetadata tokenMetadata,
AbstractReplicationStrategy rs,
InetAddressAndPort endpoint,
int numTokens) |
static java.util.Map<InetAddressAndPort,java.lang.Double> |
TokenAllocation.evaluateReplicatedOwnership(TokenMetadata tokenMetadata,
AbstractReplicationStrategy rs) |
static org.apache.commons.math3.stat.descriptive.SummaryStatistics |
TokenAllocation.replicatedOwnershipStats(TokenMetadata tokenMetadata,
AbstractReplicationStrategy rs,
InetAddressAndPort endpoint) |
Modifier and Type | Class and Description |
---|---|
class |
LocalStrategy |
class |
NetworkTopologyStrategy
This Replication Strategy takes a property file that gives the intended
replication factor in each datacenter.
|
class |
SimpleStrategy
This class returns the nodes responsible for a given
key but does not respect rack awareness.
|
Modifier and Type | Method and Description |
---|---|
static AbstractReplicationStrategy |
AbstractReplicationStrategy.createReplicationStrategy(java.lang.String keyspaceName,
java.lang.Class<? extends AbstractReplicationStrategy> strategyClass,
TokenMetadata tokenMetadata,
IEndpointSnitch snitch,
java.util.Map<java.lang.String,java.lang.String> strategyOptions) |
Modifier and Type | Method and Description |
---|---|
static java.lang.Class<AbstractReplicationStrategy> |
AbstractReplicationStrategy.getClass(java.lang.String cls) |
Modifier and Type | Method and Description |
---|---|
void |
TokenMetadata.calculatePendingRanges(AbstractReplicationStrategy strategy,
java.lang.String keyspaceName)
Calculate pending ranges according to bootsrapping and leaving nodes.
|
boolean |
AbstractReplicationStrategy.hasSameSettings(AbstractReplicationStrategy other) |
boolean |
NetworkTopologyStrategy.hasSameSettings(AbstractReplicationStrategy other) |
Modifier and Type | Method and Description |
---|---|
static AbstractReplicationStrategy |
AbstractReplicationStrategy.createReplicationStrategy(java.lang.String keyspaceName,
java.lang.Class<? extends AbstractReplicationStrategy> strategyClass,
TokenMetadata tokenMetadata,
IEndpointSnitch snitch,
java.util.Map<java.lang.String,java.lang.String> strategyOptions) |
static void |
AbstractReplicationStrategy.prepareReplicationStrategyOptions(java.lang.Class<? extends AbstractReplicationStrategy> strategyClass,
java.util.Map<java.lang.String,java.lang.String> strategyOptions,
java.util.Map<java.lang.String,java.lang.String> previousStrategyOptions)
Before constructing the ARS we first give it a chance to prepare the options map in any way it
would like to.
|
static void |
AbstractReplicationStrategy.validateReplicationStrategy(java.lang.String keyspaceName,
java.lang.Class<? extends AbstractReplicationStrategy> strategyClass,
TokenMetadata tokenMetadata,
IEndpointSnitch snitch,
java.util.Map<java.lang.String,java.lang.String> strategyOptions) |
Modifier and Type | Field and Description |
---|---|
java.lang.Class<? extends AbstractReplicationStrategy> |
ReplicationParams.klass |
Modifier and Type | Method and Description |
---|---|
AbstractReplicationStrategy |
KeyspaceMetadata.createReplicationStrategy() |
Modifier and Type | Method and Description |
---|---|
static void |
PendingRangeCalculatorService.calculatePendingRanges(AbstractReplicationStrategy strategy,
java.lang.String keyspaceName) |
static RangesByEndpoint |
RangeRelocator.calculateRangesToStreamWithEndpoints(RangesAtEndpoint streamRanges,
AbstractReplicationStrategy strat,
TokenMetadata tmdBefore,
TokenMetadata tmdAfter)
calculating endpoints to stream current ranges to if needed
in some situations node will handle current ranges as part of the new ranges
|
Copyright © 2009-2020 The Apache Software Foundation