Click or drag to resize

Builder Class

Helper class to build Cluster instances.
Inheritance Hierarchy
SystemObject
  CassandraBuilder

Namespace:  Cassandra
Assembly:  Cassandra (in Cassandra.dll) Version: 3.10.0
Syntax
C#
public class Builder : IInitializer

The Builder type exposes the following members.

Constructors
  NameDescription
Public methodBuilder
Initializes a new instance of the Builder class
Top
Properties
  NameDescription
Public propertyContactPoints
Gets the contact points that were added as IPEndPoint" instances.

Note that only contact points that were added using AddContactPoint(IPEndPoint) and AddContactPoints(IPEndPoint) are returned by this property, as IP addresses and host names must be resolved and assigned the port number, which is performed on Build.

Public propertyPoolingOptions
The pooling options used by this builder.
Public propertySocketOptions
The socket options used by this builder.
Top
Methods
  NameDescription
Public methodAddContactPoint(IPAddress)
Add contact point. See AddContactPoint(String) for more details on contact points.
Public methodAddContactPoint(IPEndPoint)
Add contact point. See AddContactPoint(String) for more details on contact points.
Public methodAddContactPoint(String)
Adds a contact point. Contact points are addresses of Cassandra nodes that the driver uses to discover the cluster topology. Only one contact point is required (the driver will retrieve the address of the other nodes automatically), but it is usually a good idea to provide more than one contact point, as if that unique contact point is not available, the driver won't be able to initialize itself correctly.
Public methodAddContactPoints(IEnumerableIPAddress)
Add contact points. See Builder.AddContactPoint for more details on contact points.
Public methodAddContactPoints(IEnumerableIPEndPoint)
Add contact points. See Builder.AddContactPoint for more details on contact points.
Public methodAddContactPoints(IEnumerableString)
Add contact points. See Builder.AddContactPoint for more details on contact points.
Public methodAddContactPoints(IPAddress)
Add contact points. See Builder.AddContactPoint for more details on contact points.
Public methodAddContactPoints(IPEndPoint)
Add contact points. See Builder.AddContactPoint for more details on contact points.
Public methodAddContactPoints(String)
Add contact points. See AddContactPoint(String) for more details on contact points.
Public methodBuild
Build the cluster with the configured set of initial contact points and policies.
Public methodGetConfiguration
The configuration that will be used for the new cluster.

You should not modify this object directly as change made to the returned object may not be used by the cluster build. Instead, you should use the other methods of this Builder

.
Public methodWithAddressTranslator
Configures the address translater to use for the new cluster.
Public methodWithAuthProvider
Use the specified AuthProvider when connecting to Cassandra hosts.

Use this method when a custom authentication scheme is in place. You shouldn't call both this method and {@code withCredentials}' on the same Builder instance as one will supersede the other

Public methodWithCompression
Sets the compression to use for the transport.
Public methodWithConnectionString
Configure the cluster by applying settings from ConnectionString.
Public methodWithCredentials
Uses the provided credentials when connecting to Cassandra hosts.

This should be used if the Cassandra cluster has been configured to use the PasswordAuthenticator. If the the default * AllowAllAuthenticator is used instead, using this method has no effect.

Public methodWithCustomCompressor
Sets a custom compressor to be used for the compression type. If specified, the compression type is mandatory. If not specified the driver default compressor will be use for the compression type.
Public methodWithDefaultKeyspace
Sets default keyspace name for the created cluster.
Public methodWithExecutionProfiles

Adds Execution Profiles to the Cluster instance.

Execution profiles are like configuration presets, multiple methods of the driver accept an execution profile name which is like telling the driver which settings to use for that particular request. This makes it easier to change settings like ConsistencyLevel and ReadTimeoutMillis on a per request basis.

Note that subsequent calls to this method will override the previously provided profiles.

To add execution profiles you can use WithProfile(String, ActionIExecutionProfileBuilder):

Cluster.Builder()
        .WithExecutionProfiles(options => options
            .WithProfile("profile1", profileBuilder => profileBuilder
                .WithReadTimeoutMillis(10000)
                .WithConsistencyLevel(ConsistencyLevel.LocalQuorum)))
        .Build()

Public methodWithLoadBalancingPolicy
Configure the load balancing policy to use for the new cluster.

If no load balancing policy is set through this method, Policies.DefaultLoadBalancingPolicy will be used instead.

Public methodWithMaxProtocolVersion(Byte)

Limits the maximum protocol version used to connect to the nodes

