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 9F18A200BF4 for ; Fri, 6 Jan 2017 08:09:24 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 9DA1B160B37; Fri, 6 Jan 2017 07:09:24 +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 4850C160B1F for ; Fri, 6 Jan 2017 08:09:23 +0100 (CET) Received: (qmail 49418 invoked by uid 500); 6 Jan 2017 07:09:22 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 49408 invoked by uid 99); 6 Jan 2017 07:09:22 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 06 Jan 2017 07:09:22 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id AA2D9C6B94 for ; Fri, 6 Jan 2017 07:09:21 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -3.32 X-Spam-Level: X-Spam-Status: No, score=-3.32 tagged_above=-999 required=6.31 tests=[HTML_MESSAGE=2, RCVD_IN_DNSWL_MED=-2.3, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-2.999, SPF_PASS=-0.001] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id UGaZIg9PmS84 for ; Fri, 6 Jan 2017 07:09:19 +0000 (UTC) Received: from szxga03-in.huawei.com (szxga03-in.huawei.com [119.145.14.66]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 742185F477 for ; Fri, 6 Jan 2017 07:09:16 +0000 (UTC) Received: from 172.24.1.60 (EHLO nkgeml414-hub.china.huawei.com) ([172.24.1.60]) by szxrg03-dlp.huawei.com (MOS 4.4.3-GA FastPath queued) with ESMTP id CNQ16678; Fri, 06 Jan 2017 15:09:05 +0800 (CST) Received: from NKGEML515-MBX.china.huawei.com ([fe80::a54a:89d2:c471:ff]) by nkgeml414-hub.china.huawei.com ([10.98.56.75]) with mapi id 14.03.0235.001; Fri, 6 Jan 2017 15:09:02 +0800 From: Hongyuhong To: "user@flink.apache.org" Subject: Re: Som question about Flink stream sql Thread-Topic: Som question about Flink stream sql Thread-Index: AdJnBXcp307wl2J5RXCLg4az/qTDBP//3xQA//9qX9CAAbe6AP//PTIQ Date: Fri, 6 Jan 2017 07:08:56 +0000 Message-ID: References: In-Reply-To: Accept-Language: en-US Content-Language: zh-CN X-MS-Has-Attach: X-MS-TNEF-Correlator: x-originating-ip: [10.177.21.251] Content-Type: multipart/alternative; boundary="_000_C232E6575B0E304A98E5B6536287CCE275DC3B61NKGEML515MBXchi_" MIME-Version: 1.0 X-CFilter-Loop: Reflected archived-at: Fri, 06 Jan 2017 07:09:24 -0000 --_000_C232E6575B0E304A98E5B6536287CCE275DC3B61NKGEML515MBXchi_ Content-Type: text/plain; charset="gb2312" Content-Transfer-Encoding: base64 VGhhbmtzIEphcmsNCg0KRG8geW91IGhhdmUgYW55IGRlc2lnbiBkb2N1bWVudHMgb3IgaW5zdHJ1 Y3Rpb25zIGFib3V0IHJvdyB3aW5kb3c/IFdlIGFyZSBpbnRlcmVzdGVkIGluIGFkZGluZyBzdXBw b3J0cyBvZiB3aW5kb3cgaW4gc3RyZWFtc3FsIHNpZGUgYW5kIGl0oa9zIGdyZWF0ZSBpZiBjYW4g aGF2ZSBzb21lIHJlZmVyZW5jZS4NClRoYW5rcyB2ZXJ5IG11Y2guDQoNCkJlc3QNCll1aG9uZw0K DQoNCreivP7IyzogSmFyayBXdSBbbWFpbHRvOnd1Y2hvbmcud2NAYWxpYmFiYS1pbmMuY29tXQ0K t6LLzcqxvOQ6IDIwMTfE6jHUwjbI1SAxMTowMQ0KytW8/sjLOiB1c2VyQGZsaW5rLmFwYWNoZS5v cmcNCtb3zOI6IFJlOiBTb20gcXVlc3Rpb24gYWJvdXQgRmxpbmsgc3RyZWFtIHNxbA0KDQpIaSBZ dWhvbmcsDQoNCkkgaGF2ZSBhc3NpZ25lZCBhbiBpc3N1ZSBmb3IgdHVtYmxlIHJvdy13aW5kb3cs IGJ1dCB0aGUgcHJvZ3Jlc3MgaXMgc3RpbGwgdW5kZXIgZGVzaWduIGFuZCBkaXNjdXNzLiBUaGUg aW1wbGVtZW50YXRpb24gb2Ygcm93IHdpbmRvdyBpcyBtb3JlIGNvbXBsZXggdGhhbiBncm91cCB3 aW5kb3cuDQpJIHdpbGwgcHVzaCBmb3J3YXJkIHRoaXMgaXNzdWUgaW4gdGhlIG5leHQgZGF5cy4N Cg0KLSBKYXJrIFd1DQoNCtTaIDIwMTfE6jHUwjXI1aOsz8LO5zc6MDCjrEhvbmd5dWhvbmcgPGhv bmd5dWhvbmdAaHVhd2VpLmNvbTxtYWlsdG86aG9uZ3l1aG9uZ0BodWF3ZWkuY29tPj4g0LS1wKO6 DQoNCkhpIEZhYmlhbiwNCg0KVGhhbmtzIGZvciB0aGUgcmVwbHkuDQpBcyB5b3Ugbm90aWNlZCwg cm93IHdpbmRvd3MgYXJlIGFscmVhZHkgc3VwcG9ydGVkIGJ5IENhbGNpdGUgYW5kIEZMSVAtMTEg aGFzIHBsYW5uZWQsDQpDYW4geW91IHRlbGwgc29tZXRoaW5nIGFib3V0IHRoZSBwcm9ncmVzcyBv ZiB0aGUgcm93IHdpbmRvd3MgaW4gVGFibGUgQVBJPw0KDQpSZWdhcmRzLg0KWXVob25nDQoNCg0K DQoNCreivP7IyzogRmFiaWFuIEh1ZXNrZSBbbWFpbHRvOmZodWVza2VAZ21haWwuY29tXQ0Kt6LL zcqxvOQ6IDIwMTfE6jHUwjXI1SAxNzo0Mw0KytW8/sjLOiB1c2VyQGZsaW5rLmFwYWNoZS5vcmc8 bWFpbHRvOnVzZXJAZmxpbmsuYXBhY2hlLm9yZz4NCtb3zOI6IFJlOiBTb20gcXVlc3Rpb24gYWJv dXQgRmxpbmsgc3RyZWFtIHNxbA0KDQpIaSBZdWhvbmcsDQphcyB5b3Ugbm90aWNlZCwgRkxJUC0x MSBpcyBhYm91dCB0aGUgd2luZG93IG9wZXJhdGlvbnMgb24gdGhlIFRhYmxlIEFQSSBhbmQgZG9l cyBub3QgaW5jbHVkZSBTUUwuDQpUaGUgcmVhc29uIGlzIHRoYXQgdGhlIFRhYmxlIEFQSSBpcyBj b21wbGV0ZWx5IEZsaW5rIGRvbWFpbiwgaS5lLiwgd2UgY2FuIGRlc2lnbiBhbmQgaW1wbGVtZW50 IHRoZSBBUEkuIEZvciBTUUwgd2UgaGF2ZSBhIGRlcGVuZGVuY3kgb24gQ2FsY2l0ZS4NCllvdSBh cmUgcmlnaHQsIHRoYXQgQ2FsY2l0ZSdzIEpJUkEgaXNzdWUgZm9yIGdyb3VwIHdpbmRvd3MgWzFd IHNlZW1zIHRvIGJlIHN0YWxlLiBJIGRvbid0IGhhdmUgbW9yZSBpbmZvcm1hdGlvbiBvbiB0aGF0 LiBZb3UgY291bGQgcGluZyB0aGVyZSBhbmQgYXNrIHdoYXQgdGhlIHN0YXR1cyBpcy4NClJvdyB3 aW5kb3dzIGFyZSBhbHJlYWR5IHN1cHBvcnRlZCBieSBDYWxjaXRlIChTUUwncyBPVkVSIGFuZCBX SU5ET1cgY2xhdXNlcyksIHNvIHRoZXNlIGNvdWxkIGJlIGltcGxlbWVudGVkIGZvciBTUUwgYXMg d2VsbC4NCk1heWJlIGl0J3MgZXZlbiBlYXNpZXIgdG8gc3RhcnQgZnJvbSB0aGUgU1FMIHNpZGUg YW5kIGFkZCB0aGUgVGFibGUgQVBJIGxhdGVyIHRvIGVuc3VyZSBhIGNvbXBhdGlibGUgY29tcGls YXRpb24gcHJvY2Vzcy4NCkJlc3QsIEZhYmlhbg0KDQoNCjIwMTctMDEtMDUgNDo0MCBHTVQrMDE6 MDAgSG9uZ3l1aG9uZyA8aG9uZ3l1aG9uZ0BodWF3ZWkuY29tPG1haWx0bzpob25neXVob25nQGh1 YXdlaS5jb20+PjoNCkhpLA0KV2UgYXJlIGN1cnJlbnRseSBleHBsb3Jpbmcgb24gRmxpbmsgc3Ry ZWFtc3FsICwNCkFuZCBJIHNlZSB0aGUgZ3JvdXAtd2luZG93IGhhcyBiZWVuIGltcGxlbWVudGVk IGluIFRhYmxlIEFQSSwgYW5kIHJvdy13aW5kb3cgaXMgYWxzbyBwbGFubmluZyBpbiBGTElQLTEx LiBJdCBzZWVtcyB0aGF0IHJvdy13aW5kb3cgZ3JhbW1hciBpcyBtb3JlIHNpbWlsYXIgdG8gY2Fs Y2l0ZSBvdmVyIGNsYXVzZS4NCkmhr20gY3VyaW91cyBhYm91dCB0aGUgZGV0YWlsIHBsYW4gYW5k IHJvYWRtYXAgb2Ygc3RyZWFtIHNxbCwgY2F1c2UgRkxJUC0xMSBqdXN0IG1lbnRpb25lZCBUYWJs ZSBBUEkuDQpBbmQgaXMgdGhhdCBzdHJlYW1zcWwgcHJpb3JpdHkgaW1wbGVtZW50IHJvdy13aW5k b3c/IE9yIGlmIGdyb3VwLXdpbmRvdyBpcyBjb25zaWRlcmVkLCB3aGF0IGlzIHRoZSBzdGF0dXMg b24gY2FsY2l0ZSBpbnRlZ3JhdGlvbj8NClRoZSBpc3N1ZSBvbiBjYWxjaXRlIGppcmEgd2FzIHJh aXNlZCBpbiBBdWd1c3QsIHdoYXShr3MgdGhlIHN0YXR1cyByaWdodCBub3c/DQpUaGFua3MgaW4g YWR2YW5jZSENCg0KUmVnYXJkcw0KWXVob25nDQoNCg== --_000_C232E6575B0E304A98E5B6536287CCE275DC3B61NKGEML515MBXchi_ Content-Type: text/html; charset="gb2312" Content-Transfer-Encoding: quoted-printable

Thanks Jar= k

 = ;

Do you hav= e any design documents or instructions about row window? We are interested = in adding supports of window in streamsql side and it=A1=AFs greate if can have some reference.

Thanks ver= y much.

 = ;

Best<= /o:p>

Yuhong

 = ;

 = ;

=B7=A2=BC=FE=C8= =CB: Jark Wu [mailto:wuchong.wc@alibaba-inc.com]
=B7=A2=CB=CD=CA=B1=BC=E4: 2017=C4=EA1=D4=C26=C8=D5 11= :01
=CA=D5=BC=FE=C8=CB: user@flink.apache.org
=D6=F7=CC=E2: Re: Som question about Flink stream sql

 

Hi Yuhong, 

 

I have assigned an issue for tu= mble row-window, but the progress is still under design and discuss. The im= plementation of row window is more complex than group window.

I will push forward this issue = in the next days.

 

- Jark Wu=  

 

=D4=DA 2017=C4=EA1= =D4=C25=C8=D5=A3=AC=CF=C2=CE=E77:00=A3=ACHongyuhong <hongyuhong@huawei.com> =D0=B4=B5=C0=A3=BA

 

Hi Fabian,

 

Thanks for the reply.

As you noticed, row windows are a= lready supported by Calcite and FLIP-11 has planned,

Can you tell something about the = progress of the row windows in Table API?<= /o:p>

 

Regards.

Yuhong

 

 

 

 

=B7=A2=BC=FE=C8=CB= : Fabian Hueske [= mailto:fhueske@gmail.com] 
=B7=A2=CB=CD=CA=B1=BC=E4: 2017=C4=EA1=D4=C25=C8=D5 17:43
=CA=D5=BC=FE=C8=CB: user@flink.apache.org
=D6=F7=CC=E2: Re: Som question about Flink stream sql

 

Hi Yuhong,

as you noticed, FLIP-11 is about the window operations= on the Table API and does not include SQL.

The reason is that the Table API is completely Flink d= omain, i.e., we can design and implement the API. For SQL we have a depende= ncy on Calcite.

You are right, that Calcite's JIRA issue for group win= dows [1] seems to be stale. I don't have more information on that. You coul= d ping there and ask what the status is.

Row windows are already supported by Calcite (SQL's OV= ER and WINDOW clauses), so these could be implemented for SQL as well.=

Maybe it's even easier to start from the SQL side and = add the Table API later to ensure a compatible compilation process.

Best, Fabian

 

 

Hi,

We are currently exploring on Flink streamsql ,

And I see the group-window has been implemented in Tab= le API, and row-window is also planning in FLIP-11. It seems that row-windo= w grammar is more similar to calcite over clause.

I=A1=AFm curious about the= detail plan and roadmap of stream sql, cause FLIP-11 just mentioned Table = API.

And is that streamsql priority implement row-window? O= r if group-window is considered, what is the status on calcite integration?=

The issue on calcite jira was raised in August, what=A1=AFs the status right now?

Thanks in advance!

 

Regards

Yuhong

 

--_000_C232E6575B0E304A98E5B6536287CCE275DC3B61NKGEML515MBXchi_--