flink 中 source-to-query schema 怎么使用

Flink的source-to-query（源到查询）模式是一种设计理念，它允许用户在编写SQL查询时直接指定数据源，而无需显式地创建表并将其与数据源关联。这种模式简化了数据处理流程，特别是在数据管道需要频繁变化或从多种源头获取数据的情况下。

在Flink中，你可以通过以下步骤来利用source-to-query模式：

1. **数据源声明**：在SQL查询中，使用`CREATE TABLE`语句声明数据源，并指定其类型，如Kafka、Hive表、文件系统等。例如：

   CREATE TABLE my_data (
       id INT,
       name STRING,
       timestamp TIMESTAMP(3)
   ) WITH (
       'connector' = 'kafka',
       'topic' = 'my-topic',
       'properties.bootstrap.servers' = 'localhost:9092'
   );

2. **SQL查询**：一旦数据源声明完毕，就可以像操作常规数据库一样编写SQL查询来读取数据、转换、过滤和聚合数据，无需显式连接表。

   SELECT * FROM my_data WHERE timestamp > NOW() - INTERVAL '1 DAY';

3. **自动连接和执行**：Flink会根据查询中的数据源描述动态连接数据源并在运行时执行相应的查询逻辑。