网站介绍:文章浏览阅读1k次。6.5 侧输出流(sideOutput)6.5.1 功能1:处理允许迟到后迟到的数据允许迟到数据,窗口也会真正的关闭,如果允许迟到后,还是有迟到的数据怎么办?Flink提供一种侧输出流的机制来处理关窗之后到达的数据。public class Flink19_Watermark_SideOutput { public static void main(String[] args) throws Exception { StreamExecutionEnvironment env _flink侧边流怎么清理
- 链接地址:https://blog.csdn.net/qq_43523503/article/details/114958749
- 链接标题:Flink侧输出流机制_flink侧边流怎么清理-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:6479
- 网站标签:flink侧边流怎么清理