Hequn Cheng created FLINK-7578:
----------------------------------
Summary: WindowStream should support rich AggregateFunction
Key: FLINK-7578
URL: https://issues.apache.org/jira/browse/FLINK-7578
Project: Flink
Issue Type: Improvement
Components: DataStream API, Table API & SQL
Reporter: Hequn Cheng
Currently, {{WindowedStream}} does not support Rich AggregateFunction which
makes users can not use user defined aggregate functions in table-api/sql.
Because user code class loader is beyond reach in {{AggregateAggFunction}}.
As shown in the following example,
{quote}
select a,udagg1(b), udagg2(c)
from Table as T
GROUP BY a, TUMBLE(processTime, interval '1' minute);
{quote}
Exceptions will be throwed when call {{initFunction()}} in
{{AggregateAggFunction}}.
As user defined aggregations are widely used in table-api/sql, it is valuable
to support Rich AggregateFunction for {{WindowStream}}.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
