Uses of Class
org.apache.cassandra.locator.AbstractReplicationStrategy
-
-
Uses of AbstractReplicationStrategy in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return AbstractReplicationStrategy Modifier and Type Method Description AbstractReplicationStrategy
Keyspace. getReplicationStrategy()
Methods in org.apache.cassandra.db with parameters of type AbstractReplicationStrategy Modifier and Type Method 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)
-
Uses of AbstractReplicationStrategy in org.apache.cassandra.db.view
Methods in org.apache.cassandra.db.view with parameters of type AbstractReplicationStrategy Modifier and Type Method Description static java.util.Optional<Replica>
ViewUtils. getViewNaturalEndpoint(AbstractReplicationStrategy replicationStrategy, Token baseToken, Token viewToken)
Calculate the natural endpoint for the view. -
Uses of AbstractReplicationStrategy in org.apache.cassandra.dht
Methods in org.apache.cassandra.dht with parameters of type AbstractReplicationStrategy Modifier and Type Method 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. -
Uses of AbstractReplicationStrategy in org.apache.cassandra.dht.tokenallocator
Methods in org.apache.cassandra.dht.tokenallocator with parameters of type AbstractReplicationStrategy Modifier and Type Method Description static java.util.Collection<Token>
TokenAllocation. allocateTokens(TokenMetadata tokenMetadata, AbstractReplicationStrategy rs, InetAddressAndPort endpoint, int numTokens)
-
Uses of AbstractReplicationStrategy in org.apache.cassandra.locator
Subclasses of AbstractReplicationStrategy in org.apache.cassandra.locator Modifier and Type Class 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.Fields in org.apache.cassandra.locator declared as AbstractReplicationStrategy Modifier and Type Field Description protected AbstractReplicationStrategy
ReplicaPlan. replicationStrategy
Methods in org.apache.cassandra.locator that return AbstractReplicationStrategy Modifier and Type Method 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()
Methods in org.apache.cassandra.locator that return types with arguments of type AbstractReplicationStrategy Modifier and Type Method Description static java.lang.Class<AbstractReplicationStrategy>
AbstractReplicationStrategy. getClass(java.lang.String cls)
Methods in org.apache.cassandra.locator with parameters of type AbstractReplicationStrategy Modifier and Type Method 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)
Method parameters in org.apache.cassandra.locator with type arguments of type AbstractReplicationStrategy Modifier and Type Method 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)
-
Uses of AbstractReplicationStrategy in org.apache.cassandra.schema
Fields in org.apache.cassandra.schema with type parameters of type AbstractReplicationStrategy Modifier and Type Field Description java.lang.Class<? extends AbstractReplicationStrategy>
ReplicationParams. klass
Methods in org.apache.cassandra.schema that return AbstractReplicationStrategy Modifier and Type Method Description AbstractReplicationStrategy
KeyspaceMetadata. createReplicationStrategy()
-
Uses of AbstractReplicationStrategy in org.apache.cassandra.service
Methods in org.apache.cassandra.service with parameters of type AbstractReplicationStrategy Modifier and Type Method 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
-