[ 
https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16144282#comment-16144282
 ] 

Shuyi Chen edited comment on FLINK-7491 at 8/29/17 11:15 PM:
-------------------------------------------------------------

Hi [~jark], thanks for the response. However, I am worried with Array as the 
runtime type, multiset specific operation will be slow, for example.

MEMBER OF operator is *O(1)* for multiset data structure and 
{code:java}
*O(n)*
{code}

SUBMULTISET OF operator is *O(m+n)* for array, and *O(m)* for multiset if to 
test M < N.

Also the actual type I am using is HashMultiset, which is backed by a java 
HashMap<E, MutableInteger>, which I think should perform reasonably well.


was (Author: suez1224):
Hi [~jark], thanks for the response. However, I am worried with Array as the 
runtime type, multiset specific operation will be slow, for example.

MEMBER OF operator is *O(1)* for multiset data structure and *O(n)*
SUBMULTISET OF operator is *O(m+n)* for array, and *O(m)* for multiset if to 
test M < N.

Also the actual type I am using is HashMultiset, which is backed by a java 
HashMap<E, MutableInteger>, which I think should perform reasonably well.

> Support COLLECT Aggregate function in Flink SQL
> -----------------------------------------------
>
>                 Key: FLINK-7491
>                 URL: https://issues.apache.org/jira/browse/FLINK-7491
>             Project: Flink
>          Issue Type: New Feature
>          Components: Table API & SQL
>            Reporter: Shuyi Chen
>            Assignee: Shuyi Chen
>




--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to