Demo: Sinking to Starrocks

In this demo, we want to showcase how RisingWave is able to sink data to Starrocks.

1. Launch the cluster:

docker-compose up -d

The cluster contains a RisingWave cluster and its necessary dependencies, a datagen that generates the data, a Starrocks fe and be for sink.

2. Create the Starrocks table via mysql:

Login to mysql

docker compose exec starrocks-fe mysql -uroot -P9030 -h127.0.0.1

Run the following queries to create database and table. You also use other starrocks table, example in ./starrocks_prepare.sql

CREATE database demo;
use demo;

CREATE table upsert_table(
    user_id int,
    target_id text,
    event_timestamp_local datetime
) ENGINE=OLAP
PRIMARY KEY(`user_id`)
DISTRIBUTED BY HASH(`user_id`) properties("replication_num" = "1");

CREATE USER 'users'@'%' IDENTIFIED BY '123456';
GRANT ALL ON *.* TO 'users'@'%';

3. Execute the SQL queries in sequence:

• create_source.sql
• create_mv.sql
• create_sink.sql
• update_delete.sql

We only support upsert with starrocks' PRIMARY KEY

Run the following query

select user_id, count(*) from demo.upsert_table group by user_id;