yuemeng created FLINK-7145:
------------------------------
Summary: Flink SQL API should support multiple parameters for
UserDefinedAggFunction
Key: FLINK-7145
URL: https://issues.apache.org/jira/browse/FLINK-7145
Project: Flink
Issue Type: New Feature
Components: Table API & SQL
Reporter: yuemeng
Priority: Critical
UDAF such as topK and some other udaf with bloom filter need more than one
parameters ,we should make flink sql support this.
base on flink sql support DML and multiple parameters udaf,we can execute sql
like:
{code}
CREATE TEMPORARY function 'TOPK' AS
'com.xxxx.aggregate.udaf.distinctUdaf.topk.ITopKUDAF';
INSERT INTO db_sink SELECT id, TOPK(price, 5, 'DESC') FROM kafka_source GROUP
BY id;
{code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
