Flink Window中的window 和 apply()方法详解_flink apply-CSDN博客

网站介绍:文章浏览阅读5.4k次,点赞2次,收藏6次。简介: 前面讲解的3中Window窗口案例中,尤其是时间窗口TimeWindow中,没有看见Window大小(起始时间,结束时间),使用apply函数,就可以获取窗口大小。import org.apache.commons.lang3.time.FastDateFormat;import org.apache.flink.api.common.functions.MapFunction;import org.apache.flink.api.java.tuple.Tuple;import org._flink apply