[
https://issues.apache.org/jira/browse/FLINK-7145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16082016#comment-16082016
]
yuemeng commented on FLINK-7145:
--------------------------------
[~jark]
TopN with different accumulate(...),there are some question:
1)which accumulate method should be be called in agg function since agg
function only call accumulate ,no other operations to find the exact
accumulate method
2) suppose UDAF such as topN have multiple parameters with different type,How
to ensure that the correct function can be matched
> 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
>
> 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)
