WSO2 BAM Hive Incremental Datasource

The WSO2BAM_HIVE_INCREMENTAL_DATASOURCE is defined in the <PRODUCT_HOME>/repository/conf/bam-datasources.xml file. It is used for storing indices, which are used in Hive incremental processing jobs.

To point to the database, where indices are stored, you need to edit the default datasource configuration defined as shown below, in the bam-datasources.xml file.

<datasource>
			<name>WSO2BAM_HIVE_INCREMENTAL_DATASOURCE</name>
			<definition type="RDBMS">
				<configuration>
                    <url>jdbc:cassandra://localhost:9160/EVENT_KS</url>
					<username>admin</username>
					<password>admin</password>
					<dataSourceProps>
						<property name="replicationFactor">1</property>
						<property name="strategyClass">org.apache.cassandra.locator.SimpleStrategy</property>
						<property name="readConsistencyLevel">QUORUM</property>
						<property name="writeConsistencyLevel">QUORUM</property>
						<property name="keyspaceName">HIVE_INCREMENTAL_KS</property>
					</dataSourceProps>
				</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
  replicationFactor
  strategyClass
  readConsistencyLevel
  writeConsistencyLevel