Flink+Paimon+StarRocks 构建实时分析
参考：揭秘“湖仓一体”——Flink+Paimon+StarRocks，打造实时分析新纪元_paimon starrocks-CSDN博客
步骤一:准备演示数据
- 在MySQL中执行以下命令，创建数据表。
USE emp;-- 用户表
CREATE TABLE users (user_id BIGINT AUTO_INCREMENT PRIMARY KEY COMMENT '用户ID，主键',user_name VARCHAR(50) NOT NULL COMMENT '用户名',email VARCHAR(100) NOT NULL COMMENT '邮箱',registration_date DATE NOT NULL COMMENT '注册日期'
) COMMENT '用户表';INSERT INTO users (user_id, user_name, email, registration_date) VALUES
(1, '张山', 'alice@example.com', '2023-01-15'),
(2, '李四', 'bob@example.com', '2023-02-20'),
(3, '刘博', 'charlie@example.com', '2023-03-10');-- 订单表
CREATE TABLE orders (order_id BIGINT AUTO_INCREMENT PRIMARY KEY COMMENT '订单ID，主键',user_id BIGINT NOT NULL COMMENT '用户ID，外键，关联到users表',order_date DATE NOT NULL COMMENT '订单日期',total_amount DECIMAL(10, 2) NOT NULL COMMENT '订单总金额',FOREIGN KEY (user_id) REFERENCES users(user_id)
) COMMENT '订单表';INSERT INTO orders (user_id, order_date, total_amount) VALUES
(1, '2023-04-01', 150.00),
(2, '2023-04-05', 200.00),
(3, '2023-04-10', 250.00),
(1, '2023-04-15', 300.00);-- 商品表
CREATE TABLE products (product_id BIGINT AUTO_INCREMENT PRIMARY KEY COMMENT '产品ID，主键',product_name VARCHAR(100) NOT NULL COMMENT '产品名',price DECIMAL(10, 2) NOT NULL COMMENT '产品价格'
) COMMENT '产品表';INSERT INTO products (product_name, price) VALUES
('笔记本', 50.00),
('手表', 75.00),
('耳机', 100.00);-- 订单详情表
CREATE TABLE order_details (order_detail_id BIGINT AUTO_INCREMENT PRIMARY KEY COMMENT '订单详情ID，主键',order_id BIGINT NOT NULL COMMENT '订单ID，外键，关联到orders表',product_id BIGINT NOT NULL COMMENT '产品ID，外键，关联到products表',quantity INT NOT NULL COMMENT '购买数量',subtotal DECIMAL(10, 2) NOT NULL COMMENT '小计金额（quantity * price）',FOREIGN KEY (order_id) REFERENCES orders(order_id),FOREIGN KEY (product_id) REFERENCES products(product_id)
) COMMENT '订单详情表';-- 演示数据
INSERT INTO order_details (order_id, product_id, quantity, subtotal) VALUES
(1, 1, 2, 100.00),
(1, 2, 1, 50.00),
(2, 1, 1, 50.00),
(2, 3, 2, 150.00),
(3, 2, 2, 150.00),
(3, 3, 1, 100.00),
(4, 3, 3, 300.00);
SHOW VARIABLES LIKE 'log_bin';
