[jira] [Created] (FLINK-3942) Add support for INTERSECT

[Shang Yuanchun (Jira)]

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)