Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id B11F1200ABE for ; Fri, 20 May 2016 11:31:14 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id AFCE51609AF; Fri, 20 May 2016 09:31:14 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 05363160A0E for ; Fri, 20 May 2016 11:31:13 +0200 (CEST) Received: (qmail 92571 invoked by uid 500); 20 May 2016 09:31:13 -0000 Mailing-List: contact dev-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list dev@flink.apache.org Received: (qmail 92541 invoked by uid 99); 20 May 2016 09:31:13 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 20 May 2016 09:31:13 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id DB4D12C14F8 for ; Fri, 20 May 2016 09:31:12 +0000 (UTC) Date: Fri, 20 May 2016 09:31:12 +0000 (UTC) From: "Fabian Hueske (JIRA)" To: dev@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Created] (FLINK-3942) Add support for INTERSECT MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Fri, 20 May 2016 09:31:14 -0000 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)