[
https://issues.apache.org/jira/browse/FLINK-7145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081861#comment-16081861
]
Fabian Hueske commented on FLINK-7145:
--------------------------------------
[~yumegn] I see.
But that's a different issue than the title and description of this JIRA report.
Also, is this a problem with Calcite only or do we also need to fix something
in Flink?
Please update the title and description appropriately and try to be as specific
as possible when reporting issue or suggesting features.
> 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)
