[ https://issues.apache.org/jira/browse/FLINK-3941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15297679#comment-15297679 ]
ASF GitHub Bot commented on FLINK-3941: --------------------------------------- GitHub user yjshen opened a pull request: https://github.com/apache/flink/pull/2025 [FLINK-3941][TableAPI]Add support for UNION (with duplicate elimination) This PR aims at adding `UNION` support in TableAPI and SQL by: - Extending Table API with a new `union()` method - Relaxing `DataSetUnionRule` to enable union conversion - a `distinct` after `union` in flink execution plan to eliminate duplicate rows Note: Currently, I think `Union` do not has its counterpart in DataStream, therefore left unsupported. If it's not true, I'd like to adapt this PR. You can merge this pull request into a Git repository by running: $ git pull https://github.com/yjshen/flink union Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/2025.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 #2025 ---- commit fb8b61b5638f0b52f5857341c7acc95e8985b2d4 Author: Yijie Shen <henry.yijies...@gmail.com> Date: 2016-05-24T04:46:21Z add union support ---- > Add support for UNION (with duplicate elimination) > -------------------------------------------------- > > Key: FLINK-3941 > URL: https://issues.apache.org/jira/browse/FLINK-3941 > Project: Flink > Issue Type: New Feature > Components: Table API > Affects Versions: 1.1.0 > Reporter: Fabian Hueske > Assignee: Yijie Shen > Priority: Minor > > Currently, only UNION ALL is supported by Table API and SQL. > UNION (with duplicate elimination) can be supported by applying a > {{DataSet.distinct()}} after the union on all fields. This issue includes: > - Extending {{DataSetUnion}} > - Relaxing {{DataSetUnionRule}} to translated non-all unions. > - Extend the Table API with union() method. -- This message was sent by Atlassian JIRA (v6.3.4#6332)