flink sql shell demo

以下是 Flink SQL Shell 的示例：

1. 启动 Flink 集群：

$ start-cluster.sh

2. 启动 Flink SQL Shell：

$ ./bin/sql-client.sh embedded

3. 在 Flink SQL Shell 中创建表：

CREATE TABLE orders (
    order_id INT,
    customer_id INT,
    order_time TIMESTAMP(3),
    order_total DECIMAL(10, 2),
    PRIMARY KEY (order_id) NOT ENFORCED
) WITH (
    'connector' = 'kafka',
    'topic' = 'orders',
    'properties.bootstrap.servers' = 'localhost:9092',
    'properties.group.id' = 'orders_group',
    'format' = 'json',
    'json.fail-on-missing-field' = 'false'
);

4. 在 Flink SQL Shell 中查询表：

SELECT *
FROM orders
WHERE order_total > 100.0;

5. 在 Flink SQL Shell 中退出：

!quit

注意：在实际操作中，需要根据实际情况修改表的定义和查询语句。此示例仅供参考。