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 22:54:16 GMT

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

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

Github user fhueske commented on a diff in the pull request:

    https://github.com/apache/flink/pull/2159#discussion_r68473826
  
    --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/table.scala
---
    @@ -446,6 +446,31 @@ class Table(
       }
     
       /**
    +    * Intersect two [[Table]]s with duplicate records removed. Intersect returns rows
only
    --- End diff --
    
    The description of intersect suggests that the same row is emitted twice if it appears
two times in the left table which is not correct. Rows that appear in both inputs are emitted
exactly once.


> 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