Package org.synchronoss.cpo.cassandra

Class ClusterDataSourceInfo

java.lang.Object
org.synchronoss.cpo.core.AbstractDataSourceInfo<ClusterDataSource>
org.synchronoss.cpo.cassandra.ClusterDataSourceInfo
All Implemented Interfaces:
DataSourceInfo<ClusterDataSource>
public class ClusterDataSourceInfo extends AbstractDataSourceInfo<ClusterDataSource>
Contains the information needed to connect to a Cassandra cluster
Author:
dberry

  • Constructor Details

    • ClusterDataSourceInfo

      public ClusterDataSourceInfo(String clusterName, String keySpace, List<String> contactPoints, int fetchSize, int batchSize)
      Constructs a ClusterDataSourceInfo
      Parameters:
      clusterName - The cluster name
      keySpace - The keyspace
      contactPoints - The contact points
      fetchSize - the number of rows to fetch per round trip on a retrieve
      batchSize - the number of statements to batch together before executing

  • Method Details

    • getMaxSchemaAgreementWaitSeconds

      public Integer getMaxSchemaAgreementWaitSeconds()
      Get the MaxSchemaAgreementWaitSeconds setting
      Returns:
      The MaxSchemaAgreementWaitSeconds

    • setMaxSchemaAgreementWaitSeconds

      public void setMaxSchemaAgreementWaitSeconds(Integer maxSchemaAgreementWaitSeconds)
      Set the MaxSchemaAgreementWaitSeconds setting
      Parameters:
      maxSchemaAgreementWaitSeconds - The MaxSchemaAgreementWaitSeconds

    • getSchemaAgreementIntervalMillis

      public Long getSchemaAgreementIntervalMillis()
      Get the schema agreement check interval, in milliseconds
      Returns:
      the schema agreement check interval in milliseconds

    • setSchemaAgreementIntervalMillis

      public void setSchemaAgreementIntervalMillis(Long schemaAgreementIntervalMillis)
      Set the schema agreement check interval, in milliseconds
      Parameters:
      schemaAgreementIntervalMillis - the schema agreement check interval in milliseconds

    • getSchemaAgreementWarnOnFailure

      public Boolean getSchemaAgreementWarnOnFailure()
      Get whether a warning is logged if schema agreement fails
      Returns:
      the schemaAgreementWarnOnFailure flag

    • setSchemaAgreementWarnOnFailure

      public void setSchemaAgreementWarnOnFailure(Boolean schemaAgreementWarnOnFailure)
      Set whether a warning is logged if schema agreement fails
      Parameters:
      schemaAgreementWarnOnFailure - the schemaAgreementWarnOnFailure flag

    • getControlConnectionTimeoutMillis

      public Long getControlConnectionTimeoutMillis()
      Get the control connection timeout, in milliseconds
      Returns:
      the control connection timeout in milliseconds

    • setControlConnectionTimeoutMillis

      public void setControlConnectionTimeoutMillis(Long controlConnectionTimeoutMillis)
      Set the control connection timeout, in milliseconds
      Parameters:
      controlConnectionTimeoutMillis - the control connection timeout in milliseconds

    • getAddressTranslatorClassName

      public String getAddressTranslatorClassName()
      Get the AddressTranslator implementation class name
      Returns:
      The fully qualified AddressTranslator implementation class name

    • setAddressTranslatorClassName

      public void setAddressTranslatorClassName(String addressTranslatorClassName)
      Set the AddressTranslator implementation class name. The driver instantiates this class itself via a (DriverContext) constructor.
      Parameters:
      addressTranslatorClassName - The fully qualified AddressTranslator implementation class name

    • getAddressTranslatorAdvertisedHostname

      public String getAddressTranslatorAdvertisedHostname()
      Get the advertised hostname used by FixedHostNameAddressTranslator
      Returns:
      the advertised hostname

    • setAddressTranslatorAdvertisedHostname

      public void setAddressTranslatorAdvertisedHostname(String addressTranslatorAdvertisedHostname)
      Set the advertised hostname used by FixedHostNameAddressTranslator
      Parameters:
      addressTranslatorAdvertisedHostname - the advertised hostname

    • getAddressTranslatorDefaultAddress

      public String getAddressTranslatorDefaultAddress()
      Get the default address used by SubnetAddressTranslator when no subnet matches
      Returns:
      the default address

    • setAddressTranslatorDefaultAddress

      public void setAddressTranslatorDefaultAddress(String addressTranslatorDefaultAddress)
      Set the default address used by SubnetAddressTranslator when no subnet matches
      Parameters:
      addressTranslatorDefaultAddress - the default address

    • getAddressTranslatorResolveAddresses

      public Boolean getAddressTranslatorResolveAddresses()
      Get whether addresses are resolved once at initialization (true) or on each reconnection (false)
      Returns:
      the addressTranslatorResolveAddresses flag

    • setAddressTranslatorResolveAddresses

      public void setAddressTranslatorResolveAddresses(Boolean addressTranslatorResolveAddresses)
      Set whether addresses are resolved once at initialization (true) or on each reconnection (false)
      Parameters:
      addressTranslatorResolveAddresses - the addressTranslatorResolveAddresses flag

    • getAddressTranslatorSubnetAddresses

      public Map<String,String> getAddressTranslatorSubnetAddresses()
      Get the CIDR-to-"host:port" map used by SubnetAddressTranslator
      Returns:
      the subnet address map

    • setAddressTranslatorSubnetAddresses

      public void setAddressTranslatorSubnetAddresses(Map<String,String> addressTranslatorSubnetAddresses)
      Set the CIDR-to-"host:port" map used by SubnetAddressTranslator
      Parameters:
      addressTranslatorSubnetAddresses - the subnet address map

    • getClusterName

      public String getClusterName()
      Get the cluster name
      Returns:
      The cluster name

    • setClusterName

      public void setClusterName(String clusterName)
      Set the cluster name. Wired to the driver's session name (basic.session-name / SESSION_NAME), used as a log/metrics prefix, in addition to being used for the CPO datasource display name.
      Parameters:
      clusterName - The cluster name

    • getKeySpace

      public String getKeySpace()
      Get the keyspace name
      Returns:
      The keyspace name

    • getLocalDatacenter

      public String getLocalDatacenter()
      Get the local datacenter, required by the driver's default load balancing policy whenever contact points are supplied.
      Returns:
      The local datacenter name

    • setLocalDatacenter

      public void setLocalDatacenter(String localDatacenter)
      Set the local datacenter
      Parameters:
      localDatacenter - The local datacenter name

    • getApplicationName

      public String getApplicationName()
      Get the application name sent in the STARTUP protocol message
      Returns:
      the application name

    • setApplicationName

      public void setApplicationName(String applicationName)
      Set the application name sent in the STARTUP protocol message
      Parameters:
      applicationName - the application name

    • getApplicationVersion

      public String getApplicationVersion()
      Get the application version sent in the STARTUP protocol message
      Returns:
      the application version

    • setApplicationVersion

      public void setApplicationVersion(String applicationVersion)
      Set the application version sent in the STARTUP protocol message
      Parameters:
      applicationVersion - the application version

    • getPort

      public int getPort()
      Get the port number
      Returns:
      The port number

    • setPort

      public void setPort(int port)
      Set the port number
      Parameters:
      port - The port number

    • getRequestTimeoutMillis

      public Long getRequestTimeoutMillis()
      Get the global request timeout, in milliseconds
      Returns:
      the request timeout in milliseconds

    • setRequestTimeoutMillis

      public void setRequestTimeoutMillis(Long requestTimeoutMillis)
      Set the global request timeout, in milliseconds
      Parameters:
      requestTimeoutMillis - the request timeout in milliseconds

    • getLoadBalancingPolicyClassName

      public String getLoadBalancingPolicyClassName()
      Get the LoadBalancingPolicy implementation class name
      Returns:
      The fully qualified LoadBalancingPolicy implementation class name

    • setLoadBalancingPolicyClassName

      public void setLoadBalancingPolicyClassName(String loadBalancingPolicyClassName)
      Set the LoadBalancingPolicy implementation class name. The driver instantiates this class itself via a (DriverContext, String profileName) constructor.
      Parameters:
      loadBalancingPolicyClassName - The fully qualified LoadBalancingPolicy implementation class name

    • getLoadBalancingSlowReplicaAvoidance

      public Boolean getLoadBalancingSlowReplicaAvoidance()
      Get whether slow-replica avoidance is enabled on the default load balancing policy
      Returns:
      the loadBalancingSlowReplicaAvoidance flag

    • setLoadBalancingSlowReplicaAvoidance

      public void setLoadBalancingSlowReplicaAvoidance(Boolean loadBalancingSlowReplicaAvoidance)
      Set whether slow-replica avoidance is enabled on the default load balancing policy
      Parameters:
      loadBalancingSlowReplicaAvoidance - the loadBalancingSlowReplicaAvoidance flag

    • getLoadBalancingDistanceEvaluatorClassName

      public String getLoadBalancingDistanceEvaluatorClassName()
      Get the custom NodeDistanceEvaluator implementation class name
      Returns:
      the fully qualified NodeDistanceEvaluator implementation class name

    • setLoadBalancingDistanceEvaluatorClassName

      public void setLoadBalancingDistanceEvaluatorClassName(String loadBalancingDistanceEvaluatorClassName)
      Set the custom NodeDistanceEvaluator implementation class name. The driver instantiates this class itself via a (DriverContext, String profileName) constructor.
      Parameters:
      loadBalancingDistanceEvaluatorClassName - the fully qualified NodeDistanceEvaluator implementation class name

    • getDcFailoverMaxNodesPerRemoteDc

      public Integer getDcFailoverMaxNodesPerRemoteDc()
      Get the maximum number of nodes to contact in each remote datacenter for cross-DC failover
      Returns:
      the max nodes per remote datacenter

    • setDcFailoverMaxNodesPerRemoteDc

      public void setDcFailoverMaxNodesPerRemoteDc(Integer dcFailoverMaxNodesPerRemoteDc)
      Set the maximum number of nodes to contact in each remote datacenter for cross-DC failover
      Parameters:
      dcFailoverMaxNodesPerRemoteDc - the max nodes per remote datacenter

    • getDcFailoverAllowForLocalConsistencyLevels

      public Boolean getDcFailoverAllowForLocalConsistencyLevels()
      Get whether cross-DC failover is allowed for local consistency levels
      Returns:
      the dcFailoverAllowForLocalConsistencyLevels flag

    • setDcFailoverAllowForLocalConsistencyLevels

      public void setDcFailoverAllowForLocalConsistencyLevels(Boolean dcFailoverAllowForLocalConsistencyLevels)
      Set whether cross-DC failover is allowed for local consistency levels
      Parameters:
      dcFailoverAllowForLocalConsistencyLevels - the dcFailoverAllowForLocalConsistencyLevels flag

    • getDcFailoverPreferredRemoteDcs

      public List<String> getDcFailoverPreferredRemoteDcs()
      Get the ordered list of preferred remote datacenters for cross-DC failover
      Returns:
      the preferred remote datacenters

    • setDcFailoverPreferredRemoteDcs

      public void setDcFailoverPreferredRemoteDcs(List<String> dcFailoverPreferredRemoteDcs)
      Set the ordered list of preferred remote datacenters for cross-DC failover
      Parameters:
      dcFailoverPreferredRemoteDcs - the preferred remote datacenters

    • getReconnectionPolicyClassName

      public String getReconnectionPolicyClassName()
      Get the ReconnectionPolicy implementation class name
      Returns:
      The fully qualified ReconnectionPolicy implementation class name

    • setReconnectionPolicyClassName

      public void setReconnectionPolicyClassName(String reconnectionPolicyClassName)
      Set the ReconnectionPolicy implementation class name. The driver instantiates this class itself via a (DriverContext) constructor.
      Parameters:
      reconnectionPolicyClassName - The fully qualified ReconnectionPolicy implementation class name

    • getReconnectionBaseDelayMillis

      public Long getReconnectionBaseDelayMillis()
      Get the base reconnection delay, in milliseconds
      Returns:
      the base delay in milliseconds

    • setReconnectionBaseDelayMillis

      public void setReconnectionBaseDelayMillis(Long reconnectionBaseDelayMillis)
      Set the base reconnection delay, in milliseconds
      Parameters:
      reconnectionBaseDelayMillis - the base delay in milliseconds

    • getReconnectionMaxDelayMillis

      public Long getReconnectionMaxDelayMillis()
      Get the maximum reconnection delay, in milliseconds
      Returns:
      the max delay in milliseconds

    • setReconnectionMaxDelayMillis

      public void setReconnectionMaxDelayMillis(Long reconnectionMaxDelayMillis)
      Set the maximum reconnection delay, in milliseconds
      Parameters:
      reconnectionMaxDelayMillis - the max delay in milliseconds

    • getReconnectOnInit

      public Boolean getReconnectOnInit()
      Get whether reconnection is attempted if all contact points are unreachable on first init
      Returns:
      the reconnectOnInit flag

    • setReconnectOnInit

      public void setReconnectOnInit(Boolean reconnectOnInit)
      Set whether reconnection is attempted if all contact points are unreachable on first init
      Parameters:
      reconnectOnInit - the reconnectOnInit flag

    • getRetryPolicyClassName

      public String getRetryPolicyClassName()
      Get the RetryPolicy implementation class name
      Returns:
      The fully qualified RetryPolicy implementation class name

    • setRetryPolicyClassName

      public void setRetryPolicyClassName(String retryPolicyClassName)
      Set the RetryPolicy implementation class name. The driver instantiates this class itself via a (DriverContext, String profileName) constructor.
      Parameters:
      retryPolicyClassName - The fully qualified RetryPolicy implementation class name

    • hasCredentials

      public boolean hasCredentials()
      Has Credentials
      Returns:
      hasCredentials

    • setHasCredentials

      public void setHasCredentials(boolean credentials)
      Set hasCredentials
      Parameters:
      credentials - hasCredentials

    • getUserName

      public String getUserName()
      Get the username
      Returns:
      The username

    • setUserName

      public void setUserName(String userName)
      Set the username
      Parameters:
      userName - The username

    • getPassword

      public String getPassword()
      Get the password
      Returns:
      The password

    • setPassword

      public void setPassword(String password)
      Set the password
      Parameters:
      password - - The password

    • getAuthProvider

      public com.datastax.oss.driver.api.core.auth.AuthProvider getAuthProvider()
      Get the AuthProvider
      Returns:
      - The AuthProvider

    • setAuthProvider

      public void setAuthProvider(com.datastax.oss.driver.api.core.auth.AuthProvider authProvider)
      Set the AuthProvider
      Parameters:
      authProvider - - The AuthProvider

    • getCompressionType

      public String getCompressionType()
      Get the compression type
      Returns:
      - the protocol compression name ("lz4", "snappy", or "none")

    • setCompressionType

      public void setCompressionType(String compressionType)
      Set the compression type
      Parameters:
      compressionType - - the protocol compression name ("lz4", "snappy", or "none")

    • getProtocolMaxFrameLengthBytes

      public Long getProtocolMaxFrameLengthBytes()
      Get the protocol maximum frame length, in bytes
      Returns:
      the max frame length in bytes

    • setProtocolMaxFrameLengthBytes

      public void setProtocolMaxFrameLengthBytes(Long protocolMaxFrameLengthBytes)
      Set the protocol maximum frame length, in bytes
      Parameters:
      protocolMaxFrameLengthBytes - the max frame length in bytes

    • getSslEngineFactory

      public com.datastax.oss.driver.api.core.ssl.SslEngineFactory getSslEngineFactory()
      Get the SslEngineFactory
      Returns:
      - The SslEngineFactory

    • setSslEngineFactory

      public void setSslEngineFactory(com.datastax.oss.driver.api.core.ssl.SslEngineFactory sslEngineFactory)
      Set the SslEngineFactory
      Parameters:
      sslEngineFactory - - The SslEngineFactory

    • getSslCipherSuites

      public List<String> getSslCipherSuites()
      Get the cipher suites enabled for the default SSL engine factory
      Returns:
      the cipher suites

    • setSslCipherSuites

      public void setSslCipherSuites(List<String> sslCipherSuites)
      Set the cipher suites enabled for the default SSL engine factory
      Parameters:
      sslCipherSuites - the cipher suites

    • getSslHostnameValidation

      public Boolean getSslHostnameValidation()
      Get whether server certificate hostname validation is enabled
      Returns:
      the sslHostnameValidation flag

    • setSslHostnameValidation

      public void setSslHostnameValidation(Boolean sslHostnameValidation)
      Set whether server certificate hostname validation is enabled
      Parameters:
      sslHostnameValidation - the sslHostnameValidation flag

    • getSslAllowDnsReverseLookupSan

      public Boolean getSslAllowDnsReverseLookupSan()
      Get whether a DNS reverse lookup is allowed for SAN addresses
      Returns:
      the sslAllowDnsReverseLookupSan flag

    • setSslAllowDnsReverseLookupSan

      public void setSslAllowDnsReverseLookupSan(Boolean sslAllowDnsReverseLookupSan)
      Set whether a DNS reverse lookup is allowed for SAN addresses
      Parameters:
      sslAllowDnsReverseLookupSan - the sslAllowDnsReverseLookupSan flag

    • getSslTruststorePath

      public String getSslTruststorePath()
      Get the truststore path
      Returns:
      the truststore path

    • setSslTruststorePath

      public void setSslTruststorePath(String sslTruststorePath)
      Set the truststore path
      Parameters:
      sslTruststorePath - the truststore path

    • getSslTruststorePassword

      public String getSslTruststorePassword()
      Get the truststore password
      Returns:
      the truststore password

    • setSslTruststorePassword

      public void setSslTruststorePassword(String sslTruststorePassword)
      Set the truststore password
      Parameters:
      sslTruststorePassword - the truststore password

    • getSslKeystorePath

      public String getSslKeystorePath()
      Get the keystore path
      Returns:
      the keystore path

    • setSslKeystorePath

      public void setSslKeystorePath(String sslKeystorePath)
      Set the keystore path
      Parameters:
      sslKeystorePath - the keystore path

    • getSslKeystorePassword

      public String getSslKeystorePassword()
      Get the keystore password
      Returns:
      the keystore password

    • setSslKeystorePassword

      public void setSslKeystorePassword(String sslKeystorePassword)
      Set the keystore password
      Parameters:
      sslKeystorePassword - the keystore password

    • getSslKeystoreReloadIntervalMinutes

      public Long getSslKeystoreReloadIntervalMinutes()
      Get the keystore reload interval, in minutes
      Returns:
      the keystore reload interval in minutes

    • setSslKeystoreReloadIntervalMinutes

      public void setSslKeystoreReloadIntervalMinutes(Long sslKeystoreReloadIntervalMinutes)
      Set the keystore reload interval, in minutes
      Parameters:
      sslKeystoreReloadIntervalMinutes - the keystore reload interval in minutes

    • getListeners

      public Collection<com.datastax.oss.driver.api.core.metadata.NodeStateListener> getListeners()
      Get the NodeStateListeners
      Returns:
      - A collection of NodeStateListeners

    • setListeners

      public void setListeners(Collection<com.datastax.oss.driver.api.core.metadata.NodeStateListener> listeners)
      Set the NodeStateListeners
      Parameters:
      listeners - - A collection of NodeStateListeners

    • getSchemaChangeListeners

      public Collection<com.datastax.oss.driver.api.core.metadata.schema.SchemaChangeListener> getSchemaChangeListeners()
      Get the SchemaChangeListeners
      Returns:
      a collection of SchemaChangeListeners

    • setSchemaChangeListeners

      public void setSchemaChangeListeners(Collection<com.datastax.oss.driver.api.core.metadata.schema.SchemaChangeListener> schemaChangeListeners)
      Set the SchemaChangeListeners
      Parameters:
      schemaChangeListeners - a collection of SchemaChangeListeners

    • getMetricsFactoryClassName

      public String getMetricsFactoryClassName()
      Get the metrics factory class name
      Returns:
      the metrics factory class name

    • setMetricsFactoryClassName

      public void setMetricsFactoryClassName(String metricsFactoryClassName)
      Set the metrics factory class name (e.g. "DefaultMetricsFactory", "MicrometerMetricsFactory", "NoopMetricsFactory", or a fully qualified custom class name)
      Parameters:
      metricsFactoryClassName - the metrics factory class name

    • getMetricsIdGeneratorClassName

      public String getMetricsIdGeneratorClassName()
      Get the metric id generator class name
      Returns:
      the metric id generator class name

    • setMetricsIdGeneratorClassName

      public void setMetricsIdGeneratorClassName(String metricsIdGeneratorClassName)
      Set the metric id generator class name (e.g. "DefaultMetricIdGenerator" or "TaggingMetricIdGenerator")
      Parameters:
      metricsIdGeneratorClassName - the metric id generator class name

    • getMetricsIdGeneratorPrefix

      public String getMetricsIdGeneratorPrefix()
      Get the prefix prepended to every generated metric name
      Returns:
      the metric name prefix

    • setMetricsIdGeneratorPrefix

      public void setMetricsIdGeneratorPrefix(String metricsIdGeneratorPrefix)
      Set the prefix prepended to every generated metric name
      Parameters:
      metricsIdGeneratorPrefix - the metric name prefix

    • getMetricsGenerateAggregableHistograms

      public Boolean getMetricsGenerateAggregableHistograms()
      Get whether aggregable histogram buckets are generated for monitoring systems
      Returns:
      the metricsGenerateAggregableHistograms flag

    • setMetricsGenerateAggregableHistograms

      public void setMetricsGenerateAggregableHistograms(Boolean metricsGenerateAggregableHistograms)
      Set whether aggregable histogram buckets are generated for monitoring systems
      Parameters:
      metricsGenerateAggregableHistograms - the metricsGenerateAggregableHistograms flag

    • getMetricsSessionEnabled

      public List<String> getMetricsSessionEnabled()
      Get the session-level metric names to enable
      Returns:
      the enabled session metric names

    • setMetricsSessionEnabled

      public void setMetricsSessionEnabled(List<String> metricsSessionEnabled)
      Set the session-level metric names to enable
      Parameters:
      metricsSessionEnabled - the enabled session metric names

    • getMetricsNodeEnabled

      public List<String> getMetricsNodeEnabled()
      Get the node-level metric names to enable
      Returns:
      the enabled node metric names

    • setMetricsNodeEnabled

      public void setMetricsNodeEnabled(List<String> metricsNodeEnabled)
      Set the node-level metric names to enable
      Parameters:
      metricsNodeEnabled - the enabled node metric names

    • getMetricsNodeExpireAfterMinutes

      public Long getMetricsNodeExpireAfterMinutes()
      Get how long a node's metrics are kept registered after it leaves the cluster, in minutes
      Returns:
      the node metric expiry in minutes

    • setMetricsNodeExpireAfterMinutes

      public void setMetricsNodeExpireAfterMinutes(Long metricsNodeExpireAfterMinutes)
      Set how long a node's metrics are kept registered after it leaves the cluster, in minutes
      Parameters:
      metricsNodeExpireAfterMinutes - the node metric expiry in minutes

    • getMetricsSessionCqlRequests

      public HistogramOptions getMetricsSessionCqlRequests()
      Get the histogram tuning for the session "cql-requests" metric
      Returns:
      the histogram options

    • setMetricsSessionCqlRequests

      public void setMetricsSessionCqlRequests(HistogramOptions metricsSessionCqlRequests)
      Set the histogram tuning for the session "cql-requests" metric
      Parameters:
      metricsSessionCqlRequests - the histogram options

    • getMetricsSessionThrottlingDelay

      public HistogramOptions getMetricsSessionThrottlingDelay()
      Get the histogram tuning for the session "throttling.delay" metric
      Returns:
      the histogram options

    • setMetricsSessionThrottlingDelay

      public void setMetricsSessionThrottlingDelay(HistogramOptions metricsSessionThrottlingDelay)
      Set the histogram tuning for the session "throttling.delay" metric
      Parameters:
      metricsSessionThrottlingDelay - the histogram options

    • getMetricsNodeCqlMessages

      public HistogramOptions getMetricsNodeCqlMessages()
      Get the histogram tuning for the node "cql-messages" metric
      Returns:
      the histogram options

    • setMetricsNodeCqlMessages

      public void setMetricsNodeCqlMessages(HistogramOptions metricsNodeCqlMessages)
      Set the histogram tuning for the node "cql-messages" metric
      Parameters:
      metricsNodeCqlMessages - the histogram options

    • getConnectionPoolLocalSize

      public Integer getConnectionPoolLocalSize()
      Get the local connection pool size
      Returns:
      - the local connection pool size

    • setConnectionPoolLocalSize

      public void setConnectionPoolLocalSize(Integer connectionPoolLocalSize)
      Set the local connection pool size
      Parameters:
      connectionPoolLocalSize - - the local connection pool size

    • getConnectionPoolRemoteSize

      public Integer getConnectionPoolRemoteSize()
      Get the remote connection pool size
      Returns:
      - the remote connection pool size

    • setConnectionPoolRemoteSize

      public void setConnectionPoolRemoteSize(Integer connectionPoolRemoteSize)
      Set the remote connection pool size
      Parameters:
      connectionPoolRemoteSize - - the remote connection pool size

    • getHeartbeatIntervalSeconds

      public Integer getHeartbeatIntervalSeconds()
      Get the heartbeat interval, in seconds
      Returns:
      - the heartbeat interval in seconds

    • setHeartbeatIntervalSeconds

      public void setHeartbeatIntervalSeconds(Integer heartbeatIntervalSeconds)
      Set the heartbeat interval, in seconds
      Parameters:
      heartbeatIntervalSeconds - - the heartbeat interval in seconds

    • getHeartbeatTimeoutSeconds

      public Integer getHeartbeatTimeoutSeconds()
      Get the heartbeat response timeout, in seconds
      Returns:
      the heartbeat timeout in seconds

    • setHeartbeatTimeoutSeconds

      public void setHeartbeatTimeoutSeconds(Integer heartbeatTimeoutSeconds)
      Set the heartbeat response timeout, in seconds
      Parameters:
      heartbeatTimeoutSeconds - the heartbeat timeout in seconds

    • getConnectInitQueryTimeoutMillis

      public Long getConnectInitQueryTimeoutMillis()
      Get the timeout for internal queries run just after a connection opens, in milliseconds
      Returns:
      the init query timeout in milliseconds

    • setConnectInitQueryTimeoutMillis

      public void setConnectInitQueryTimeoutMillis(Long connectInitQueryTimeoutMillis)
      Set the timeout for internal queries run just after a connection opens, in milliseconds
      Parameters:
      connectInitQueryTimeoutMillis - the init query timeout in milliseconds

    • getSetKeyspaceTimeoutMillis

      public Long getSetKeyspaceTimeoutMillis()
      Get the timeout used when switching keyspace on a connection at runtime, in milliseconds
      Returns:
      the set-keyspace timeout in milliseconds

    • setSetKeyspaceTimeoutMillis

      public void setSetKeyspaceTimeoutMillis(Long setKeyspaceTimeoutMillis)
      Set the timeout used when switching keyspace on a connection at runtime, in milliseconds
      Parameters:
      setKeyspaceTimeoutMillis - the set-keyspace timeout in milliseconds

    • getMaxRequestsPerConnection

      public Integer getMaxRequestsPerConnection()
      Get the maximum number of requests that can execute concurrently on a single connection
      Returns:
      the max requests per connection

    • setMaxRequestsPerConnection

      public void setMaxRequestsPerConnection(Integer maxRequestsPerConnection)
      Set the maximum number of requests that can execute concurrently on a single connection
      Parameters:
      maxRequestsPerConnection - the max requests per connection

    • getMaxOrphanRequests

      public Integer getMaxOrphanRequests()
      Get the maximum number of orphaned requests before a connection is closed and replaced
      Returns:
      the max orphan requests

    • setMaxOrphanRequests

      public void setMaxOrphanRequests(Integer maxOrphanRequests)
      Set the maximum number of orphaned requests before a connection is closed and replaced
      Parameters:
      maxOrphanRequests - the max orphan requests

    • getWarnOnInitError

      public Boolean getWarnOnInitError()
      Get whether non-fatal connection-init errors are logged
      Returns:
      the warnOnInitError flag

    • setWarnOnInitError

      public void setWarnOnInitError(Boolean warnOnInitError)
      Set whether non-fatal connection-init errors are logged
      Parameters:
      warnOnInitError - the warnOnInitError flag

    • getConnectTimeoutMillis

      public Integer getConnectTimeoutMillis()
      Get the connect timeout, in milliseconds
      Returns:
      - the connect timeout in milliseconds

    • setConnectTimeoutMillis

      public void setConnectTimeoutMillis(Integer connectTimeoutMillis)
      Set the connect timeout, in milliseconds
      Parameters:
      connectTimeoutMillis - - the connect timeout in milliseconds

    • getTcpNoDelay

      public Boolean getTcpNoDelay()
      Get the tcpNoDelay flag
      Returns:
      - the tcpNoDelay flag

    • setTcpNoDelay

      public void setTcpNoDelay(Boolean tcpNoDelay)
      Set the tcpNoDelay flag
      Parameters:
      tcpNoDelay - - the tcpNoDelay flag

    • getSocketKeepAlive

      public Boolean getSocketKeepAlive()
      Get the socket keep-alive flag
      Returns:
      the socketKeepAlive flag

    • setSocketKeepAlive

      public void setSocketKeepAlive(Boolean socketKeepAlive)
      Set the socket keep-alive flag
      Parameters:
      socketKeepAlive - the socketKeepAlive flag

    • getSocketReuseAddress

      public Boolean getSocketReuseAddress()
      Get the socket reuse-address flag
      Returns:
      the socketReuseAddress flag

    • setSocketReuseAddress

      public void setSocketReuseAddress(Boolean socketReuseAddress)
      Set the socket reuse-address flag
      Parameters:
      socketReuseAddress - the socketReuseAddress flag

    • getSocketLingerIntervalSeconds

      public Integer getSocketLingerIntervalSeconds()
      Get the socket linger interval, in seconds
      Returns:
      the linger interval in seconds

    • setSocketLingerIntervalSeconds

      public void setSocketLingerIntervalSeconds(Integer socketLingerIntervalSeconds)
      Set the socket linger interval, in seconds
      Parameters:
      socketLingerIntervalSeconds - the linger interval in seconds

    • getSocketReceiveBufferSize

      public Integer getSocketReceiveBufferSize()
      Get the socket receive buffer size hint
      Returns:
      the receive buffer size

    • setSocketReceiveBufferSize

      public void setSocketReceiveBufferSize(Integer socketReceiveBufferSize)
      Set the socket receive buffer size hint
      Parameters:
      socketReceiveBufferSize - the receive buffer size

    • getSocketSendBufferSize

      public Integer getSocketSendBufferSize()
      Get the socket send buffer size hint
      Returns:
      the send buffer size

    • setSocketSendBufferSize

      public void setSocketSendBufferSize(Integer socketSendBufferSize)
      Set the socket send buffer size hint
      Parameters:
      socketSendBufferSize - the send buffer size

    • getConsistencyLevel

      public String getConsistencyLevel()
      Get the request consistency level name
      Returns:
      - the request consistency level name

    • setConsistencyLevel

      public void setConsistencyLevel(String consistencyLevel)
      Set the request consistency level name (e.g. "LOCAL_ONE")
      Parameters:
      consistencyLevel - - the request consistency level name

    • getSerialConsistencyLevel

      public String getSerialConsistencyLevel()
      Get the request serial consistency level name
      Returns:
      - the request serial consistency level name

    • setSerialConsistencyLevel

      public void setSerialConsistencyLevel(String serialConsistencyLevel)
      Set the request serial consistency level name (e.g. "LOCAL_SERIAL")
      Parameters:
      serialConsistencyLevel - - the request serial consistency level name

    • getDefaultIdempotence

      public Boolean getDefaultIdempotence()
      Get the defaultIdempotence flag
      Returns:
      - the defaultIdempotence flag

    • setDefaultIdempotence

      public void setDefaultIdempotence(Boolean defaultIdempotence)
      Set the defaultIdempotence flag
      Parameters:
      defaultIdempotence - - the defaultIdempotence flag

    • getPageSize

      public Integer getPageSize()
      Get the default request page size
      Returns:
      - the default request page size

    • setPageSize

      public void setPageSize(Integer pageSize)
      Set the default request page size
      Parameters:
      pageSize - - the default request page size

    • getSpeculativeExecutionPolicyClassName

      public String getSpeculativeExecutionPolicyClassName()
      Get the SpeculativeExecutionPolicy implementation class name
      Returns:
      - The fully qualified SpeculativeExecutionPolicy implementation class name

    • setSpeculativeExecutionPolicyClassName

      public void setSpeculativeExecutionPolicyClassName(String speculativeExecutionPolicyClassName)
      Set the SpeculativeExecutionPolicy implementation class name. The driver instantiates this class itself via a (DriverContext, String profileName) constructor.
      Parameters:
      speculativeExecutionPolicyClassName - - The fully qualified SpeculativeExecutionPolicy implementation class name

    • getSpeculativeExecutionMaxExecutions

      public Integer getSpeculativeExecutionMaxExecutions()
      Get the maximum number of speculative executions (including the initial one)
      Returns:
      the max executions

    • setSpeculativeExecutionMaxExecutions

      public void setSpeculativeExecutionMaxExecutions(Integer speculativeExecutionMaxExecutions)
      Set the maximum number of speculative executions (including the initial one), used by the built-in ConstantSpeculativeExecutionPolicy
      Parameters:
      speculativeExecutionMaxExecutions - the max executions

    • getSpeculativeExecutionDelayMillis

      public Long getSpeculativeExecutionDelayMillis()
      Get the delay between speculative executions, in milliseconds
      Returns:
      the delay in milliseconds

    • setSpeculativeExecutionDelayMillis

      public void setSpeculativeExecutionDelayMillis(Long speculativeExecutionDelayMillis)
      Set the delay between speculative executions, in milliseconds, used by the built-in ConstantSpeculativeExecutionPolicy
      Parameters:
      speculativeExecutionDelayMillis - the delay in milliseconds

    • getTimestampGeneratorClassName

      public String getTimestampGeneratorClassName()
      Get the TimestampGenerator implementation class name
      Returns:
      - The fully qualified TimestampGenerator implementation class name

    • setTimestampGeneratorClassName

      public void setTimestampGeneratorClassName(String timestampGeneratorClassName)
      Set the TimestampGenerator implementation class name. The driver instantiates this class itself via a (DriverContext) constructor.
      Parameters:
      timestampGeneratorClassName - - The fully qualified TimestampGenerator implementation class name

    • getTimestampGeneratorForceJavaClock

      public Boolean getTimestampGeneratorForceJavaClock()
      Get whether the generator is forced to use Java's millisecond-precision system clock
      Returns:
      the timestampGeneratorForceJavaClock flag

    • setTimestampGeneratorForceJavaClock

      public void setTimestampGeneratorForceJavaClock(Boolean timestampGeneratorForceJavaClock)
      Set whether the generator is forced to use Java's millisecond-precision system clock
      Parameters:
      timestampGeneratorForceJavaClock - the timestampGeneratorForceJavaClock flag

    • getTimestampGeneratorDriftWarningThresholdMillis

      public Long getTimestampGeneratorDriftWarningThresholdMillis()
      Get how far timestamps may drift into the future before a warning is logged, in milliseconds
      Returns:
      the drift warning threshold in milliseconds

    • setTimestampGeneratorDriftWarningThresholdMillis

      public void setTimestampGeneratorDriftWarningThresholdMillis(Long timestampGeneratorDriftWarningThresholdMillis)
      Set how far timestamps may drift into the future before a warning is logged, in milliseconds
      Parameters:
      timestampGeneratorDriftWarningThresholdMillis - the drift warning threshold in milliseconds

    • getTimestampGeneratorDriftWarningIntervalSeconds

      public Long getTimestampGeneratorDriftWarningIntervalSeconds()
      Get how often the drift warning is re-logged, in seconds
      Returns:
      the drift warning interval in seconds

    • setTimestampGeneratorDriftWarningIntervalSeconds

      public void setTimestampGeneratorDriftWarningIntervalSeconds(Long timestampGeneratorDriftWarningIntervalSeconds)
      Set how often the drift warning is re-logged, in seconds
      Parameters:
      timestampGeneratorDriftWarningIntervalSeconds - the drift warning interval in seconds

    • getRequestWarnIfSetKeyspace

      public Boolean getRequestWarnIfSetKeyspace()
      Get whether a warning is logged when a request changes the active keyspace
      Returns:
      the requestWarnIfSetKeyspace flag

    • setRequestWarnIfSetKeyspace

      public void setRequestWarnIfSetKeyspace(Boolean requestWarnIfSetKeyspace)
      Set whether a warning is logged when a request changes the active keyspace
      Parameters:
      requestWarnIfSetKeyspace - the requestWarnIfSetKeyspace flag

    • getRequestLogWarnings

      public Boolean getRequestLogWarnings()
      Get whether server-generated query warnings are logged
      Returns:
      the requestLogWarnings flag

    • setRequestLogWarnings

      public void setRequestLogWarnings(Boolean requestLogWarnings)
      Set whether server-generated query warnings are logged
      Parameters:
      requestLogWarnings - the requestLogWarnings flag

    • getRequestTraceAttempts

      public Integer getRequestTraceAttempts()
      Get how many times the driver retries fetching a not-yet-ready query trace
      Returns:
      the trace fetch attempts

    • setRequestTraceAttempts

      public void setRequestTraceAttempts(Integer requestTraceAttempts)
      Set how many times the driver retries fetching a not-yet-ready query trace
      Parameters:
      requestTraceAttempts - the trace fetch attempts

    • getRequestTraceIntervalMillis

      public Long getRequestTraceIntervalMillis()
      Get the interval between query trace fetch attempts, in milliseconds
      Returns:
      the trace fetch interval in milliseconds

    • setRequestTraceIntervalMillis

      public void setRequestTraceIntervalMillis(Long requestTraceIntervalMillis)
      Set the interval between query trace fetch attempts, in milliseconds
      Parameters:
      requestTraceIntervalMillis - the trace fetch interval in milliseconds

    • getRequestTraceConsistencyLevel

      public String getRequestTraceConsistencyLevel()
      Get the consistency level used when fetching query traces
      Returns:
      the trace consistency level name

    • setRequestTraceConsistencyLevel

      public void setRequestTraceConsistencyLevel(String requestTraceConsistencyLevel)
      Set the consistency level used when fetching query traces
      Parameters:
      requestTraceConsistencyLevel - the trace consistency level name

    • getRequestTrackerClasses

      public List<String> getRequestTrackerClasses()
      Get the RequestTracker implementation class names to register
      Returns:
      the fully qualified RequestTracker implementation class names

    • setRequestTrackerClasses

      public void setRequestTrackerClasses(List<String> requestTrackerClasses)
      Set the RequestTracker implementation class names to register. The driver instantiates each class itself via a (DriverContext) constructor.
      Parameters:
      requestTrackerClasses - the fully qualified RequestTracker implementation class names

    • getRequestLoggerSuccessEnabled

      public Boolean getRequestLoggerSuccessEnabled()
      Get whether the built-in RequestLogger logs successful requests
      Returns:
      the requestLoggerSuccessEnabled flag

    • setRequestLoggerSuccessEnabled

      public void setRequestLoggerSuccessEnabled(Boolean requestLoggerSuccessEnabled)
      Set whether the built-in RequestLogger logs successful requests
      Parameters:
      requestLoggerSuccessEnabled - the requestLoggerSuccessEnabled flag

    • getRequestLoggerSlowThresholdMillis

      public Long getRequestLoggerSlowThresholdMillis()
      Get the threshold above which a successful request is classified as "slow", in milliseconds
      Returns:
      the slow-request threshold in milliseconds

    • setRequestLoggerSlowThresholdMillis

      public void setRequestLoggerSlowThresholdMillis(Long requestLoggerSlowThresholdMillis)
      Set the threshold above which a successful request is classified as "slow", in milliseconds
      Parameters:
      requestLoggerSlowThresholdMillis - the slow-request threshold in milliseconds

    • getRequestLoggerSlowEnabled

      public Boolean getRequestLoggerSlowEnabled()
      Get whether the built-in RequestLogger logs slow requests
      Returns:
      the requestLoggerSlowEnabled flag

    • setRequestLoggerSlowEnabled

      public void setRequestLoggerSlowEnabled(Boolean requestLoggerSlowEnabled)
      Set whether the built-in RequestLogger logs slow requests
      Parameters:
      requestLoggerSlowEnabled - the requestLoggerSlowEnabled flag

    • getRequestLoggerErrorEnabled

      public Boolean getRequestLoggerErrorEnabled()
      Get whether the built-in RequestLogger logs failed requests
      Returns:
      the requestLoggerErrorEnabled flag

    • setRequestLoggerErrorEnabled

      public void setRequestLoggerErrorEnabled(Boolean requestLoggerErrorEnabled)
      Set whether the built-in RequestLogger logs failed requests
      Parameters:
      requestLoggerErrorEnabled - the requestLoggerErrorEnabled flag

    • getRequestLoggerMaxQueryLength

      public Integer getRequestLoggerMaxQueryLength()
      Get the maximum logged query string length
      Returns:
      the max query length

    • setRequestLoggerMaxQueryLength

      public void setRequestLoggerMaxQueryLength(Integer requestLoggerMaxQueryLength)
      Set the maximum logged query string length
      Parameters:
      requestLoggerMaxQueryLength - the max query length

    • getRequestLoggerShowValues

      public Boolean getRequestLoggerShowValues()
      Get whether the built-in RequestLogger logs bound values
      Returns:
      the requestLoggerShowValues flag

    • setRequestLoggerShowValues

      public void setRequestLoggerShowValues(Boolean requestLoggerShowValues)
      Set whether the built-in RequestLogger logs bound values
      Parameters:
      requestLoggerShowValues - the requestLoggerShowValues flag

    • getRequestLoggerMaxValueLength

      public Integer getRequestLoggerMaxValueLength()
      Get the maximum logged bound-value length
      Returns:
      the max value length

    • setRequestLoggerMaxValueLength

      public void setRequestLoggerMaxValueLength(Integer requestLoggerMaxValueLength)
      Set the maximum logged bound-value length
      Parameters:
      requestLoggerMaxValueLength - the max value length

    • getRequestLoggerMaxValues

      public Integer getRequestLoggerMaxValues()
      Get the maximum number of bound values logged per request
      Returns:
      the max number of bound values logged

    • setRequestLoggerMaxValues

      public void setRequestLoggerMaxValues(Integer requestLoggerMaxValues)
      Set the maximum number of bound values logged per request
      Parameters:
      requestLoggerMaxValues - the max number of bound values logged

    • getRequestLoggerShowStackTraces

      public Boolean getRequestLoggerShowStackTraces()
      Get whether the built-in RequestLogger logs stack traces for failed queries
      Returns:
      the requestLoggerShowStackTraces flag

    • setRequestLoggerShowStackTraces

      public void setRequestLoggerShowStackTraces(Boolean requestLoggerShowStackTraces)
      Set whether the built-in RequestLogger logs stack traces for failed queries
      Parameters:
      requestLoggerShowStackTraces - the requestLoggerShowStackTraces flag

    • getThrottlerClassName

      public String getThrottlerClassName()
      Get the RequestThrottler implementation class name
      Returns:
      the fully qualified RequestThrottler implementation class name

    • setThrottlerClassName

      public void setThrottlerClassName(String throttlerClassName)
      Set the RequestThrottler implementation class name (e.g. "ConcurrencyLimitingRequestThrottler", "RateLimitingRequestThrottler", or a fully qualified custom class name). The driver instantiates this class itself via a (DriverContext) constructor.
      Parameters:
      throttlerClassName - the fully qualified RequestThrottler implementation class name

    • getThrottlerMaxQueueSize

      public Integer getThrottlerMaxQueueSize()
      Get the maximum number of requests that can be enqueued once throttled
      Returns:
      the max queue size

    • setThrottlerMaxQueueSize

      public void setThrottlerMaxQueueSize(Integer throttlerMaxQueueSize)
      Set the maximum number of requests that can be enqueued once throttled
      Parameters:
      throttlerMaxQueueSize - the max queue size

    • getThrottlerMaxConcurrentRequests

      public Integer getThrottlerMaxConcurrentRequests()
      Get the maximum number of requests allowed to execute in parallel (ConcurrencyLimitingRequestThrottler only)
      Returns:
      the max concurrent requests

    • setThrottlerMaxConcurrentRequests

      public void setThrottlerMaxConcurrentRequests(Integer throttlerMaxConcurrentRequests)
      Set the maximum number of requests allowed to execute in parallel (ConcurrencyLimitingRequestThrottler only)
      Parameters:
      throttlerMaxConcurrentRequests - the max concurrent requests

    • getThrottlerMaxRequestsPerSecond

      public Integer getThrottlerMaxRequestsPerSecond()
      Get the maximum allowed request rate (RateLimitingRequestThrottler only)
      Returns:
      the max requests per second

    • setThrottlerMaxRequestsPerSecond

      public void setThrottlerMaxRequestsPerSecond(Integer throttlerMaxRequestsPerSecond)
      Set the maximum allowed request rate (RateLimitingRequestThrottler only)
      Parameters:
      throttlerMaxRequestsPerSecond - the max requests per second

    • getThrottlerDrainIntervalMillis

      public Long getThrottlerDrainIntervalMillis()
      Get how often the throttler attempts to dequeue requests, in milliseconds (RateLimitingRequestThrottler only)
      Returns:
      the drain interval in milliseconds

    • setThrottlerDrainIntervalMillis

      public void setThrottlerDrainIntervalMillis(Long throttlerDrainIntervalMillis)
      Set how often the throttler attempts to dequeue requests, in milliseconds (RateLimitingRequestThrottler only)
      Parameters:
      throttlerDrainIntervalMillis - the drain interval in milliseconds

    • getMetadataSchemaEnabled

      public Boolean getMetadataSchemaEnabled()
      Get whether schema metadata is enabled
      Returns:
      the metadataSchemaEnabled flag

    • setMetadataSchemaEnabled

      public void setMetadataSchemaEnabled(Boolean metadataSchemaEnabled)
      Set whether schema metadata is enabled
      Parameters:
      metadataSchemaEnabled - the metadataSchemaEnabled flag

    • getMetadataSchemaRefreshedKeyspaces

      public List<String> getMetadataSchemaRefreshedKeyspaces()
      Get the keyspace name-matching rules for which schema/token metadata is maintained
      Returns:
      the keyspace matching rules

    • setMetadataSchemaRefreshedKeyspaces

      public void setMetadataSchemaRefreshedKeyspaces(List<String> metadataSchemaRefreshedKeyspaces)
      Set the keyspace name-matching rules for which schema/token metadata is maintained
      Parameters:
      metadataSchemaRefreshedKeyspaces - the keyspace matching rules

    • getMetadataSchemaRequestTimeoutMillis

      public Long getMetadataSchemaRequestTimeoutMillis()
      Get the timeout for schema metadata requests, in milliseconds
      Returns:
      the schema request timeout in milliseconds

    • setMetadataSchemaRequestTimeoutMillis

      public void setMetadataSchemaRequestTimeoutMillis(Long metadataSchemaRequestTimeoutMillis)
      Set the timeout for schema metadata requests, in milliseconds
      Parameters:
      metadataSchemaRequestTimeoutMillis - the schema request timeout in milliseconds

    • getMetadataSchemaRequestPageSize

      public Integer getMetadataSchemaRequestPageSize()
      Get the page size for schema metadata requests
      Returns:
      the schema request page size

    • setMetadataSchemaRequestPageSize

      public void setMetadataSchemaRequestPageSize(Integer metadataSchemaRequestPageSize)
      Set the page size for schema metadata requests
      Parameters:
      metadataSchemaRequestPageSize - the schema request page size

    • getMetadataSchemaWindowMillis

      public Long getMetadataSchemaWindowMillis()
      Get the debounce window for coalescing schema-change events, in milliseconds
      Returns:
      the schema debounce window in milliseconds

    • setMetadataSchemaWindowMillis

      public void setMetadataSchemaWindowMillis(Long metadataSchemaWindowMillis)
      Set the debounce window for coalescing schema-change events, in milliseconds
      Parameters:
      metadataSchemaWindowMillis - the schema debounce window in milliseconds

    • getMetadataSchemaMaxEvents

      public Integer getMetadataSchemaMaxEvents()
      Get the maximum number of schema-change events accumulated before forcing a refresh
      Returns:
      the max schema events

    • setMetadataSchemaMaxEvents

      public void setMetadataSchemaMaxEvents(Integer metadataSchemaMaxEvents)
      Set the maximum number of schema-change events accumulated before forcing a refresh
      Parameters:
      metadataSchemaMaxEvents - the max schema events

    • getMetadataTopologyWindowMillis

      public Long getMetadataTopologyWindowMillis()
      Get the debounce window for coalescing topology events, in milliseconds
      Returns:
      the topology debounce window in milliseconds

    • setMetadataTopologyWindowMillis

      public void setMetadataTopologyWindowMillis(Long metadataTopologyWindowMillis)
      Set the debounce window for coalescing topology events, in milliseconds
      Parameters:
      metadataTopologyWindowMillis - the topology debounce window in milliseconds

    • getMetadataTopologyMaxEvents

      public Integer getMetadataTopologyMaxEvents()
      Get the maximum number of topology events accumulated before forcing propagation
      Returns:
      the max topology events

    • setMetadataTopologyMaxEvents

      public void setMetadataTopologyMaxEvents(Integer metadataTopologyMaxEvents)
      Set the maximum number of topology events accumulated before forcing propagation
      Parameters:
      metadataTopologyMaxEvents - the max topology events

    • getMetadataTokenMapEnabled

      public Boolean getMetadataTokenMapEnabled()
      Get whether token metadata is enabled
      Returns:
      the metadataTokenMapEnabled flag

    • setMetadataTokenMapEnabled

      public void setMetadataTokenMapEnabled(Boolean metadataTokenMapEnabled)
      Set whether token metadata is enabled
      Parameters:
      metadataTokenMapEnabled - the metadataTokenMapEnabled flag

    • getPrepareOnAllNodes

      public Boolean getPrepareOnAllNodes()
      Get whether Session.prepare() calls are re-sent to all other active nodes
      Returns:
      the prepareOnAllNodes flag

    • setPrepareOnAllNodes

      public void setPrepareOnAllNodes(Boolean prepareOnAllNodes)
      Set whether Session.prepare() calls are re-sent to all other active nodes
      Parameters:
      prepareOnAllNodes - the prepareOnAllNodes flag

    • getReprepareEnabled

      public Boolean getReprepareEnabled()
      Get whether the driver re-prepares statements on nodes that come back up or join the cluster
      Returns:
      the reprepareEnabled flag

    • setReprepareEnabled

      public void setReprepareEnabled(Boolean reprepareEnabled)
      Set whether the driver re-prepares statements on nodes that come back up or join the cluster
      Parameters:
      reprepareEnabled - the reprepareEnabled flag

    • getReprepareCheckSystemTable

      public Boolean getReprepareCheckSystemTable()
      Get whether system.prepared_statements is checked before repreparing
      Returns:
      the reprepareCheckSystemTable flag

    • setReprepareCheckSystemTable

      public void setReprepareCheckSystemTable(Boolean reprepareCheckSystemTable)
      Set whether system.prepared_statements is checked before repreparing
      Parameters:
      reprepareCheckSystemTable - the reprepareCheckSystemTable flag

    • getReprepareMaxStatements

      public Integer getReprepareMaxStatements()
      Get the maximum number of statements to reprepare
      Returns:
      the max statements to reprepare

    • setReprepareMaxStatements

      public void setReprepareMaxStatements(Integer reprepareMaxStatements)
      Set the maximum number of statements to reprepare; 0 or negative means no limit
      Parameters:
      reprepareMaxStatements - the max statements to reprepare

    • getReprepareMaxParallelism

      public Integer getReprepareMaxParallelism()
      Get the maximum number of concurrent reprepare requests
      Returns:
      the max reprepare parallelism

    • setReprepareMaxParallelism

      public void setReprepareMaxParallelism(Integer reprepareMaxParallelism)
      Set the maximum number of concurrent reprepare requests
      Parameters:
      reprepareMaxParallelism - the max reprepare parallelism

    • getReprepareTimeoutMillis

      public Long getReprepareTimeoutMillis()
      Get the reprepare request timeout, in milliseconds
      Returns:
      the reprepare timeout in milliseconds

    • setReprepareTimeoutMillis

      public void setReprepareTimeoutMillis(Long reprepareTimeoutMillis)
      Set the reprepare request timeout, in milliseconds
      Parameters:
      reprepareTimeoutMillis - the reprepare timeout in milliseconds

    • getPreparedCacheWeakValues

      public Boolean getPreparedCacheWeakValues()
      Get whether the prepared-statement cache uses weak references for its values
      Returns:
      the preparedCacheWeakValues flag

    • setPreparedCacheWeakValues

      public void setPreparedCacheWeakValues(Boolean preparedCacheWeakValues)
      Set whether the prepared-statement cache uses weak references for its values
      Parameters:
      preparedCacheWeakValues - the preparedCacheWeakValues flag

    • getNettyDaemonThreads

      public Boolean getNettyDaemonThreads()
      Get whether the driver's internal threads are daemon threads
      Returns:
      the nettyDaemonThreads flag

    • setNettyDaemonThreads

      public void setNettyDaemonThreads(Boolean nettyDaemonThreads)
      Set whether the driver's internal threads are daemon threads
      Parameters:
      nettyDaemonThreads - the nettyDaemonThreads flag

    • getNettyIoGroupSize

      public Integer getNettyIoGroupSize()
      Get the number of I/O threads
      Returns:
      the I/O thread count

    • setNettyIoGroupSize

      public void setNettyIoGroupSize(Integer nettyIoGroupSize)
      Set the number of I/O threads; 0 means availableProcessors() * 2
      Parameters:
      nettyIoGroupSize - the I/O thread count

    • getNettyIoGroupShutdownQuietPeriodSeconds

      public Integer getNettyIoGroupShutdownQuietPeriodSeconds()
      Get the I/O event loop group shutdown quiet period, in seconds
      Returns:
      the quiet period in seconds

    • setNettyIoGroupShutdownQuietPeriodSeconds

      public void setNettyIoGroupShutdownQuietPeriodSeconds(Integer nettyIoGroupShutdownQuietPeriodSeconds)
      Set the I/O event loop group shutdown quiet period, in seconds
      Parameters:
      nettyIoGroupShutdownQuietPeriodSeconds - the quiet period in seconds

    • getNettyIoGroupShutdownTimeoutSeconds

      public Integer getNettyIoGroupShutdownTimeoutSeconds()
      Get the I/O event loop group shutdown timeout, in seconds
      Returns:
      the shutdown timeout in seconds

    • setNettyIoGroupShutdownTimeoutSeconds

      public void setNettyIoGroupShutdownTimeoutSeconds(Integer nettyIoGroupShutdownTimeoutSeconds)
      Set the I/O event loop group shutdown timeout, in seconds
      Parameters:
      nettyIoGroupShutdownTimeoutSeconds - the shutdown timeout in seconds

    • getNettyAdminGroupSize

      public Integer getNettyAdminGroupSize()
      Get the number of admin threads
      Returns:
      the admin thread count

    • setNettyAdminGroupSize

      public void setNettyAdminGroupSize(Integer nettyAdminGroupSize)
      Set the number of admin threads (cluster events, metadata refresh, reconnection scheduling)
      Parameters:
      nettyAdminGroupSize - the admin thread count

    • getNettyAdminGroupShutdownQuietPeriodSeconds

      public Integer getNettyAdminGroupShutdownQuietPeriodSeconds()
      Get the admin event loop group shutdown quiet period, in seconds
      Returns:
      the quiet period in seconds

    • setNettyAdminGroupShutdownQuietPeriodSeconds

      public void setNettyAdminGroupShutdownQuietPeriodSeconds(Integer nettyAdminGroupShutdownQuietPeriodSeconds)
      Set the admin event loop group shutdown quiet period, in seconds
      Parameters:
      nettyAdminGroupShutdownQuietPeriodSeconds - the quiet period in seconds

    • getNettyAdminGroupShutdownTimeoutSeconds

      public Integer getNettyAdminGroupShutdownTimeoutSeconds()
      Get the admin event loop group shutdown timeout, in seconds
      Returns:
      the shutdown timeout in seconds

    • setNettyAdminGroupShutdownTimeoutSeconds

      public void setNettyAdminGroupShutdownTimeoutSeconds(Integer nettyAdminGroupShutdownTimeoutSeconds)
      Set the admin event loop group shutdown timeout, in seconds
      Parameters:
      nettyAdminGroupShutdownTimeoutSeconds - the shutdown timeout in seconds

    • getNettyTimerTickDurationMillis

      public Long getNettyTimerTickDurationMillis()
      Get the request-timeout/speculative-execution timer's tick duration, in milliseconds
      Returns:
      the tick duration in milliseconds

    • setNettyTimerTickDurationMillis

      public void setNettyTimerTickDurationMillis(Long nettyTimerTickDurationMillis)
      Set the request-timeout/speculative-execution timer's tick duration, in milliseconds
      Parameters:
      nettyTimerTickDurationMillis - the tick duration in milliseconds

    • getNettyTimerTicksPerWheel

      public Integer getNettyTimerTicksPerWheel()
      Get the timer's hashed wheel size
      Returns:
      the ticks per wheel

    • setNettyTimerTicksPerWheel

      public void setNettyTimerTicksPerWheel(Integer nettyTimerTicksPerWheel)
      Set the timer's hashed wheel size
      Parameters:
      nettyTimerTicksPerWheel - the ticks per wheel

    • getCoalescerIntervalMicros

      public Long getCoalescerIntervalMicros()
      Get the write-coalescer reschedule interval, in microseconds
      Returns:
      the reschedule interval in microseconds

    • setCoalescerIntervalMicros

      public void setCoalescerIntervalMicros(Long coalescerIntervalMicros)
      Set the write-coalescer reschedule interval, in microseconds. Expert-level tuning; the driver's default is fine for almost all use cases.
      Parameters:
      coalescerIntervalMicros - the reschedule interval in microseconds

    • getCoalescerMaxRuns

      public Integer getCoalescerMaxRuns()
      Get the maximum number of coalescing runs per reschedule interval
      Returns:
      the max coalescing runs

    • setCoalescerMaxRuns

      public void setCoalescerMaxRuns(Integer coalescerMaxRuns)
      Set the maximum number of coalescing runs per reschedule interval. Expert-level tuning.
      Parameters:
      coalescerMaxRuns - the max coalescing runs

    • getSessionLeakThreshold

      public Integer getSessionLeakThreshold()
      Get the maximum number of live sessions allowed to coexist in this JVM before a leak warning is logged
      Returns:
      the session leak threshold

    • setSessionLeakThreshold

      public void setSessionLeakThreshold(Integer sessionLeakThreshold)
      Set the maximum number of live sessions allowed to coexist in this JVM before a leak warning is logged
      Parameters:
      sessionLeakThreshold - the session leak threshold

    • getResolveContactPoints

      public Boolean getResolveContactPoints()
      Get whether contact-point addresses are resolved once at startup (true) or on every connection attempt (false)
      Returns:
      the resolveContactPoints flag

    • setResolveContactPoints

      public void setResolveContactPoints(Boolean resolveContactPoints)
      Set whether contact-point addresses are resolved once at startup (true) or on every connection attempt (false)
      Parameters:
      resolveContactPoints - the resolveContactPoints flag

    • getProtocolVersion

      public String getProtocolVersion()
      Get the ProtocolVersion name
      Returns:
      - the protocol version name (e.g. "V4")

    • setProtocolVersion

      public void setProtocolVersion(String protocolVersion)
      Set the ProtocolVersion name
      Parameters:
      protocolVersion - - the protocol version name (e.g. "V4")