You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "yuemeng (JIRA)" <ji...@apache.org> on 2017/07/11 07:50:00 UTC
[jira] [Created] (FLINK-7145) Flink SQL API should support multiple
parameters for UserDefinedAggFunction
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)