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 |
DelegatingCluster.register(SchemaChangeListener listener) |
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 |
DelegatingCluster.unregister(SchemaChangeListener listener) |
Cluster |
Cluster.unregister(SchemaChangeListener listener)
Unregisters the provided schema change listener from being updated
with schema change events.
|
Modifier and Type | Method and Description |
---|---|
void |
SchemaChangeListenerBase.onRegister(Cluster cluster) |
void |
SchemaChangeListener.onRegister(Cluster cluster)
Gets invoked when the listener is registered with a cluster.
|
void |
QueryLogger.onRegister(Cluster cluster) |
void |
QueryLogger.DynamicThresholdQueryLogger.onRegister(Cluster cluster) |
void |
PercentileTracker.onRegister(Cluster cluster) |
void |
LatencyTracker.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.StateListener.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 |
SchemaChangeListenerBase.onUnregister(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.onUnregister(Cluster cluster) |
void |
PercentileTracker.onUnregister(Cluster cluster) |
void |
LatencyTracker.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.StateListener.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.
|
Modifier and Type | Method and Description |
---|---|
void |
SpeculativeExecutionPolicy.init(Cluster cluster)
Gets invoked at cluster startup.
|
void |
RetryPolicy.init(Cluster cluster)
Gets invoked at cluster startup.
|
void |
ReconnectionPolicy.init(Cluster cluster)
Gets invoked at cluster startup.
|
void |
PercentileSpeculativeExecutionPolicy.init(Cluster cluster) |
void |
NoSpeculativeExecutionPolicy.init(Cluster cluster) |
void |
LoggingRetryPolicy.init(Cluster cluster) |
void |
IdentityTranslator.init(Cluster cluster) |
void |
IdempotenceAwareRetryPolicy.init(Cluster cluster)
Deprecated.
|
void |
FallthroughRetryPolicy.init(Cluster cluster) |
void |
ExponentialReconnectionPolicy.init(Cluster cluster) |
void |
EC2MultiRegionAddressTranslator.init(Cluster cluster) |
void |
DowngradingConsistencyRetryPolicy.init(Cluster cluster) |
void |
DefaultRetryPolicy.init(Cluster cluster) |
void |
ConstantSpeculativeExecutionPolicy.init(Cluster cluster) |
void |
ConstantReconnectionPolicy.init(Cluster cluster) |
void |
AddressTranslator.init(Cluster cluster)
Initializes this address translator.
|
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 |
ErrorAwarePolicy.init(Cluster cluster,
Collection<Host> hosts) |
void |
DCAwareRoundRobinPolicy.init(Cluster cluster,
Collection<Host> hosts) |