Adapter for Apache Cassandra 10.2 | webMethods Adapter for Apache Cassandra Documentation | webMethods Adapter for Apache Cassandra Installation and User’s Documentation | Adapter for Apache Cassandra Connections | Configuring Adapter for Apache Cassandra Connection | Supported Backed Connection Properties
 
Supported Backed Connection Properties
CodecRegistry
Properties
Action/Description
cassandra.codecRegistry.typecodecs=
Configuration directory.
PoolinglOptions(Options related to connection pooling)
Properties
Action/Description
cassandra.poolingOptions.
hearbeatIntervalSeconds
Sets the heart beat interval. Later, a message is sent on an idle connection to make sure it is still alive.
cassandra.poolingOptions.
idleTimeoutSeconds=
Sets the timeout before an idle connection is removed.
cassandra.poolingOptions.
poolTimeoutMillis=
Sets the timeout when trying to acquire a connection from a host's pool.
cassandra.poolingOptions.
coreConnectionsPerHost.local=
Sets the core and maximum number of connections per host with HostDistance set to LOCAL in one call.
cassandra.poolingOptions.
maxConnectionsPerHost.local=
cassandra.poolingOptions.
coreConnectionsPerHost.remote=#
Sets the core and maximum number of connections per host with HostDistance set to REMOTE in one call.
cassandra.poolingOptions.
maxConnectionsPerHost.remote=
ProtocolOptions(Options of the Cassandra native binary protocol)
Properties
Action/Description
cassandra.protocolOptions.port=
Port to be used for binary protocol.
cassandra.protocolOptions.
authProvider=
AuthProvider to be used for authentication against the Cassandra nodes.
cassandra.protocolOptions.
username=
Username for the
com.datastax.driver.core.
PlainTextAuthProvider.
cassandra.protocolOptions.
password=
Password for the
com.datastax.driver.core.
PlainTextAuthProvider.
cassandra.protocolOptions.
sslOption=
Specify the implementation class of com.datastax.driver.core.SSLOptions interface.
cassandra.protocolOptions.version=
Specify the protocol version. If the version is null, then the biggest version supported by the first node to which the driver connects to is used.
cassandra.protocolOptions.
compression=
Sets the compression to be used. By default, the compression is not used.
cassandra.protocolOptions.
maxSchemaAgreement=
Specify the maximum wait time in seconds for schema agreement before returning from a DDL query.
QueryOptions(Options related to defaults for individual queries)
Properties
Action/Description
cassandra.queryOptions.consistency=
Sets the default consistency level to use queries.
cassandra.queryOptions.serialConsistency=
Sets the default serial consistency level to use queries.
cassandra.queryOptions.fetchSize=
Sets the default fetch size value to use SELECT queries.
cassandra.queryOptions.idemPotence=
Sets the default idempotence for queries.
cassandra.queryOptions.metadata=
Specifies if the client-side token and schema metadata is to be enabled or not. By default, this feature is enabled. Some applications might want to disable it in order to eliminate the overhead of querying the metadata and building its client-side representation.
cassandra.queryOptions.
maxPendingRefreshNodeListRequests=
Sets the default window size in milliseconds, which is used to debounce the node list refresh requests.
cassandra.queryOptions.
maxPendingRefreshNodeRequests=
The default window size in milliseconds used to debounce schema refresh requests.
cassandra.queryOptions.
maxPendingRefreshSchemaRequests=
Sets the maximum number of schema refresh requests that the control connection can accumulate before executing them.
cassandra.queryOptions.
refreshNodeListIntervalMillis=
Sets the default window size in milliseconds which is used to debounce the node list refresh requests.
cassandra.queryOptions.
refreshNodeIntervalMillis=
Sets the default window size in milliseconds which is used to debounce node refresh requests.
cassandra.queryOptions.
refreshSchemaIntervalMillis=
Sets the maximum number of node refresh requests that the control connection can accumulate before executing them.
cassandra.queryOptions.reprepareOnUp=
Specify whether the driver should re-prepare all cached prepared statements on a host when it marks it as back up. By default, this feature is enabled.
cassandra.queryOptions.prepareOnAllHosts=
Specify whether the driver should prepare statements on all hosts in the cluster.
SocketOptions( Options to configure low-level socket options for the connections kept to the Cassandra hosts)
Properties
Action/Description
cassandra.socketOptions.
connectTimeoutMillis=
Sets the connection timeout in milliseconds.
cassandra.socketOptions.
readTimeoutMillis=
Sets the per-host read timeout in milliseconds.
cassandra.socketOptions.reuseAddress=
Specifies whether to enable reuse-address. It can be either true or false.
cassandra.socketOptions.keepAlive=
Specifies whether to enable TCP keepalive. It can be either true or false.
cassandra.socketOptions.soLinger=
Sets the linger-on-close timeout. By default, this option is not set by the driver. The actual value is the default from the underlying Netty transport (Java NIO or native epoll).
cassandra.socketOptions.tcpNoDelay=
Specifies whether to disable Nagle's algorithm. By default, this option is set to true (Nagle disabled).
cassandra.socketOptions.receiveBufferSize=
Sets a hint to the size of the underlying buffers for incoming network Input/Output. The value given is an integer value.
cassandra.socketOptions.sendBufferSize=
Sets a hint to the size of the underlying buffers for outgoing network Input/Output. The value given is an integer value.
Policies(Policy that decides how often the reconnection to a dead node is attempted)
Properties
Action/Description
cassandra.policies.reconnection.type=
Type of ReconnectionPolicy either
com.datastax.driver.core.
policies.ConstantReconnectionPolicy
or
com.datastax.driver.core.
policies.ExponentialReconnectionPolicy.
cassandra.policies.reconnection.delay=
The constant/base delay in milliseconds to be used for this policy.
cassandra.policies.reconnection.
maxDelay=
The maximum delay in milliseconds between the number of reconnecting attempts for this policy.
cassandra.policies.adresstranslator=
Translates IP addresses received from Cassandra nodes into locally queriable addresses. Specify the implementation class of com.datastax.driver.core.
policies.AddressTranslator.
cassandra.policies.retry=
A policy that defines a default behavior to adopt when a request fails. Specify the implementation class of
com.datastax.driver.core.policies.RetryPolicy.
cassandra.policies.timestamp=
Generates client-side, microsecond-precision query timestamps. Specify the implementation class of
com.datastax.driver.core.TimestampGenerator.
cassandra.policies.speculative=
The policy that decides if the driver will send speculative queries to the next hosts when the current host takes too long to respond.
cassandra.policies.speculative.
const.DelayMillis=
The delay between each speculative execution. The value must be strictly positive.
cassandra.policies.speculative.
const.maxExecutions=
The number of speculative executions. The value must be an integer and strictly positive.
cassandra.policies.speculative.
percentile.tracker=
The component that will record latencies. It will get registered with the cluster when this policy initializes.
cassandra.policies.speculative.
percentile.percentile=
The percentile that a request's latency must fall into is considered slow. For example, 99.0.
cassandra.policies.speculative.
percentile.maxExecutions=
The maximum number of speculative executions that is triggered for a given request. The request does not include the initial, normal requests. The Value must be strictly positive.
cassandra.policies.speculative.
percentile.
highestTrackableLatencyMillis=
The highest expected latency. If a higher value is reported, it will be ignored and a warning will be logged.
cassandra.policies.speculative.
percentile.
numberOfSignificantValueDigits=
Sets the number of significant decimal digits to which histograms maintains the value resolution and separation.
cassandra.policies.speculative.
percentile.minRecordedValues=
Sets the minimum number of values that is recorded for a host before you consider the sample size significant.
cassandra.policies.speculative.
percentile.intervalMs=
Sets the time interval over which samples are recorded.
Policies/LoadBalancing
Properties
Action/Description
cassandra.policies.loadbalancing=
The policy that decides the respective Cassandra hosts to contact for each new query.
Specify implementation classes of
com.datastax.driver.core.policies.
LoadBalancingPolicy with comma separated.
com.datastax.driver.core.policies.DCAwareRoundRobinPolicy
Properties
Action/Description
cassandra.policies.loadbalancing.
dcaware.localdc=
Sets the name of the datacenter that is considered "local" by the policy.
cassandra.policies.loadbalancing.
dcaware.hostPerRemoteDc=
Sets the number of hosts per remote datacenter that the policy should consider.
cassandra.policies.loadbalancing.
dcaware.allowhostPerRemote=
Allows the policy to return remote hosts when building query plans for queries having consistency level LOCAL_ONE or LOCAL_QUORUM.
com.datastax.driver.core.policies.TokenAwarePolicy
Properties
Action/Description
cassandra.policies.loadbalancing.
token.shufflereplicas=
Specifies whether to shuffle the replicas returned by getRoutingKey. Note that setting this parameter to true might decrease the effectiveness of caching (especially at consistency level ONE), since the same row will be retrieved from any replica (instead of only the "primary" replica without shuffling). On the other hand, shuffling will better distribute writes, and can alleviate hotspots caused by "fat" partitions.
com.datastax.driver.core.policies.WhiteListPolicy
Properties
Action/Description
cassandra.policies.loadbalancing.
whilelist.addresses=
Specify the white listed hosts.
com.datastax.driver.core.policies.LatencyAwarePolicy
Properties
Action/Description
cassandra.policies.loadbalancing.
latency.exclusionThreshold=
Sets the exclusion threshold to use for the resulting latency aware policy.
cassandra.policies.loadbalancing.
latency.scale=
Sets the scale for the resulting latency aware policy.
cassandra.policies.loadbalancing.
latency.retryPeriod=
Sets the retry period for the resulting latency aware policy.
cassandra.policies.loadbalancing.
latency.minMeasure=
Sets the minimum number of measurements per-host to consider the resulting latency aware policy.
cassandra.policies.loadbalancing.
latency.updateRate=
Sets the update rate for the resulting latency aware policy.
com.datastax.driver.core.policies.ErrorAwarePolicy
Properties
Action/Description
cassandra.policies.loadbalancing.
error.retryPeriodNanos=
Defines the time during which a host is excluded by the policy once it has exceeded. By default, the value for the retry period is 2 minutes.
cassandra.policies.loadbalancing.
error.maxErrorPerMinute=
Defines the maximum number of errors allowed per minute for each host. By default, the value for the threshold is 1.