WindowFunction函数参数传递

首页课程实战体系课手记专栏慕课教程

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

Michael_PK

2019-06-13

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

0

2

Michael_PK

回复

passmefive

根据那个tuple具体的类型传入就行，人家要什么就传什么

2019-06-13

共2条回复

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

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

969 学习 · 296 问题

相似问题

老师：RichMapFunction 这个函数能通俗解释一下作用么，为什么做计数器的时候要用到这个啊，还有其他的函数可以辅助完成计数器的功能吗

回答 2

为什么readCsvFile方法里面没有设置字符集的参数？我输出的时候中文是乱码？

回答 1

flink1.11的yarn-session废弃了-n参数

回答 1

大数据面试经验

回答 1

关于官网中session window的讨论

回答 1

打开慕课网App查看更多内容