| Package | Description |
|---|---|
| com.datastax.driver.core |
The main package for the DataStax Java driver for Cassandra.
|
| com.datastax.driver.dse |
| Modifier and Type | Method and Description |
|---|---|
Cluster.Builder |
Cluster.Builder.addContactPoint(String address)
Adds a contact point - or many if it host resolves to multiple
InetAddresss (A records). |
Cluster.Builder |
Cluster.Builder.addContactPoints(Collection<InetAddress> addresses)
Adds contact points.
|
Cluster.Builder |
Cluster.Builder.addContactPoints(InetAddress... addresses)
Adds contact points.
|
Cluster.Builder |
Cluster.Builder.addContactPoints(String... addresses)
Adds contact points.
|
Cluster.Builder |
Cluster.Builder.addContactPointsWithPorts(Collection<InetSocketAddress> addresses)
Adds contact points.
|
Cluster.Builder |
Cluster.Builder.addContactPointsWithPorts(InetSocketAddress... addresses)
Adds contact points.
|
static Cluster.Builder |
Cluster.builder()
Creates a new
Cluster.Builder instance. |
Cluster.Builder |
Cluster.Builder.withAddressTranslator(AddressTranslator translator)
Configures the address translator to use for the new cluster.
|
Cluster.Builder |
Cluster.Builder.withAuthProvider(AuthProvider authProvider)
Use the specified AuthProvider when connecting to Cassandra
hosts.
|
Cluster.Builder |
Cluster.Builder.withClusterName(String name)
An optional name for the create cluster.
|
Cluster.Builder |
Cluster.Builder.withCodecRegistry(CodecRegistry codecRegistry)
Configures the
CodecRegistry instance to use for the new cluster. |
Cluster.Builder |
Cluster.Builder.withCompression(ProtocolOptions.Compression compression)
Sets the compression to use for the transport.
|
Cluster.Builder |
Cluster.Builder.withCredentials(String username,
String password)
Uses the provided credentials when connecting to Cassandra hosts.
|
Cluster.Builder |
Cluster.Builder.withInitialListeners(Collection<Host.StateListener> listeners)
Register the provided listeners in the newly created cluster.
|
Cluster.Builder |
Cluster.Builder.withLoadBalancingPolicy(LoadBalancingPolicy policy)
Configures the load balancing policy to use for the new cluster.
|
Cluster.Builder |
Cluster.Builder.withMaxSchemaAgreementWaitSeconds(int maxSchemaAgreementWaitSeconds)
Sets the maximum time to wait for schema agreement before returning from a DDL query.
|
Cluster.Builder |
Cluster.Builder.withNettyOptions(NettyOptions nettyOptions)
Set the
NettyOptions to use for the newly created Cluster. |
Cluster.Builder |
Cluster.Builder.withoutJMXReporting()
Disables JMX reporting of the metrics.
|
Cluster.Builder |
Cluster.Builder.withoutMetrics()
Disables metrics collection for the created cluster (metrics are
enabled by default otherwise).
|
Cluster.Builder |
Cluster.Builder.withPoolingOptions(PoolingOptions options)
Sets the PoolingOptions to use for the newly created Cluster.
|
Cluster.Builder |
Cluster.Builder.withPort(int port)
The port to use to connect to the Cassandra host.
|
Cluster.Builder |
Cluster.Builder.withProtocolVersion(ProtocolVersion version)
The native protocol version to use.
|
Cluster.Builder |
Cluster.Builder.withQueryOptions(QueryOptions options)
Sets the QueryOptions to use for the newly created Cluster.
|
Cluster.Builder |
Cluster.Builder.withReconnectionPolicy(ReconnectionPolicy policy)
Configures the reconnection policy to use for the new cluster.
|
Cluster.Builder |
Cluster.Builder.withRetryPolicy(RetryPolicy policy)
Configures the retry policy to use for the new cluster.
|
Cluster.Builder |
Cluster.Builder.withSocketOptions(SocketOptions options)
Sets the SocketOptions to use for the newly created Cluster.
|
Cluster.Builder |
Cluster.Builder.withSpeculativeExecutionPolicy(SpeculativeExecutionPolicy policy)
Configures the speculative execution policy to use for the new cluster.
|
Cluster.Builder |
Cluster.Builder.withSSL()
Enables the use of SSL for the created
Cluster. |
Cluster.Builder |
Cluster.Builder.withSSL(SSLOptions sslOptions)
Enable the use of SSL for the created
Cluster using the provided options. |
Cluster.Builder |
Cluster.Builder.withTimestampGenerator(TimestampGenerator timestampGenerator)
Configures the generator that will produce the client-side timestamp sent
with each query.
|
| Modifier and Type | Class and Description |
|---|---|
static class |
DseCluster.Builder
Helper class to build
DseCluster instances. |