WindowFunction函数参数传递

来源:11-11 WindowFunction业务逻辑的实现

passmefive

2019-06-13

Hi,PK哥,请问一下这个WindowFunction函数中的第三个参数,与第四个参数,应该如何确定传入什么参数啊, 这次是 Tuple,TimeWindow,但不是很清楚下次我应该如何传递参数。
.apply(new WindowFunction[(Long, String, Long), (String, String, Long), Tuple, TimeWindow]

写回答

1回答

Michael_PK

2019-06-13

第四个参数是这个TimeWindow,只要传入实现了TimeWindow的子类都是可以的

0
2
Michael_PK
回复
passmefive
根据那个tuple具体的类型传入就行,人家要什么就传什么
2019-06-13
共2条回复

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势,多语言系统化讲解,极速入门Flink

969 学习 · 296 问题

查看课程