Flink中DataStream<String> 转DataStream有大佬便捷的写法？

可以使用Flink的Table API将DataStream转换为DataStream<org.apache.flink.table.data.RowData>。以下是一个示例代码：

DataStream<RowData> rowDataStream = env.fromElements(row1, row2, row3);
DataStream<org.apache.flink.table.data.RowData> tableRowDataStream = rowDataStream
    .map(new Function<RowData, org.apache.flink.table.data.RowData>() {
        @Override
        public org.apache.flink.table.data.RowData apply(RowData input) {
            return RowDataConverter.toTableRowData(input);
        }
    });

在上面的代码中，我们首先创建了一个包含三个RowData对象的数据流rowDataStream。然后，我们使用map()函数将每个RowData对象映射到一个org.apache.flink.table.data.RowData对象，并将其存储在一个新的数据流tableRowDataStream中。在映射过程中，我们使用了RowDataConverter类来将原始的RowData对象转换为TableRowData对象。