向您问好,
我是一名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的示例, 我将不胜感激！
提前感谢您的帮助！
马宏元
