This documentation is for WSO2 Data Services Server 3.2.0. View the home page of the latest release.

Unknown macro: {next_previous_link3}
Skip to end of metadata
Go to start of metadata

You are viewing an old version of this page. View the current version.

Compare with Current View Page History

« Previous Version 24 Next »

The Cassandra data source supports Cassandra server versions 1.2.x and upwards, and works with Cassandra Query Language version 3 (CQL3).

You can create your Cassandra data source as you create the data service: Follow the steps from 1 to 3 in creating a data service using various data sources. When you get to the Add New Data Source screen, select Cassandra as the data source type. The Cassandra-specific options will be available for editing. 

The following describes the properties supported by the Cassandra datasource. For more detailed information about the functionality of the underlying connector, check http://www.datastax.com/documentation/developer/java-driver/2.0/index.html.

Data Source PropertyDescription
Cassandra Servers*Comma separated list of host names of Cassandra servers.
PortThe port of Cassandra servers.
Cluster NameThe Cassandra cluster name.
CompressionCompression used in communication.
User NameThe authenticating user's username.
PasswordThe authenticating user's password.
Load Balancing PolicyThe client load balancing policy on how calls should be made to the provided servers.
Enable JMX ReportingEnable JMX statistics of the connector.
Enable MetricsEnable metrics of the connector.
Local Core Connections Per HostConnection pooling: Local core connections per server host.
Remote Core Connections Per HostConnection pooling: Remote core connections per server host.
Local Max.Connections Per HostConnection pooling: Maximum local connections per server host.
Remote Max.Connections Per HostConnection pooling: Remote max connections per server host
Local Max.Simultaneous Requests Per Connection ThresholdConnection pooling: Number of simultaneous requests on all local connections to a host. If the number of requests exceeds this number, new connections are created.
Remote Max.Simultaneous Requests Per Connection ThresholdConnection pooling: Number of simultaneous requests on all remote connections to a host. If the number of requests exceeds this number, new connections are created.
Local Min.Simultaneous Requests Per Connection ThresholdConnection pooling: Number of simultaneous requests on a connection. If the number of requests is less than this number, the remote connections in excess are reclaimed.
Remote Min.Simultaneous Requests Per Connection ThresholdConnection pooling: Number of simultaneous requests on a connection. If the number of requests is less than this number, the remote connections in excess are reclaimed.
Protocol VersionThe native protocol version to use. By default, it auto connects. "2" for Cassandra versions 2.0 and upwards, and "1" for Cassandra version 1.2.x.
Consistency LevelThe consistency level used for queries.
Fetch SizeFetch size used by queries.
Serial Consistency LevelThe serial consistency level used for queries.
Reconnection PolicyThe reconnection policy used for the cluster.
Constant Reconnection Policy DelayIf "ConstantReconnectionPolicy" is used for Reconnection Policy, this represents the constant wait time between reconnection attempts in milliseconds.
Exponential Reconnection Policy Base DelayIf "ExponentialReconnectionPolicy" is used for Reconnection Policy, this represent the base delay in milliseconds.
Exponential Reconnection Policy Max. DelayIf "ExponentialReconnectionPolicy" is used for Reconnection Policy, this represent the maximum delay in milliseconds.
Retry PolicyConfigured the retry policy in this cluster.
Connection TimeoutThe socket connection timeout in milliseconds.
The socket connection timeout in milliseconds.Set if socket keeps alive.
Keep AliveSet if socket keeps alive.
Read TimeoutSet per host socket read timeout in milliseconds.
Receive Buffer SizeThe socket receive buffer size.
Send Buffer SizeThe socket send buffer size.
Reuse AddressThe socket re-use address.
So LingerThe socket linger on value.
TCP no DelaySet socket TCP to no delay.
Disable Native Batch RequestsDisables native Cassandra batch requests, and reverts to emulated batch requests.

* Mandatory fields.

To write a query to this datasource, see Writing Data Service Queries.

Queries based on Cassandra datasources, currently do not support named parameters or array type parameters.

A sample based on the Cassandra datasource can be found here: Cassandra Sample.

  • No labels