Flink如何用窗格来优化窗口

1.可以使用主键选择函数方法代码如下

2.实现在POJO类型中指定字段名称的方法代码

3.使用的是Flink tuple类型--》那么只要简单地指定字段元组的位置--》可以被用作主键了代码如下

4.可读性的代码

5.创建一个类--》该类需要继承TupleX类--》为类里面的这些字段实现getter和setter。

6.实现可以用来提高Flink应用程序性能的选项是当从用户定义的函数返回数据时使用可变对象代码如下

7.新建一个Tuple2类的实例--》因此增加了对垃圾收集器的压力--》解决这个问题的一种方法是反复使用相同的实例代码如下