Flink中Window详解之Window的API

Flink中Window详解之Window的API

stream.keyBy(...) // 是Keyed类型数据集 .window(...) //指定窗口分配器类型 [.trigger(...)] //指定触发器类型（可选） [.evictor(...)] //指定evictor或者不指定（可选） [.allowedLateness(...)] //指定是否延迟处理数据（可选） [.sideOutputLateData(...)] //指定Output Lag（可选） .reduce/aggregate/fold/apply() //指定窗口计算函数[.getSideOutput(...)] //根据Tag输出数据（可选）

Windows Assigner：指定窗口的类型，定义如何将数据流分配到一个或多个窗口； Windows Trigger：指定窗口触发的时机，定义窗口满足什么样的条件触发计算； Evictor：用于数据剔除； allowedLateness：标记是否处理迟到数据，当迟到数据到达窗口中是否触发计算； Output Tag：标记输出标签，然后在通过 getSideOutput 将窗口中的数据根据标签输出； Windows Funciton：定义窗口上数据处理的逻辑，例如对数据进行 sum 操作。

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。