Greetings,
I am a newbie to pyflink. I want to be able to use processWindowFunction in a Tumble Window, and finally output 0 or more lines. I have checked the datastreamAPI and TableAPI of pyflink, but have not found a complete example. pyflink's datastream API does not seem to implement window() yet. And I'm not sure how to use TableAPI. If I use java to implement "public class MyProcessWindowFunctextends ProcessWindowFunction” and registered as udf in python, is it possible to call it through select statement in pyflink? Can the select statement correctly return zero or more rows of results? Any help will be appreciated! ----- Best Regards, Hongyuan Ma
