Huang Xingbo created FLINK-20507: ------------------------------------ Summary: Support Aggregate Operation in Python Table API Key: FLINK-20507 URL: https://issues.apache.org/jira/browse/FLINK-20507 Project: Flink Issue Type: Sub-task Components: API / Python Reporter: Huang Xingbo Fix For: 1.13.0
Support Python UDAF for Aggregate Operation in Python Table API The usage: {code:java} t = ... # type: Table, table schema: [a: String, b: Int, c: Int] # aggregate General Python UDAF t_env.create_temporary_function("agg", GeneralPythonAggregateFunction()) t.group_by(t.c).select("agg(a)") # aggregate Pandas UDAF mean_max_udaf = udaf(lambda a: Row(a.mean(), a.max()), result_type=DataTypes.ROW( [DataTypes.FIELD("a", DataTypes.FLOAT()), DataTypes.FIELD("b", DataTypes.INT()), func_type="pandas") t.group_by(t.a).aggregate(mean_max_udaf(t.b).alias("d", "f")).select("a, d, f"){code} -- This message was sent by Atlassian Jira (v8.3.4#803005)