4、Flink SQL 与 DataStream API 集成处理 Insert-Only 流详解

StreamTableEnvironment 提供以下方法来从 DataStream 转换和转换到 DataStream：

fromDataStream(DataStream)：将 insert-only 和任意类型的流转换为表，默认情况下不传播事件时间和水印。
fromDataStream(DataStream,Schema)：将 insert-only 和任意类型的流转化为表，可选模式允许丰富列数据类型，并添加时间属性、水印策略、其它计算列或主键。
createTemporaryView(String,DataStream)：根据流创建 view，以便在 SQL 中访问它，它是 createTemporaryView(String,fromDataStream(DataStream)) 的快捷方式。
createTemporaryView(String,DataStream,Schema)：根据流创建 view，以便在 SQL 中访问它，它是 createTemporaryView(String,fromDataStream(DataStream,Schema)) 的快捷方式。
toDataStream(Table)：将表转换为 insert-only 流，默认流

标签： flink sql 大数据

本文转载自: https://blog.csdn.net/m0_50186249/article/details/140979285
版权归原作者 猫猫爱吃小鱼粮 所有，如有侵权，请联系我们删除。