Modifier and Type | Method and Description |
---|---|
AbstractReplicationStrategy |
Keyspace.getReplicationStrategy() |
Modifier and Type | Method and Description |
---|---|
int |
ConsistencyLevel.blockFor(AbstractReplicationStrategy replicationStrategy) |
int |
ConsistencyLevel.blockForWrite(AbstractReplicationStrategy replicationStrategy,
Endpoints<?> pending) |
static com.carrotsearch.hppc.ObjectIntHashMap<java.lang.String> |
ConsistencyLevel.eachQuorumForRead(AbstractReplicationStrategy replicationStrategy) |
static com.carrotsearch.hppc.ObjectIntHashMap<java.lang.String> |
ConsistencyLevel.eachQuorumForWrite(AbstractReplicationStrategy replicationStrategy,
Endpoints<?> pendingWithDown) |
static int |
ConsistencyLevel.localQuorumFor(AbstractReplicationStrategy replicationStrategy,
java.lang.String dc) |
static int |
ConsistencyLevel.localQuorumForOurDc(AbstractReplicationStrategy replicationStrategy) |
static int |
ConsistencyLevel.quorumFor(AbstractReplicationStrategy replicationStrategy) |
boolean |
ConsistencyLevel.satisfies(ConsistencyLevel other,
AbstractReplicationStrategy replicationStrategy)
Determine if this consistency level meets or exceeds the consistency requirements of the given cl for the given keyspace
WARNING: this is not locality aware; you cannot safely use this with mixed locality consistency levels (e.g.
|
void |
ConsistencyLevel.validateForCasCommit(AbstractReplicationStrategy replicationStrategy) |
Modifier and Type | Method and Description |
---|---|
static java.util.Optional<Replica> |
ViewUtils.getViewNaturalEndpoint(AbstractReplicationStrategy replicationStrategy,
Token baseToken,
Token viewToken)
Calculate the natural endpoint for the view.
|
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) |
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 | Field and Description |
---|---|
protected AbstractReplicationStrategy |
ReplicaPlan.replicationStrategy |
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) |
AbstractReplicationStrategy |
ReplicaLayout.replicationStrategy() |
AbstractReplicationStrategy |
ReplicaPlan.replicationStrategy() |
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.
|
static ReplicaLayout.ForTokenWrite |
ReplicaLayout.forTokenWrite(AbstractReplicationStrategy replicationStrategy,
EndpointsForToken natural,
EndpointsForToken pending) |
boolean |
AbstractReplicationStrategy.hasSameSettings(AbstractReplicationStrategy other) |
boolean |
NetworkTopologyStrategy.hasSameSettings(AbstractReplicationStrategy other) |
static boolean |
ReplicaPlans.isSufficientLiveReplicasForRead(AbstractReplicationStrategy replicationStrategy,
ConsistencyLevel consistencyLevel,
Endpoints<?> liveReplicas) |
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-2022 The Apache Software Foundation