flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Fabian Hueske (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-3942) Add support for INTERSECT
Date Fri, 20 May 2016 09:31:12 GMT
Fabian Hueske created FLINK-3942:
------------------------------------

             Summary: 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
    Affects Versions: 1.1.0
            Reporter: Fabian Hueske
            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