[jira] [Created] (FLINK-20507) Support Aggregate Operation in Python Table API

[Shang Yuanchun (Jira)]

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)