Return-Path: X-Original-To: apmail-flink-dev-archive@www.apache.org Delivered-To: apmail-flink-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id DB42018D69 for ; Thu, 7 Jan 2016 17:36:52 +0000 (UTC) Received: (qmail 45049 invoked by uid 500); 7 Jan 2016 17:36:52 -0000 Delivered-To: apmail-flink-dev-archive@flink.apache.org Received: (qmail 44978 invoked by uid 500); 7 Jan 2016 17:36:52 -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 44967 invoked by uid 99); 7 Jan 2016 17:36:52 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 07 Jan 2016 17:36:52 +0000 Received: from mail-yk0-f179.google.com (mail-yk0-f179.google.com [209.85.160.179]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id 5651F1A0015 for ; Thu, 7 Jan 2016 17:36:52 +0000 (UTC) Received: by mail-yk0-f179.google.com with SMTP id k129so315006718yke.0 for ; Thu, 07 Jan 2016 09:36:52 -0800 (PST) MIME-Version: 1.0 X-Received: by 10.129.156.139 with SMTP id t133mr70184087ywg.288.1452188211612; Thu, 07 Jan 2016 09:36:51 -0800 (PST) Received: by 10.13.204.206 with HTTP; Thu, 7 Jan 2016 09:36:51 -0800 (PST) In-Reply-To: References: <568E78ED.9080603@apache.org> Date: Thu, 7 Jan 2016 18:36:51 +0100 X-Gmail-Original-Message-ID: Message-ID: Subject: Re: Effort to add SQL / StreamSQL to Flink From: Kostas Tzoumas To: "dev@flink.apache.org" Content-Type: multipart/alternative; boundary=94eb2c0c047a801c110528c1eaf5 --94eb2c0c047a801c110528c1eaf5 Content-Type: text/plain; charset=UTF-8 Wow! Thanks Fabian, this looks fantastic! On Thu, Jan 7, 2016 at 4:35 PM, Stephan Ewen wrote: > Super, thanks for that detailed effort, Fabian! > > On Thu, Jan 7, 2016 at 3:40 PM, Matthias J. Sax wrote: > > > Pretty cool! > > > > On 01/07/2016 03:05 PM, Fabian Hueske wrote: > > > Hi everybody, > > > > > > in the last days, Timo and I refined the design document for adding a > > SQL / > > > StreamSQL interface on top of Flink that was started by Stephan. > > > > > > The document proposes an architecture that is centered around Apache > > > Calcite. Calcite is an Apache top-level project and includes a SQL > > parser, > > > a semantic validator for relational queries, and a rule- and cost-based > > > relational optimizer. Calcite is used by Apache Hive and Apache Drill > > > (among other projects). In a nutshell, the plan is to translate Table > API > > > and SQL queries into Calcite's relational expression trees, optimize > > these > > > trees, and translate them into DataSet and DataStream programs.The > > document > > > breaks down the work into several tasks and subtasks. > > > > > > Please review the design document and comment. > > > > > > -- > > > > > > > https://docs.google.com/document/d/1TLayJNOTBle_-m1rQfgA6Ouj1oYsfqRjPcp1h2TVqdI/edit?usp=sharing > > > > > > Unless there are major concerns with the design, Timo and I want to > start > > > next week to move the current Table API on top of Apache Calcite (Task > 1 > > in > > > the document). The goal of this task is to have the same functionality > as > > > currently, but with Calcite in the translation process. This is a > > blocking > > > task that we hope to complete soon. Afterwards, we can independently > work > > > on different aspects such as extending the Table API, adding a SQL > > > interface (basically just a parser), integration with external data > > > sources, better code generation, optimization rules, streaming support > > for > > > the Table API, StreamSQL, etc.. > > > > > > Timo and I plan to work on a WIP branch to implement Task 1 and merge > it > > to > > > the master branch once the task is completed. Of course, everybody is > > > welcome to contribute to this effort. Please let us know such that we > can > > > coordinate our efforts. > > > > > > Thanks, > > > Fabian > > > > > > > > --94eb2c0c047a801c110528c1eaf5--