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.
|
com.datastax.driver.dse |
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 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 |
---|---|
void |
SchemaChangeListener.onRegister(Cluster cluster)
Gets invoked when the listener is registered with a cluster.
|
void |
QueryLogger.onRegister(Cluster cluster) |
void |
PerHostPercentileTracker.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 |
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 |
PerHostPercentileTracker.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.
|
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) |
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 |
DCAwareRoundRobinPolicy.init(Cluster cluster,
Collection<Host> hosts) |
Modifier and Type | Class and Description |
---|---|
class |
DseCluster
Information and known state of a DSE cluster.
|
Modifier and Type | Method and Description |
---|---|
protected Cluster |
DseCluster.delegate() |
Modifier and Type | Method and Description |
---|---|
void |
LoggingIdempotenceAwareRetryPolicy.init(Cluster cluster) |
void |
DseLoadBalancingPolicy.init(Cluster cluster,
Collection<Host> hosts) |