The latest version for DAS is WSO2 Data Analytics Server 3.2.0. View documentation for the latest release.
WSO2 Data Analytics Server is succeeded by WSO2 Stream Processor. To view the latest documentation for WSO2 SP, see WSO2 Stream Processor Documentation.
Skip to end of metadata
Go to start of metadata

Instructions on how to migrate from WSO2 Business Activity Monitor 2.x to WSO2 DAS are as follows.

Migrating analytics data

The analytics data migration tool can be used to migrate the Cassandra column family data of a WSO2 BAM 2.x server to WSO2 Data Analytics Server (DAS) 3.0.0. The <DAS_HOME>/bin/ script serves as the analytics migration tool.


Before running the <DAS_HOME>/bin/ script, the event table(s) that serve as the destination for migrated data should be defined in WSO2 DAS. Follow the procedure below to create the required event tables by copying the relevant stream definitions from WSO2 BAM.


  1. Log into the WSO2 BAM Management Console, and go to the Main tab.
  2. Under Registry, click Browse to open the Browse page.
  3. Navigate to <Top_Folder>/system/governance/StreamDefinitions/<relevant_event_stream>/<relevant_stream_version> as shown in the example below.
  4. Click on the stream version. This will open the Detail View tab for the event stream version you selected.
  5. Click Display as Text to view the event stream configuration as a JSON array.
  6. Copy the JSON array to the clipboard.
  7. Log into the DAS Management Console and go to the Main tab.
  8. Click Streams to open the Available Event Streams page.
  9. Click Add Event Streams to open the Define New Event Stream page.
  10. Click switch to source view.
  11. Clear the existing text in the source view and paste the JSON array you copied to the clipboard.
  12. Click Add Event Stream.
  13. If you want the event stream to persist events, follow the instructions in Persisting Data for Batch Analytics.

Alternatively, you can redefine the complete event stream configuration as described in Understanding Event Streams and Event Tables.

Sample command

./ -cassandraUrl localhost -columnFamily org_wso2_bam_phone_retail_store_kpi -analyticTable org_wso2_bam_phone_retail_store_kpi -batchSize 1000 -tenantId -1234 -username admin -password admin -cassandraPort 9161 -clusterName Test Cluster


The arguments that can be used with the command are described below.

ParameterDescriptionDefault ValueExample


Destination name of the table which will have the migrated data.



Name of the columnFamily to which analytics data will be migrated.



Tenant ID of the considered tenant.

super tenant-1234
-serverUrlThe URL of the DAS server.

-serverPortThe Cassandra CQL port90429042
-cassandraUrlThe URL to access the Cassandra server.localhost

-cassandraPortThe thrift port for the Cassandra server.91609160
-batchSizeCassandra data is migrated from BAM to DAS in batches. This property specifies the size of a batch of data transferred at a given time.10001000
-usernameThe username to access the Cassandra server.Noneadmin
-passwordsThe password to access the Cassandra server.Noneadmin
-clusterNameThe name of the cluster to which the data should be migrated.Nonecluster001

Migrating WSO2 BAM toolboxes

Toolboxes concept of WSO2 Business Activity Monitor is replaced in WSO2 DAS by a CAR file based deployment approach. Since you need to map Hive queries to the Apache Spark syntax that is supported by WSO2 DAS, you cannot directly upload WSO2 BAM (2.x versions) toolboxes to WSO2 DAS. Thereby, you need to wrap all the artifacts (stream definitions, event receivers, event stores, event publishers, Spark scripts etc.) in a .car file and upload it to WSO2 DAS. For instructions on how to create a Carbon application with the CAR extension, see Carbon Application Deployment for DAS. However, you can use the analytics migration tool to migrate the data from Cassandra to the DAS datasource.

  • No labels
  • Download PDF icon Download PDF
  • Download a PDF file of the documentation