WindowFunction函数参数传递

Question

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

Answer 1

Michael_PK 2019-06-13 19:53:20

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

• 提问者 passmefive #1

  那第三个参数呢。应该如何传入什么样的参数。或者说应该根据什么依据传入参数呢

• Michael_PK 回复 提问者 passmefive #2

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