Uses of Class
org.apache.cassandra.locator.AbstractReplicationStrategy

Packages that use AbstractReplicationStrategy

Package	Description
org.apache.cassandra.db
org.apache.cassandra.db.view
org.apache.cassandra.dht
org.apache.cassandra.dht.tokenallocator
org.apache.cassandra.locator
org.apache.cassandra.schema
org.apache.cassandra.service

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.AbstractReplicaPlan.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.AbstractReplicaPlan.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.ForTokenRead	ReplicaLayout.forTokenReadLiveSorted(AbstractReplicationStrategy replicationStrategy, Token token)
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)
static EndpointsForToken	EndpointsForToken.natural(AbstractReplicationStrategy replicationStrategy, Token token)
void	TokenMetadata.unsafeCalculatePendingRanges(AbstractReplicationStrategy strategy, java.lang.String keyspaceName)

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, ClientState state)

Constructors in org.apache.cassandra.locator with parameters of type AbstractReplicationStrategy

Constructor	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)
ForTokenRead(AbstractReplicationStrategy replicationStrategy, EndpointsForToken natural)
ForTokenRead(Keyspace keyspace, AbstractReplicationStrategy replicationStrategy, ConsistencyLevel consistencyLevel, EndpointsForToken candidates, EndpointsForToken contacts)
ForTokenWrite(AbstractReplicationStrategy replicationStrategy, EndpointsForToken natural, EndpointsForToken pending)
ForTokenWrite(AbstractReplicationStrategy replicationStrategy, EndpointsForToken natural, EndpointsForToken pending, EndpointsForToken all)
ForWrite(Keyspace keyspace, AbstractReplicationStrategy replicationStrategy, ConsistencyLevel consistencyLevel, EndpointsForToken pending, EndpointsForToken liveAndDown, EndpointsForToken live, EndpointsForToken contact)

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