Package org.apache.cassandra.locator

Class AbstractReplicationStrategy

java.lang.Object

org.apache.cassandra.locator.AbstractReplicationStrategy

Direct Known Subclasses:

LocalStrategy, NetworkTopologyStrategy, SimpleStrategy

public abstract class AbstractReplicationStrategy
extends Object

A abstract parent for all replication strategies.

Field Summary

Fields

Modifier and Type	Field	Description
final Map<String,String>	configOptions
protected final String	keyspaceName
IEndpointSnitch	snitch

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractReplicationStrategy(String keyspaceName, TokenMetadata tokenMetadata, IEndpointSnitch snitch, Map<String,String> configOptions)

Method Summary

Modifier and Type	Method	Description
abstract EndpointsForRange	calculateNaturalReplicas(Token searchToken, TokenMetadata tokenMetadata)	Calculate the natural endpoints for the given token.
static AbstractReplicationStrategy	createReplicationStrategy(String keyspaceName, Class<? extends AbstractReplicationStrategy> strategyClass, TokenMetadata tokenMetadata, IEndpointSnitch snitch, Map<String,String> strategyOptions)
RangesByEndpoint	getAddressReplicas()
RangesAtEndpoint	getAddressReplicas(InetAddressAndPort endpoint)
RangesByEndpoint	getAddressReplicas(TokenMetadata metadata)
RangesAtEndpoint	getAddressReplicas(TokenMetadata metadata, InetAddressAndPort endpoint)
EndpointsForRange	getCachedReplicas(long ringVersion, Token t)
static Class<AbstractReplicationStrategy>	getClass(String cls)
Replica	getLocalReplicaFor(Token searchPosition)
EndpointsForRange	getNaturalReplicas(RingPosition<?> searchPosition)
EndpointsForToken	getNaturalReplicasForToken(RingPosition<?> searchPosition)	get the (possibly cached) endpoints that should store the given Token.
RangesAtEndpoint	getPendingAddressRanges(TokenMetadata metadata, Collection<Token> pendingTokens, InetAddressAndPort pendingAddress)
RangesAtEndpoint	getPendingAddressRanges(TokenMetadata metadata, Token pendingToken, InetAddressAndPort pendingAddress)
EndpointsByRange	getRangeAddresses(TokenMetadata metadata)
abstract ReplicationFactor	getReplicationFactor()	calculate the RF based on strategy_options.
<T> AbstractWriteResponseHandler<T>	getWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime)
<T> AbstractWriteResponseHandler<T>	getWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime, ConsistencyLevel idealConsistencyLevel)
boolean	hasSameSettings(AbstractReplicationStrategy other)
boolean	hasTransientReplicas()
boolean	isTokenInLocalNaturalOrPendingRange(Token token)	Check if the token is in a naturally replicated range or pending range
void	maybeWarnOnOptions()	Deprecated. See CASSANDRA-17212
void	maybeWarnOnOptions(ClientState state)
static void	prepareReplicationStrategyOptions(Class<? extends AbstractReplicationStrategy> strategyClass, Map<String,String> strategyOptions, Map<String,String> previousStrategyOptions)	Before constructing the ARS we first give it a chance to prepare the options map in any way it would like to.
Collection<String>	recognizedOptions()
protected void	validateExpectedOptions()
abstract void	validateOptions()
protected void	validateReplicationFactor(String s)
static void	validateReplicationStrategy(String keyspaceName, Class<? extends AbstractReplicationStrategy> strategyClass, TokenMetadata tokenMetadata, IEndpointSnitch snitch, Map<String,String> strategyOptions, ClientState state)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

configOptions

public final Map<String,String> configOptions

keyspaceName

protected final String keyspaceName

snitch

public IEndpointSnitch snitch

Constructor Details

AbstractReplicationStrategy

protected AbstractReplicationStrategy(String keyspaceName,
 TokenMetadata tokenMetadata,
 IEndpointSnitch snitch,
 Map<String,String> configOptions)

Method Details

getCachedReplicas

public EndpointsForRange getCachedReplicas(long ringVersion,
 Token t)

getNaturalReplicasForToken

public EndpointsForToken getNaturalReplicasForToken(RingPosition<?> searchPosition)

get the (possibly cached) endpoints that should store the given Token. Note that while the endpoints are conceptually a Set (no duplicates will be included), we return a List to avoid an extra allocation when sorting by proximity later

Parameters:

searchPosition - the position the natural endpoints are requested for

Returns:

a copy of the natural endpoints for the given token

getNaturalReplicas

public EndpointsForRange getNaturalReplicas(RingPosition<?> searchPosition)

isTokenInLocalNaturalOrPendingRange

public boolean isTokenInLocalNaturalOrPendingRange(Token token)

Check if the token is in a naturally replicated range or pending range

Parameters:

token - the position to check

Returns:

true if the token is in a natural or pending locally replicationed range, false otherwise

getLocalReplicaFor

public Replica getLocalReplicaFor(Token searchPosition)

calculateNaturalReplicas

public abstract EndpointsForRange calculateNaturalReplicas(Token searchToken,
 TokenMetadata tokenMetadata)

Calculate the natural endpoints for the given token. Endpoints are returned in the order they occur in the ring following the searchToken, as defined by the replication strategy. Note that the order of the replicas is _implicitly relied upon_ by the definition of "primary" range in StorageService.getPrimaryRangesForEndpoint(String, InetAddressAndPort) which is in turn relied on by various components like repair and size estimate calculations.

Parameters:

tokenMetadata - the token metadata used to find the searchToken, e.g. contains token to endpoint mapping information

searchToken - the token to find the natural endpoints for

Returns:

a copy of the natural endpoints for the given token

See Also:

• getNaturalReplicasForToken(org.apache.cassandra.dht.RingPosition)

getWriteResponseHandler

public <T> AbstractWriteResponseHandler<T> getWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan,
 Runnable callback,
 WriteType writeType,
 Supplier<Mutation> hintOnFailure,
 Dispatcher.RequestTime requestTime)

getWriteResponseHandler

public <T> AbstractWriteResponseHandler<T> getWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan,
 Runnable callback,
 WriteType writeType,
 Supplier<Mutation> hintOnFailure,
 Dispatcher.RequestTime requestTime,
 ConsistencyLevel idealConsistencyLevel)

getReplicationFactor

public abstract ReplicationFactor getReplicationFactor()

calculate the RF based on strategy_options. When overwriting, ensure that this get() is FAST, as this is called often.

Returns:

the replication factor

hasTransientReplicas

public boolean hasTransientReplicas()

getAddressReplicas

public RangesByEndpoint getAddressReplicas(TokenMetadata metadata)

getAddressReplicas

public RangesAtEndpoint getAddressReplicas(TokenMetadata metadata,
 InetAddressAndPort endpoint)

getRangeAddresses

public EndpointsByRange getRangeAddresses(TokenMetadata metadata)

getAddressReplicas

public RangesByEndpoint getAddressReplicas()

getAddressReplicas

public RangesAtEndpoint getAddressReplicas(InetAddressAndPort endpoint)

getPendingAddressRanges

public RangesAtEndpoint getPendingAddressRanges(TokenMetadata metadata,
 Token pendingToken,
 InetAddressAndPort pendingAddress)

getPendingAddressRanges

public RangesAtEndpoint getPendingAddressRanges(TokenMetadata metadata,
 Collection<Token> pendingTokens,
 InetAddressAndPort pendingAddress)

validateOptions

public abstract void validateOptions()
                              throws ConfigurationException

Throws:

ConfigurationException

maybeWarnOnOptions

@Deprecated(since="4.1")
public void maybeWarnOnOptions()

Deprecated.

See CASSANDRA-17212

maybeWarnOnOptions

public void maybeWarnOnOptions(ClientState state)

recognizedOptions

public Collection<String> recognizedOptions()

createReplicationStrategy

public static AbstractReplicationStrategy createReplicationStrategy(String keyspaceName,
 Class<? extends AbstractReplicationStrategy> strategyClass,
 TokenMetadata tokenMetadata,
 IEndpointSnitch snitch,
 Map<String,String> strategyOptions)

prepareReplicationStrategyOptions

public static void prepareReplicationStrategyOptions(Class<? extends AbstractReplicationStrategy> strategyClass,
 Map<String,String> strategyOptions,
 Map<String,String> previousStrategyOptions)

Before constructing the ARS we first give it a chance to prepare the options map in any way it would like to. For example datacenter auto-expansion or other templating to make the user interface more usable. Note that this may mutate the passed strategyOptions Map. We do this prior to the construction of the strategyClass itself because at that point the option map is already immutable and comes from ReplicationParams (and should probably stay that way so we don't start having bugs related to ReplicationParams being mutable). Instead ARS classes get a static hook here via the prepareOptions(Map, Map) method to mutate the user input before it becomes an immutable part of the ReplicationParams.

Parameters:

strategyClass - The class to call prepareOptions on

strategyOptions - The proposed strategy options that will be potentially mutated by the prepareOptions method.

previousStrategyOptions - In the case of an ALTER statement, the previous strategy options of this class. This map cannot be mutated.

validateReplicationStrategy

public static void validateReplicationStrategy(String keyspaceName,
 Class<? extends AbstractReplicationStrategy> strategyClass,
 TokenMetadata tokenMetadata,
 IEndpointSnitch snitch,
 Map<String,String> strategyOptions,
 ClientState state)
                                        throws ConfigurationException

Throws:

ConfigurationException

getClass

public static Class<AbstractReplicationStrategy> getClass(String cls)
                                                   throws ConfigurationException

Throws:

ConfigurationException

hasSameSettings

public boolean hasSameSettings(AbstractReplicationStrategy other)

validateReplicationFactor

protected void validateReplicationFactor(String s)
                                  throws ConfigurationException

Throws:

ConfigurationException

validateExpectedOptions

protected void validateExpectedOptions()
                                throws ConfigurationException

Throws:

ConfigurationException