|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.cassandra.locator.AbstractReplicationStrategy
public abstract class AbstractReplicationStrategy
This class contains a helper method that will be used by all abstraction that implement the IReplicaPlacementStrategy interface.
Field Summary | |
---|---|
protected static org.apache.log4j.Logger |
logger_
|
protected IEndPointSnitch |
snitch_
|
Method Summary | |
---|---|
com.google.common.collect.Multimap<java.net.InetAddress,Range> |
getAddressRanges(java.lang.String table)
|
com.google.common.collect.Multimap<java.net.InetAddress,Range> |
getAddressRanges(TokenMetadata metadata,
java.lang.String table)
|
com.google.common.collect.Multimap<java.net.InetAddress,java.net.InetAddress> |
getHintedEndpoints(java.lang.String table,
java.util.Collection<java.net.InetAddress> targets)
returns multimap of {live destination: ultimate targets}, where if target is not the same as the destination, it is a "hinted" write, and will need to be sent to the ultimate target when it becomes alive again. |
java.util.ArrayList<java.net.InetAddress> |
getNaturalEndpoints(Token token,
java.lang.String table)
|
abstract java.util.ArrayList<java.net.InetAddress> |
getNaturalEndpoints(Token token,
TokenMetadata metadata,
java.lang.String table)
get the endpoints that should store the given Token, for the given table. |
java.util.Collection<Range> |
getPendingAddressRanges(TokenMetadata metadata,
Token pendingToken,
java.net.InetAddress pendingAddress,
java.lang.String table)
|
com.google.common.collect.Multimap<Range,java.net.InetAddress> |
getRangeAddresses(TokenMetadata metadata,
java.lang.String table)
|
java.util.Collection<java.net.InetAddress> |
getWriteEndpoints(Token token,
java.lang.String table,
java.util.Collection<java.net.InetAddress> naturalEndpoints)
write endpoints may be different from read endpoints, because read endpoints only need care about the "natural" nodes for a token, but write endpoints also need to account for nodes that are bootstrapping into the ring, and write data there too so that they stay up to date during the bootstrap process. |
WriteResponseHandler |
getWriteResponseHandler(int blockFor,
ConsistencyLevel consistency_level,
java.lang.String table)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected static final org.apache.log4j.Logger logger_
protected final IEndPointSnitch snitch_
Method Detail |
---|
public abstract java.util.ArrayList<java.net.InetAddress> getNaturalEndpoints(Token token, TokenMetadata metadata, java.lang.String table)
public WriteResponseHandler getWriteResponseHandler(int blockFor, ConsistencyLevel consistency_level, java.lang.String table)
public java.util.ArrayList<java.net.InetAddress> getNaturalEndpoints(Token token, java.lang.String table)
public com.google.common.collect.Multimap<java.net.InetAddress,java.net.InetAddress> getHintedEndpoints(java.lang.String table, java.util.Collection<java.net.InetAddress> targets)
public java.util.Collection<java.net.InetAddress> getWriteEndpoints(Token token, java.lang.String table, java.util.Collection<java.net.InetAddress> naturalEndpoints)
public com.google.common.collect.Multimap<java.net.InetAddress,Range> getAddressRanges(TokenMetadata metadata, java.lang.String table)
public com.google.common.collect.Multimap<Range,java.net.InetAddress> getRangeAddresses(TokenMetadata metadata, java.lang.String table)
public com.google.common.collect.Multimap<java.net.InetAddress,Range> getAddressRanges(java.lang.String table)
public java.util.Collection<Range> getPendingAddressRanges(TokenMetadata metadata, Token pendingToken, java.net.InetAddress pendingAddress, java.lang.String table)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |