|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.cassandra.locator.AbstractEndpointSnitch
org.apache.cassandra.locator.DynamicEndpointSnitch
public class DynamicEndpointSnitch
A dynamic snitch that sorts endpoints by latency with an adapted phi failure detector
Field Summary | |
---|---|
IEndPointSnitch |
subsnitch
|
Constructor Summary | |
---|---|
DynamicEndpointSnitch(IEndPointSnitch snitch)
|
Method Summary | |
---|---|
int |
compareEndpoints(java.net.InetAddress target,
java.net.InetAddress a1,
java.net.InetAddress a2)
compares two endpoints in relation to the target endpoint, returning as Comparator.compare would |
java.lang.String |
getLocation(java.net.InetAddress endpoint)
Determines the name of the datacenter this endpoint lives in. |
java.util.Map<java.net.InetAddress,java.lang.Double> |
getScores()
|
java.util.List<java.net.InetAddress> |
getSortedListByProximity(java.net.InetAddress address,
java.util.Collection<java.net.InetAddress> addresses)
returns a new List |
boolean |
isInSameDataCenter(java.net.InetAddress a1,
java.net.InetAddress a2)
Determines if 2 nodes are in the same data center. |
boolean |
isOnSameRack(java.net.InetAddress a1,
java.net.InetAddress a2)
Determines if 2 nodes are in the same rack in the data center. |
void |
receiveTiming(java.net.InetAddress host,
java.lang.Double latency)
|
java.util.List<java.net.InetAddress> |
sortByProximity(java.net.InetAddress address,
java.util.List<java.net.InetAddress> addresses)
This method will sort the List |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public IEndPointSnitch subsnitch
Constructor Detail |
---|
public DynamicEndpointSnitch(IEndPointSnitch snitch)
Method Detail |
---|
public boolean isOnSameRack(java.net.InetAddress a1, java.net.InetAddress a2) throws java.net.UnknownHostException
AbstractEndpointSnitch
isOnSameRack
in interface IEndPointSnitch
isOnSameRack
in class AbstractEndpointSnitch
a1
- a specified endpointa2
- another specified endpoint
java.net.UnknownHostException
public boolean isInSameDataCenter(java.net.InetAddress a1, java.net.InetAddress a2) throws java.net.UnknownHostException
AbstractEndpointSnitch
isInSameDataCenter
in interface IEndPointSnitch
isInSameDataCenter
in class AbstractEndpointSnitch
a1
- a specified endpointa2
- another specified endpoint
java.net.UnknownHostException
public java.lang.String getLocation(java.net.InetAddress endpoint) throws java.net.UnknownHostException
AbstractEndpointSnitch
getLocation
in interface IEndPointSnitch
getLocation
in class AbstractEndpointSnitch
java.net.UnknownHostException
public java.util.List<java.net.InetAddress> getSortedListByProximity(java.net.InetAddress address, java.util.Collection<java.net.InetAddress> addresses)
IEndPointSnitch
getSortedListByProximity
in interface IEndPointSnitch
getSortedListByProximity
in class AbstractEndpointSnitch
public java.util.List<java.net.InetAddress> sortByProximity(java.net.InetAddress address, java.util.List<java.net.InetAddress> addresses)
IEndPointSnitch
sortByProximity
in interface IEndPointSnitch
sortByProximity
in class AbstractEndpointSnitch
public int compareEndpoints(java.net.InetAddress target, java.net.InetAddress a1, java.net.InetAddress a2)
IEndPointSnitch
compareEndpoints
in interface IEndPointSnitch
compareEndpoints
in class AbstractEndpointSnitch
public void receiveTiming(java.net.InetAddress host, java.lang.Double latency)
receiveTiming
in interface ILatencySubscriber
public java.util.Map<java.net.InetAddress,java.lang.Double> getScores()
getScores
in interface DynamicEndpointSnitchMBean
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |