Hi Wei, Thanks for the discussion! Overall, + 1 for this FLIP. One question is, can the @udaf added by flip-137 be used in General Python UDAF? Would be gread if we can consider it combination with FLIP-137 for design.
What do you think? Best, Jincheng Wei Zhong <weizhong0...@gmail.com> 于2020年8月26日周三 上午11:28写道： > Hi everyone, > > I would like to start discussion about how to support General Python > User-Defined Aggregate Function on Table API. > > FLIP-58[1] has already introduced the stateless Python UDF and has already > been supported in the previous releases. However the stateful Python UDF, > i.e. User-Defined Aggregate Function is not supported in PyFlink yet. We > want to introduce the general Python user-defined aggregate function for > PyFlink Table API. > > Here is the design doc: > > > https://cwiki.apache.org/confluence/display/FLINK/FLIP-139%3A+General+Python+User-Defined+Aggregate+Function+Support+on+Table+API > > Looking forward to your feedback! > > Best, > Wei > > [1] > https://cwiki.apache.org/confluence/display/FLINK/FLIP-58%3A+Flink+Python+User-Defined+Stateless+Function+for+Table > >
