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 | Class and Description |
---|---|
class |
DelegatingCluster
Base class for custom
Cluster implementations that wrap another instance (delegate / decorator pattern). |
Modifier and Type | Field and Description |
---|---|
protected Cluster |
QueryLogger.cluster |
Modifier and Type | Method and Description |
---|---|
Cluster |
Cluster.Builder.build()
Builds the cluster with the configured set of initial contact points
and policies.
|
static Cluster |
Cluster.buildFrom(Cluster.Initializer initializer)
Build a new cluster based on the provided initializer.
|
protected Cluster |
ClusterWidePercentileTracker.computeKey(Host host,
Statement statement,
Exception exception) |
protected abstract Cluster |
DelegatingCluster.delegate()
Returns the delegate instance where all calls will be forwarded.
|
Cluster |
Session.getCluster()
Returns the
Cluster object this session is part of. |
Cluster |
DelegatingCluster.init() |
Cluster |
Cluster.init()
Initialize this Cluster instance.
|
Cluster |
DelegatingCluster.register(Host.StateListener listener) |
Cluster |
Cluster.register(Host.StateListener listener)
Registers the provided listener to be notified on hosts
up/down/added/removed events.
|
Cluster |
DelegatingCluster.register(LatencyTracker tracker) |
Cluster |
Cluster.register(LatencyTracker tracker)
Registers the provided tracker to be updated with hosts read
latencies.
|
Cluster |
Cluster.register(SchemaChangeListener listener)
Registers the provided listener to be updated with schema change events.
|
Cluster |
DelegatingCluster.unregister(Host.StateListener listener) |
Cluster |
Cluster.unregister(Host.StateListener listener)
Unregisters the provided listener from being notified on hosts events.
|
Cluster |
DelegatingCluster.unregister(LatencyTracker tracker) |
Cluster |
Cluster.unregister(LatencyTracker tracker)
Unregisters the provided latency tracking from being updated
with host read latencies.
|
Cluster |
Cluster.unregister(SchemaChangeListener listener)
Unregisters the provided schema change listener from being updated
with schema change events.
|
Modifier and Type | Method and Description |
---|---|
static QueryLogger.Builder |
QueryLogger.builder(Cluster cluster)
Creates a new
QueryLogger.Builder instance. |
void |
SchemaChangeListener.onRegister(Cluster cluster)
Gets invoked when the listener is registered with a cluster.
|
void |
QueryLogger.ConstantThresholdQueryLogger.onRegister(Cluster cluster) |
void |
QueryLogger.DynamicThresholdQueryLogger.onRegister(Cluster cluster) |
void |
PercentileTracker.onRegister(Cluster cluster) |
void |
LifecycleAwareLatencyTracker.onRegister(Cluster cluster)
Gets invoked when the tracker is registered with a cluster, or at cluster startup if the
tracker was registered at initialization with
register(LatencyTracker) . |
void |
Host.LifecycleAwareStateListener.onRegister(Cluster cluster)
Gets invoked when the listener is registered with a cluster, or at cluster startup if the
listener was registered at initialization with
com.datastax.driver.core.Cluster.Initializer#register(StateListener) . |
void |
ClusterWidePercentileTracker.onRegister(Cluster cluster) |
void |
SchemaChangeListener.onUnregister(Cluster cluster)
Gets invoked when the listener is unregistered from a cluster, or at cluster shutdown if
the tracker was not unregistered.
|
void |
QueryLogger.ConstantThresholdQueryLogger.onUnregister(Cluster cluster) |
void |
QueryLogger.DynamicThresholdQueryLogger.onUnregister(Cluster cluster) |
void |
PercentileTracker.onUnregister(Cluster cluster) |
void |
LifecycleAwareLatencyTracker.onUnregister(Cluster cluster)
Gets invoked when the tracker is unregistered from a cluster, or at cluster shutdown if
the tracker was not unregistered.
|
void |
Host.LifecycleAwareStateListener.onUnregister(Cluster cluster)
Gets invoked when the listener is unregistered from a cluster, or at cluster shutdown if
the listener was not unregistered.
|
Constructor and Description |
---|
Builder(Cluster cluster) |
Modifier and Type | Method and Description |
---|---|
void |
SpeculativeExecutionPolicy.init(Cluster cluster)
Gets invoked at cluster startup.
|
void |
PercentileSpeculativeExecutionPolicy.init(Cluster cluster) |
void |
NoSpeculativeExecutionPolicy.init(Cluster cluster) |
void |
ConstantSpeculativeExecutionPolicy.init(Cluster cluster) |
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 |
HostFilterPolicy.init(Cluster cluster,
Collection<Host> hosts)
Initialize this load balancing policy.
|
void |
DCAwareRoundRobinPolicy.init(Cluster cluster,
Collection<Host> hosts) |