flink将rowdata封装为datastream

在 Flink 中，可以通过使用 `StreamExecutionEnvironment` 来创建 `DataStream`。`DataStream` 可以从多种数据来源创建，其中之一是使用 `StreamTableEnvironment` 将表转换为 `DataStream`。以下是一个示例代码，将 `RowData` 封装为 `DataStream`：

import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
import org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl;
import org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.DataStreamProvider;

// 创建 StreamExecutionEnvironment
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

// 创建 StreamTableEnvironment
StreamTableEnvironment tableEnv = StreamTableEnvironmentImpl.create(env);

// 创建DataStreamProvider，传入RowData类型的Schema信息
DataStreamProvider<RowData> provider = new DataStreamProvider<>(dataStream, rowType);

// 将DataStreamProvider转换为DataStream
DataStream<RowData> dataStream = tableEnv.fromDataStream(provider);

在上述代码中，`DataStreamProvider` 是一个用于将 `RowData` 转换为 `DataStream` 的类。它需要传入 `RowData` 的 `Schema` 信息。`tableEnv.fromDataStream()` 方法将 `DataStreamProvider` 转换为 `DataStream`。