4、Flink SQL 与 DataStream API 集成处理 Insert-Only 流详解_flink datastream api与flinksql 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 流，默认流 record 类型为 org.apache.flink.types.Row，会将单个 rowtime 属性列写回到DataStream API 的记录中，水印也会传播。

• toDataStream(Table,AbstractDataType)：将表转换为 insert-only 流，此方法接受一个数据类型来表