flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Shuyi Chen (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL
Date Mon, 28 Aug 2017 20:17:01 GMT

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

Shuyi Chen commented on FLINK-7491:

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) for array.
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

View raw message