如何在pyflink中使用全量窗口聚合ProcessWindowFunction

[Hongyuan Ma]

向您问好,


我是一名pyflink的新手。我希望能够在Tumble Window中使用processWindowFunction， 对窗口内数据进行全量计算并最终输出0行或者多行。我查阅了pyflink的datastreamAPI和TableAPI,都没有找到完整的示例。pyflink 的datastreamAPI目前似乎还没有实现window()。而我对TableAPI的使用方法还不太明确。
假如我使用java实现了“public class MyProcessWindowFunctextends ProcessWindowFunction {}”, 打成jar包在pyflink中注册为udf,
有可能在TableAPI中通过select语句调用它吗, select语句可以正确地返回0行或者多行结果吗？如果能提供一个pyflink简单的 processWindowFunction的示例, 我将不胜感激！




提前感谢您的帮助！
马宏元