Thanks for bring up this discussion Xingbo! The the design is pretty nice for me! This feature is really need which mentioned in FLIP-58. So, I think is better to create the JIRA and open the PR, then more detail can be reviewed. :)
Best, Jincheng Xingbo Huang <hxbks...@gmail.com> 于2020年2月3日周一 下午3:02写道： > Hi all, > > The scalar Python UDF has already been supported in coming release of 1.10, > we’d like to introduce Python UDTF now. FLIP-58[1] has already introduced > some content about Python UDTF. However, the implementation details are > still not touched. I have drafted a design doc[2]. It includes the > following items: > > - How to define Python UDTF. > > - The introduced rules for Python UDTF. > > - How to execute Python UDTF. > > Because the implementation relies on Beam's portability framework for > Python user-defined table function execution and not all the contributors > are familiar with it, I have done a prototype[3]. > > Welcome any feedback. > > Best, > > Xingbo > > [1] > > https://cwiki.apache.org/confluence/display/FLINK/FLIP-58%3A+Flink+Python+User-Defined+Stateless+Function+for+Table > > [2] > > https://docs.google.com/document/d/1Pkv5S0geoYQ2ySS5YTTBivJ3hoi-uzLXVQkDVIaR0cE/edit#heading=h.pzeztvig3kg1 > [3] https://github.com/HuangXingBo/flink/commits/FLINK-UDTF >
