flinksql 汇总订单明细的金额，数量 实时展示

在Flink SQL中，可以通过编写SQL查询语句来实时汇总订单明细的金额和数量，并进行展示。以下是一个示例，展示了如何使用Flink SQL实现这一功能。

假设我们有一个订单明细表`order_details`，包含以下字段：
- `order_id`：订单ID
- `product_id`：产品ID
- `amount`：金额
- `quantity`：数量
- `order_time`：订单时间

我们希望实时汇总每个订单的金额和数量，并将结果展示出来。

-- 创建订单明细表
CREATE TABLE order_details (
    order_id STRING,
    product_id STRING,
    amount DOUBLE,
    quantity INT,
    order_time TIMESTAMP(3),
    WATERMARK FOR order_time AS order_time - INTERVAL '5' SECOND
) WITH (
    'connector' = 'kafka',
    'topic' = 'order_details_topic',
    'properties.bootstrap.servers' = 'localhost:9092',
    'format' = 'json'
);

-- 创建结果表，用于展示汇总结果
CREATE TABLE order_summary (
    order_id STRING,
    total_amount DOUBLE,
    total_quantity INT,
    window_start TIMESTAMP(3),
    window_end TIMESTAMP(3)
) WITH (
    'connector' = 'kafka',
    'topic' = 'order_summary_topic',
    'properties.bootstrap.servers' = 'localhost:9092',
    'format' = 'json'
);

-- 实时汇总订单金额和数量
INSERT INTO order_summary
SELECT
    order_id,
    SUM(amount) AS total_amount,
    SUM(quantity) AS total_quantity,
    TUMBLE_START(order_time, INTERVAL '1' MINUTE) AS window_start,
    TUMBLE_END(order_time, INTERVAL '1' MINUTE) AS window_end
FROM
    order_details
GROUP BY
    order_id,
    TUMBLE(order_time, INTERVAL '1' MINUTE);

在这个示例中：
1. 我们首先创建了一个订单明细表`order_details`，并指定了Kafka作为数据源。
2. 然后，我们创建了一个结果表`order_summary`，用于存储汇总结果。
3. 最后，我们使用Flink SQL的窗口函数`TUMBLE`对订单明细进行1分钟的滚动窗口聚合，并插入到结果表中。

通过这种方式，我们可以实时汇总订单的金额和数量，并将结果展示出来。