Flink中window Trigger的理解

初识Flink,对于window相关的几个概念不甚了解,先抛出几个关键问题!java window是如何划分的? watermark生成方式?多久产生一次? window触发计算条件? 延迟数据如何处理? 1、window是如何划分的? window的划分与数据自己无关,而是由系统定义好的。web dataStreamSource.flatMap(new MyFlatMapFunction())
相关文章
相关标签/搜索