Flink侧输出流机制_flink侧边流怎么清理-CSDN博客

网站介绍:文章浏览阅读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侧边流怎么清理