榆林市网站建设_网站建设公司_Django_seo优化

本文重点

前面的课程中我们学习了KeyedProcessFunction，本文我们将学习另外一种类型的处理函数----基于窗口的处理函数ProcessWindowFunction。

全窗口函数和处理函数之间的关系

ProcessWindowFunction既是处理函数又是全窗口函数。

ProcessAllWindowFunction既是处理函数又是全窗口函数。

本文我们从处理函数的角度，来学习它们的使用方法。

ProcessWindowFunction

public abstract class ProcessWindowFunction<IN, OUT, KEY, W extends Window> extends AbstractRichFunction { ... public abstract void process( KEY key, Context context, Iterable<IN> elements, Collector<OUT> out) throws Exception; public void clear(Context context) throws Exception {} public abstract class Context implements java.io.Serializable {...} }

ProcessWindowFunction是一个继承了 AbstractRichFunction 的抽象类，它有四个类型参数：