处理 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 流,此方法接受一个数据类型来表