flink 1.15版本，table转成datastream

在 Flink 1.15 版本中，可以通过将 Table 转换为 DataStream 来实现基于 SQL 的流处理。

具体步骤如下：

1. 创建 StreamExecutionEnvironment 对象，并设置相关参数。

2. 创建 StreamTableEnvironment 对象，并设置相关参数。

3. 使用 TableEnvironment 对象注册数据源表，并创建 Table 对象。

4. 将 Table 对象转换为 DataStream 对象，可以通过 toAppendStream()、toRetractStream()、toChangelogStream() 等方法来实现。

下面是一个简单的示例代码，将 Table 转换为 DataStream：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);

// 注册数据源表
tableEnv.executeSql("CREATE TABLE source_table (id INT, name STRING) WITH (...)");
Table sourceTable = tableEnv.from("source_table");

// 将 Table 转换为 DataStream
DataStream<Tuple2<Boolean, Row>> resultStream = tableEnv.toRetractStream(sourceTable, Row.class);

需要注意的是，Flink 1.15 中的 Table API 和 SQL 支持了更多的数据类型，如 MAP、ARRAY、ROW 等，可以更方便地进行数据处理。