Huang Xingbo created FLINK-19169: ------------------------------------ Summary: Support Pandas UDAF in PyFlink (FLIP-137) Key: FLINK-19169 URL: https://issues.apache.org/jira/browse/FLINK-19169 Project: Flink Issue Type: Improvement Components: API / Python Reporter: Huang Xingbo Fix For: 1.12.0
Pandas UDF has been supported in FLINK 1.11 ([FLIP-97|https://cwiki.apache.org/confluence/display/FLINK/FLIP-97%3A+Support+Scalar+Vectorized+Python+UDF+in+PyFlink]). It solves the high serialization/deserialization overhead in Python UDF and makes it convenient to leverage the popular Python libraries such as Pandas, Numpy, etc. Since Pandas UDF has so many advantages, we want to support Pandas UDAF to extend usage of Pandas UDF. -- This message was sent by Atlassian Jira (v8.3.4#803005)