本文重点

在前面的课程中，无论是窗口联结还是间隔联结，都会将两条流中的元素进行两两匹配，然后分别以第一个元素和第二个元素的方式输入到处理函数中，如果我们不想这样匹配该如何操作？

API

apply()传入一个CoGroupFunction，它的定义如下：

public interface CoGroupFunction<IN1, IN2, O> extends Function, Serializable { void coGroup(Iterable<IN1> first, Iterable<IN2> second, Collector<O> out) throws Exception; }

关键方法是coGroup，其中第一个元素表示当前窗口下的第一条流中的所有元素事件，第二个元素表示当前窗口下的第二条流中的所有元素事件，可以看到这里不再是匹配的数据了，而是每条流的数据集合，我们可以自己定义如何匹配了。

import org.apache.flink.api.common.eventtime.SerializableTimestampAssigner; import org.apache.flink.api.common.eventtime.WatermarkStrategy; import org.apache.flink