Package | Description |
---|---|
com.datastax.driver.core |
The main package for the DataStax Java driver for Cassandra.
|
com.datastax.driver.core.policies |
Policies that allow to control some of the behavior of the DataStax Java driver for Cassandra.
|
Modifier and Type | Method and Description |
---|---|
Host |
ExecutionInfo.getQueriedHost()
Return the Cassandra host that coordinated this query.
|
Modifier and Type | Method and Description |
---|---|
Set<Host> |
Metadata.getAllHosts()
Returns the known hosts of this cluster.
|
Set<Host> |
Metadata.getReplicas(ByteBuffer partitionKey)
Returns the set of hosts that are replica for a given partition key.
|
List<Host> |
ExecutionInfo.getTriedHosts()
The list of tried hosts for this query.
|
Modifier and Type | Method and Description |
---|---|
void |
Host.StateListener.onAdd(Host host)
Called when a new node is added to the cluster.
|
void |
Host.StateListener.onDown(Host host)
Called when a node is determined to be down.
|
void |
Host.StateListener.onRemove(Host host)
Called when a node is removed from the cluster.
|
void |
Host.StateListener.onUp(Host host)
Called when a node is determined to be up.
|
void |
LatencyTracker.update(Host host,
long newLatencyNanos)
A method that is called after each request to a Cassandra node with
the duration of that operation.
|
Modifier and Type | Method and Description |
---|---|
Map<Host,LatencyAwarePolicy.Snapshot.Stats> |
LatencyAwarePolicy.Snapshot.getAllStats()
A map with the stats for all hosts tracked by the
LatencyAwarePolicy at the time of the snapshot. |
Iterator<Host> |
WhiteListPolicy.newQueryPlan(Query query)
Returns the hosts to use for a new query.
|
Iterator<Host> |
TokenAwarePolicy.newQueryPlan(Query query)
Returns the hosts to use for a new query.
|
Iterator<Host> |
RoundRobinPolicy.newQueryPlan(Query query)
Returns the hosts to use for a new query.
|
Iterator<Host> |
LoadBalancingPolicy.newQueryPlan(Query query)
Returns the hosts to use for a new query.
|
Iterator<Host> |
LatencyAwarePolicy.newQueryPlan(Query query)
Returns the hosts to use for a new query.
|
Iterator<Host> |
DCAwareRoundRobinPolicy.newQueryPlan(Query query)
Returns the hosts to use for a new query.
|
Modifier and Type | Method and Description |
---|---|
HostDistance |
WhiteListPolicy.distance(Host host)
Return the HostDistance for the provided host.
|
HostDistance |
TokenAwarePolicy.distance(Host host)
Return the HostDistance for the provided host.
|
HostDistance |
RoundRobinPolicy.distance(Host host)
Return the HostDistance for the provided host.
|
HostDistance |
LoadBalancingPolicy.distance(Host host)
Returns the distance assigned by this policy to the provided host.
|
HostDistance |
LatencyAwarePolicy.distance(Host host)
Returns the HostDistance for the provided host.
|
HostDistance |
DCAwareRoundRobinPolicy.distance(Host host)
Return the HostDistance for the provided host.
|
LatencyAwarePolicy.Snapshot.Stats |
LatencyAwarePolicy.Snapshot.getStats(Host host)
The
Stats object for a given host. |
void |
WhiteListPolicy.onAdd(Host host) |
void |
TokenAwarePolicy.onAdd(Host host) |
void |
RoundRobinPolicy.onAdd(Host host) |
void |
LatencyAwarePolicy.onAdd(Host host) |
void |
DCAwareRoundRobinPolicy.onAdd(Host host) |
void |
WhiteListPolicy.onDown(Host host) |
void |
TokenAwarePolicy.onDown(Host host) |
void |
RoundRobinPolicy.onDown(Host host) |
void |
LatencyAwarePolicy.onDown(Host host) |
void |
DCAwareRoundRobinPolicy.onDown(Host host) |
void |
WhiteListPolicy.onRemove(Host host) |
void |
TokenAwarePolicy.onRemove(Host host) |
void |
RoundRobinPolicy.onRemove(Host host) |
void |
LatencyAwarePolicy.onRemove(Host host) |
void |
DCAwareRoundRobinPolicy.onRemove(Host host) |
void |
WhiteListPolicy.onUp(Host host) |
void |
TokenAwarePolicy.onUp(Host host) |
void |
RoundRobinPolicy.onUp(Host host) |
void |
LatencyAwarePolicy.onUp(Host host) |
void |
DCAwareRoundRobinPolicy.onUp(Host host) |
Modifier and Type | Method and Description |
---|---|
void |
WhiteListPolicy.init(Cluster cluster,
Collection<Host> hosts)
Initialize this load balancing policy.
|
void |
TokenAwarePolicy.init(Cluster cluster,
Collection<Host> hosts) |
void |
RoundRobinPolicy.init(Cluster cluster,
Collection<Host> hosts) |
void |
LoadBalancingPolicy.init(Cluster cluster,
Collection<Host> hosts)
Initialize this load balancing policy.
|
void |
LatencyAwarePolicy.init(Cluster cluster,
Collection<Host> hosts) |
void |
DCAwareRoundRobinPolicy.init(Cluster cluster,
Collection<Host> hosts) |
Copyright © 2014. All Rights Reserved.