When it is not set, the protocol version used is negotiated between the driver and the Cassandra cluster upon establishing the first connection.

Useful when connecting to a cluster that contains nodes with different major/minor versions of Cassandra. For example, preparing for a rolling upgrade of the Cluster.

Public methodWithMaxProtocolVersion(ProtocolVersion)

Limits the maximum protocol version used to connect to the nodes

When it is not set, the protocol version used is negotiated between the driver and the Cassandra cluster upon establishing the first connection.

Useful when connecting to a cluster that contains nodes with different major/minor versions of Cassandra. For example, preparing for a rolling upgrade of the Cluster.

Public methodWithMaxSchemaAgreementWaitSeconds
Sets the maximum time to wait for schema agreement before returning from a DDL query.

DDL queries introduce schema changes that need to be propagated to all nodes in the cluster. Once they have settled on a common version, we say that they are in agreement.

If not set through this method, the default value (10 seconds) will be used.

Public methodWithMetadataSyncOptions

If not set through this method, the default value options will be used (metadata synchronization is enabled by default). The api reference of MetadataSyncOptions specifies what is the default for each option.

In case you disable Metadata synchronization, please ensure you invoke RefreshSchemaAsync(String, String) in order to keep the token metadata up to date otherwise you will not be getting everything you can out of token aware routing, i.e. TokenAwarePolicy, which is enabled by the default.

Disabling this feature has the following impact:

  • Token metadata will not be computed and stored. This means that token aware routing (TokenAwarePolicy, enabled by default) will only work correctly if you keep the token metadata up to date using the RefreshSchemaAsync(String, String) method. If you wish to go this route of manually refreshing the metadata then it's recommended to refresh only the keyspaces that this application will use, by passing the
    keyspace
    parameter.
  • Keyspace metadata will not be cached by the driver. Every time you call methods like GetTable(String, String), GetKeyspace(String) and other similar methods of the Metadata class, the driver will query that data on demand and will not cache it.
  • The driver will not handle
    SCHEMA_CHANGED
    responses. This means that when you execute schema changing statements through the driver, it will not update the schema or topology metadata automatically before returning.

Public methodWithNoCompact
Enables the NO_COMPACT startup option.

When this option is set, SELECT, UPDATE, DELETE, and BATCH statements on COMPACT STORAGE tables function in "compatibility" mode which allows seeing these tables as if they were "regular" CQL tables.

This option only affects interactions with tables using COMPACT STORAGE and it is only supported by C* 3.0.16+, 3.11.2+, 4.0+ and DSE 6.0+.

Public methodWithoutRowSetBuffering
Disables row set buffering for the created cluster (row set buffering is enabled by default otherwise).
Public methodWithPoolingOptions
Public methodWithPort
The port to use to connect to all Cassandra hosts. If not set through this method, the default port (9042) will be used instead.
Public methodWithQueryOptions
Sets the QueryOptions to use for the newly created Cluster. If no query options are set through this method, default query options will be used.
Public methodWithQueryTimeout
Specifies the number of milliseconds that the driver should wait for the response before the query times out in a synchronous operation.

This will cause that synchronous operations like Execute(String) to throw a TimeoutException after the specified number of milliseconds.

Default timeout value is set to
20,000
(20 seconds).
Public methodWithReconnectionPolicy
Configure the reconnection policy to use for the new cluster.

If no reconnection policy is set through this method, Policies.DefaultReconnectionPolicy will be used instead.

Public methodWithRetryPolicy
Configure the retry policy to be used for the new cluster.

When the retry policy is not set with this method, the DefaultRetryPolicy will be used instead.

Use a IExtendedRetryPolicy implementation to cover all error scenarios.

Public methodWithSocketOptions
Configures the socket options that are going to be used to create the connections to the hosts.
Public methodWithSpeculativeExecutionPolicy
Configure the speculative execution to use for the new cluster.

If no speculative execution policy is set through this method, DefaultSpeculativeExecutionPolicy will be used instead.

Public methodWithSSL
Enables the use of SSL for the created Cluster. Calling this method will use default SSL options.
Public methodWithSSL(SSLOptions)
Enables the use of SSL for the created Cluster using the provided options.
Public methodWithTimestampGenerator
Configures the generator that will produce the client-side timestamp sent with each query.

This feature is only available with protocol version 3 or above of the native protocol. With earlier versions, timestamps are always generated server-side, and setting a generator through this method will have no effect.

If no generator is set through this method, the driver will default to client-side timestamps by using AtomicMonotonicTimestampGenerator.

Public methodWithTypeSerializers
Top
See Also