Cluster.Builder |
Cluster.Builder.addContactPoint(EndPoint contactPoint) |
Adds a contact point using the given connection information.
|
Cluster.Builder |
Cluster.Builder.addContactPoint(String address) |
Adds a contact point - or many if the given address resolves to multiple InetAddress
s (A records).
|
Cluster.Builder |
Cluster.Builder.addContactPoints(String... addresses) |
Adds contact points.
|
Cluster.Builder |
Cluster.Builder.addContactPoints(InetAddress... addresses) |
Adds contact points.
|
Cluster.Builder |
Cluster.Builder.addContactPoints(Collection<InetAddress> addresses) |
Adds contact points.
|
Cluster.Builder |
Cluster.Builder.addContactPointsWithPorts(InetSocketAddress... addresses) |
Adds contact points.
|
Cluster.Builder |
Cluster.Builder.addContactPointsWithPorts(Collection<InetSocketAddress> addresses) |
Adds contact points.
|
Cluster.Builder |
Cluster.Builder.allowBetaProtocolVersion() |
Create cluster connection using latest development protocol version, which is currently in
beta.
|
static Cluster.Builder |
Cluster.builder() |
|
Cluster.Builder |
Cluster.Builder.withAddressTranslator(AddressTranslator translator) |
Configures the address translator to use for the new cluster.
|
Cluster.Builder |
Cluster.Builder.withApplicationInfo(ApplicationInfo applicationInfo) |
Sets application information provider, every connection on startup sends this information to
the server.
|
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.withDriverConfigReporting(boolean enabled) |
Enables or disables driver configuration reporting, i.e. whether the control connection sends
a DRIVER_CONFIG JSON blob describing the effective driver configuration in its
startup options.
|
Cluster.Builder |
Cluster.Builder.withEndPointFactory(EndPointFactory endPointFactory) |
Configures the endpoint factory to use for the new cluster.
|
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.withLocalPortRange(int low,
int high) |
Sets local port range for use by advanced shard awareness.
|
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) |
|
Cluster.Builder |
Cluster.Builder.withNoCompact() |
Enables the NO_COMPACT startup option.
|
Cluster.Builder |
Cluster.Builder.withoutAdvancedShardAwareness() |
Disables advanced shard awareness.
|
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.withoutPagingInSchemaQueries() |
Disables paging in schema queries.
|
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.withThreadingOptions(ThreadingOptions options) |
Sets the threading options to use for the newly created Cluster.
|
Cluster.Builder |
Cluster.Builder.withTimestampGenerator(TimestampGenerator timestampGenerator) |
Configures the generator that will produce the client-side timestamp sent with each query.
|