flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-3942) Add support for INTERSECT
Date Fri, 24 Jun 2016 12:45:16 GMT

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

ASF GitHub Bot commented on FLINK-3942:
---------------------------------------

GitHub user wuchong opened a pull request:

    https://github.com/apache/flink/pull/2159

    [FLINK-3942] [tableAPI] Add support for INTERSECT

    Internally, I translate INTERSECT into a Join on all fields and then a distinct for removing
duplicate records. 
    
    As Calcite SQL Parser doesn't support `INTERSECT ALL` , so I didn't add `intersectAll()`
function to `Table`.
    
    I can add the corresponding documents if needed. 

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/wuchong/flink INTERSECT

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/flink/pull/2159.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #2159
    
----
commit a666a3aabb01090eb3c6205b28e54a0dbb2e8a05
Author: Jark Wu <wuchong.wc@alibaba-inc.com>
Date:   2016-06-24T11:57:09Z

    [FLINK-3942] [tableAPI] Add support for INTERSECT

----


> Add support for INTERSECT
> -------------------------
>
>                 Key: FLINK-3942
>                 URL: https://issues.apache.org/jira/browse/FLINK-3942
>             Project: Flink
>          Issue Type: New Feature
>          Components: Table API & SQL
>    Affects Versions: 1.1.0
>            Reporter: Fabian Hueske
>            Assignee: Jark Wu
>            Priority: Minor
>
> Currently, the Table API and SQL do not support INTERSECT.
> INTERSECT can be executed as join on all fields.
> In order to add support for INTERSECT to the Table API and SQL we need to:
> - Implement a {{DataSetIntersect}} class that translates an INTERSECT into a DataSet
API program using a join on all fields.
> - Implement a {{DataSetIntersectRule}} that translates a Calcite {{LogicalIntersect}}
into a {{DataSetIntersect}}.
> - Extend the Table API (and validation phase) to provide an intersect() method.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message