Re: [DISCUSS] Support User-Defined Table Function in PyFlink

2020-02-04 Thread Xingbo Huang
Hi Hequn, Thanks for your feedback. Good suggestion. I will avoid Scala code in the flink-table module. Best, Xingbo Hequn Cheng 于2020年2月4日周二 下午10:14写道: > Hi Xingbo, > > Thanks a lot for bringing up the discussion. Looks good from my side. > One suggestion beyond the document: it would be

Re: [DISCUSS] Support User-Defined Table Function in PyFlink

2020-02-04 Thread Xingbo Huang
Hi Jincheng, Thanks for your feed back. The more details we can discussed in the JIRA and PR. :) Best, Xingbo jincheng sun 于2020年2月4日周二 下午9:09写道: > 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.

Re: [DISCUSS] Support User-Defined Table Function in PyFlink

2020-02-04 Thread Hequn Cheng
Hi Xingbo, Thanks a lot for bringing up the discussion. Looks good from my side. One suggestion beyond the document: it would be nice to avoid Scala code in the flink-table module since we would like to get rid of Scala in the long-term[1][2]. Best, Hequn [1]

Re: [DISCUSS] Support User-Defined Table Function in PyFlink

2020-02-04 Thread jincheng sun
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 于2020年2月3日周一 下午3:02写道: > Hi

[DISCUSS] Support User-Defined Table Function in PyFlink

2020-02-02 Thread Xingbo Huang
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