The WSO2BAM_CASSANDRA_DATASOURCE
, which is defined in the <PRODUCT_HOME>/repository/conf/bam-datasources.xml
file is used for pointing to the Cassandra node/cluster, from where the data for the analyzer will be sourced.
To point to the Cassandra node/cluster, you need to edit the default datasource configuration defined as shown below in the bam-datasources.xml
file.
Replace the url
, username
and password
settings with your custom values and also the other values accordingly in the bam-datasources.xml
file as shown in the below example.
<datasource> <name>WSO2BAM_CASSANDRA_DATASOURCE</name> <description>The datasource used for Cassandra data</description> <definition type="CASSANDRA"> <configuration> <hosts>localhost</hosts> <port>9160</port> <username>admin</username> <password>admin</password> <keySpace>EVENT_KS</keySpace> <externalCassandra>false</externalCassandra> <replicationFactor>1</replicationFactor> <strategyClass>org.apache.cassandra.locator.SimpleStrategy</strategyClass> <readConsistencyLevel>QUORUM</readConsistencyLevel> <writeConsistencyLevel>QUORUM</writeConsistencyLevel> <gcGraceInterval>864000</gcGraceInterval> </configuration> </definition> </datasource>The datasource configuration options are as follows:
- url - The URL of the database.
username - The name of the database user.
- password - The password of the database user.
dataSourceProps - The properties of the datasource. The following properties can be defined:
Property Description externalCassandra
Whether an external Cassandra server or the Cassandra server which is bundled with BAM is used. replicationFactor
The total number of nodes on which the data will be replicated across the Cassandra cluster. strategyClass
The strategy class used in arranging the structure of the Cassandra nodes. readConsistencyLevel
The number of replicas which must respond to a read request before returning data to the client application. writeConsistencyLevel
The number of replicas on which the write must succeed before returning an acknowledgment to the client application.